Add prefix in options of loki syncer

syncer_loki.go

@@ -62,33 +62,33 @@ func WithLokiPassword(pass string) LokiSyncerOption {
 	}
 }
 
-// WithClientTls provide loki http client TLS config
-func WithClientTls(conf *tls.Config) LokiSyncerOption {
+// WithLokiClientTls provide loki http client TLS config
+func WithLokiClientTls(conf *tls.Config) LokiSyncerOption {
 	return func(syncer *lokiSyncer) {
 		syncer.tlsConfig = conf
 	}
 }
 
-// WithLabel provide labels, should follow isValidLabelName()
-func WithLabel(key, value string) LokiSyncerOption {
+// WithLokiLabel provide labels, should follow isValidLabelName()
+func WithLokiLabel(key, value string) LokiSyncerOption {
 	return func(syncer *lokiSyncer) {
 		if len(key) > 0 && len(value) > 0 {
 			syncer.labels[key] = value
 		}
 	}
 }
 
-// WithMaxBatchWaitMs provide max batch wait time in milli
-func WithMaxBatchWaitMs(in time.Duration) LokiSyncerOption {
+// WithLokiMaxBatchWaitMs provide max batch wait time in milli
+func WithLokiMaxBatchWaitMs(in time.Duration) LokiSyncerOption {
 	return func(syncer *lokiSyncer) {
 		if in.Milliseconds() > 0 {
 			syncer.maxBatchWaitMs = in
 		}
 	}
 }
 
-// WithMaxBatchSize provide max batch size
-func WithMaxBatchSize(batchSize int) LokiSyncerOption {
+// WithLokiMaxBatchSize provide max batch size
+func WithLokiMaxBatchSize(batchSize int) LokiSyncerOption {
 	return func(syncer *lokiSyncer) {
 		if batchSize > 0 {
 			syncer.maxBatchSize = batchSize

syncer_loki_test.go

@@ -37,10 +37,10 @@ func TestNewLokiSyncer(t *testing.T) {
 		WithLokiPath("ut-path"),
 		WithLokiUsername("ut-name"),
 		WithLokiPassword("ut-pass"),
-		WithClientTls(&tls.Config{}),
-		WithLabel("key", "value"),
-		WithMaxBatchWaitMs(time.Second),
-		WithMaxBatchSize(10))
+		WithLokiClientTls(&tls.Config{}),
+		WithLokiLabel("key", "value"),
+		WithLokiMaxBatchWaitMs(time.Second),
+		WithLokiMaxBatchSize(10))
 	assert.Equal(t, "https://ut-addr", syncer.addr)
 	assert.Equal(t, "ut-path", syncer.path)
 	assert.NotEmpty(t, syncer.basicAuthHeader)