add more logs

README.md

@@ -90,4 +90,8 @@ When a Pod becomes unready, the controller will remove it from the hashring.
 This behaviour can be considered for use alongside the [Ketama hashing algorithm](https://thanos.io/tip/components/receive.md/#ketama-recommended).
 
 ## About the `--use-az-aware-hashring` flag
-By default, the controller does not support
+By default, the controller does not support az aware hashring introduced in Thanos v0.32+ (https://thanos.io/tip/components/receive.md/#az-aware-ketama-hashring-experimental),
+This flag allows the user to enable this behaviour.
+When enabled, the controller will generate az aware hashring configuration based on the `--pod-az-annotation-key` flag, namely the value of the annotation key will be used as the az name for each pod.
+If not specified, the statefulset name will be used as AZ field.
+Note that Thanos has be upgraded to v0.32+ to work with new hashring endpoint struct.

main.go

@@ -593,6 +593,7 @@ func (c *controller) sync(ctx context.Context) {
 		}
 		// Append the new value to the slice associated with the key
 		statefulsets[hashring] = append(statefulsets[hashring], sts.DeepCopy())
+		level.Info(c.logger).Log("Hashring ", hashring, " got a statefulset: ", sts.Name)
 
 		time.Sleep(c.options.scaleTimeout) // Give some time for all replicas before they receive hundreds req/s
 	}
@@ -697,7 +698,7 @@ func (c *controller) populate(ctx context.Context, hashrings []receive.HashringC
 				}
 
 				endpoints = append(endpoints, endpoint)
-
+				level.Info(c.logger).Log("Hashring ", h.Hashring, " got an endpoint: ", endpoint.Address, "with AZ", endpoint.AZ)
 			}
 		}
 
@@ -825,8 +826,8 @@ func newQueue() *queue {
 }
 
 func (q *queue) add() {
-	q.Lock()
-	defer q.Unlock()
+	q.Mutex.Lock()
+	defer q.Mutex.Unlock()
 
 	if !q.ok {
 		return
@@ -838,8 +839,8 @@ func (q *queue) add() {
 }
 
 func (q *queue) stop() {
-	q.Lock()
-	defer q.Unlock()
+	q.Mutex.Lock()
+	defer q.Mutex.Unlock()
 
 	if !q.ok {
 		return
@@ -851,8 +852,8 @@ func (q *queue) stop() {
 
 func (q *queue) get() bool {
 	<-q.ch
-	q.Lock()
-	defer q.Unlock()
+	q.Mutex.Lock()
+	defer q.Mutex.Unlock()
 
 	return q.ok
 }