go fmt

Author: zluudg

internal/nats/nats.go

@@ -68,7 +68,7 @@ func Create(conf Conf) (*natsClient, error) {
 		return nil, errors.New("zero ttl")
 	}
 
-    nc.url = conf.Url
+	nc.url = conf.Url
 	nc.bucket = conf.Bucket
 	nc.subjectPrefix = strings.Trim(conf.SubjectPrefix, c_NATS_DELIM)
 	nc.subjectSouthbound = strings.Trim(conf.SubjectSouthbound, c_NATS_DELIM)
@@ -125,7 +125,7 @@ func (nc *natsClient) WatchObservations(ctx context.Context) (<-chan common.Nats
 }
 
 func (nc *natsClient) GetObservations(ctx context.Context, domain string) (uint32, error) {
-    subject := nc.genKeyFilterSubject(domain)
+	subject := nc.genKeyFilterSubject(domain)
 	ls, err := nc.kv.ListKeysFiltered(ctx, subject)
 	if err != nil {
 		nc.log.Error("Couldn't list keys for %s: %s", domain, err)
@@ -134,11 +134,11 @@ func (nc *natsClient) GetObservations(ctx context.Context, domain string) (uint3
 
 	var obs uint32
 	for k := range ls.Keys() {
-        flagUint, err := nc.extractObservationFromKey(k)
-        if err != nil {
-            nc.log.Warning("Couldn't extract observation: %s", err)
-            continue
-        }
+		flagUint, err := nc.extractObservationFromKey(k)
+		if err != nil {
+			nc.log.Warning("Couldn't extract observation: %s", err)
+			continue
+		}
 		obs |= flagUint
 	}
 
@@ -153,26 +153,26 @@ func (nc *natsClient) genKeyFilterSubject(domain string) string {
 	subjectParts := []string{nc.subjectPrefix, c_NATS_WILDCARD, domRev}
 	subject := strings.Join(subjectParts, c_NATS_DELIM)
 
-    return subject
+	return subject
 }
 
 func (nc *natsClient) extractObservationFromKey(key string) (uint32, error) {
-		kSplit := strings.Split(key, c_NATS_DELIM)
-        prefixLen := len(strings.Split(nc.subjectPrefix, c_NATS_DELIM))
+	kSplit := strings.Split(key, c_NATS_DELIM)
+	prefixLen := len(strings.Split(nc.subjectPrefix, c_NATS_DELIM))
 
-		if len(kSplit)-prefixLen < c_MIN_RAW_KEY_LEN {
-			nc.log.Error("Badly formatted key '%s'", key)
-            return 0, common.ErrBadKey
-		}
+	if len(kSplit)-prefixLen < c_MIN_RAW_KEY_LEN {
+		nc.log.Error("Badly formatted key '%s'", key)
+		return 0, common.ErrBadKey
+	}
 
-		flag := kSplit[prefixLen] /* Flag is first label after prefix */
-		flagUint, ok := common.OBS_MAP[flag]
-		if !ok {
-			nc.log.Error("Unrecognized flag '%s'", flag)
-            return 0, common.ErrBadFlag
-		}
+	flag := kSplit[prefixLen] /* Flag is first label after prefix */
+	flagUint, ok := common.OBS_MAP[flag]
+	if !ok {
+		nc.log.Error("Unrecognized flag '%s'", flag)
+		return 0, common.ErrBadFlag
+	}
 
-        return flagUint, nil
+	return flagUint, nil
 }
 
 func (nc *natsClient) initNats() error {

internal/nats/nats_test.go

@@ -87,45 +87,45 @@ func TestRemovePrefix(t *testing.T) {
 
 func TestExtractObservationFromKey(t *testing.T) {
 	tests := map[string]struct {
-		input1 string
-		input2 string
-		expect uint32
+		input1    string
+		input2    string
+		expect    uint32
 		expectErr error
 	}{
 		"globally_new, one label prefix": {
-			input1: "obs",
-			input2: "obs.globally_new.xa.foo",
-			expect: 1,
+			input1:    "obs",
+			input2:    "obs.globally_new.xa.foo",
+			expect:    1,
 			expectErr: nil,
 		},
 		"globally_new, two label prefix": {
-			input1: "obs1.obs2",
-			input2: "obs1.obs2.globally_new.xa.foo",
-			expect: 1,
+			input1:    "obs1.obs2",
+			input2:    "obs1.obs2.globally_new.xa.foo",
+			expect:    1,
 			expectErr: nil,
 		},
 		"bad flag": {
-			input1: "obs1.obs2",
-			input2: "obs1.obs2.bad_flag.xa.foo",
-			expect: 0,
+			input1:    "obs1.obs2",
+			input2:    "obs1.obs2.bad_flag.xa.foo",
+			expect:    0,
 			expectErr: common.ErrBadFlag,
 		},
 		"too short key": {
-			input1: "obs1.obs2",
-			input2: "obs1.obs2.looptest",
-			expect: 0,
+			input1:    "obs1.obs2",
+			input2:    "obs1.obs2.looptest",
+			expect:    0,
 			expectErr: common.ErrBadKey,
 		},
 		"single-label key": {
-			input1: "obs",
-			input2: "obs.looptest.xa",
-			expect: 1024,
+			input1:    "obs",
+			input2:    "obs.looptest.xa",
+			expect:    1024,
 			expectErr: nil,
 		},
 		"long prefix, short domain name": {
-			input1: "a.b.c.d.e.f.g.h.j.k",
-			input2: "a.b.c.d.e.f.g.h.j.k.globally_new.xa",
-			expect: 1,
+			input1:    "a.b.c.d.e.f.g.h.j.k",
+			input2:    "a.b.c.d.e.f.g.h.j.k.globally_new.xa",
+			expect:    1,
 			expectErr: nil,
 		},
 	}
@@ -138,9 +138,9 @@ func TestExtractObservationFromKey(t *testing.T) {
 			}
 
 			got, err := nh.extractObservationFromKey(test.input2)
-            if err != test.expectErr {
+			if err != test.expectErr {
 				t.Fatalf("Got: '%s', Expected: '%s'", err, test.expectErr)
-            }
+			}
 
 			if got != test.expect {
 				t.Fatalf("Got: '%d', Expected: '%d'", got, test.expect)