Merge branch 'master' into feat/kq_trace

kevwan · web-flow · commit ad61cc326963 · 2024-07-15T13:48:47.000+08:00
diff --git a/kq/pusher.go b/kq/pusher.go
@@ -29,7 +29,7 @@ type (
 		chunkSize     int
 		flushInterval time.Duration
 
-		// enable sync push
+		// enableSyncPush is used to enable sync push
 		enableSyncPush bool
 	}
 )
@@ -56,7 +56,7 @@ func NewPusher(addrs []string, topic string, opts ...PushOption) *Pusher {
 		topic:    topic,
 	}
 
-	// apply sync push
+	// if enableSyncPush is true, return the pusher directly
 	if options.enableSyncPush {
 		return pusher
 	}

Original file line number	Diff line number	Diff line change
`@@ -29,7 +29,7 @@ type (`
`29`	`29`	`chunkSize int`
`30`	`30`	`flushInterval time.Duration`
`31`	`31`
`32`		`- // enable sync push`
	`32`	`+ // enableSyncPush is used to enable sync push`
`33`	`33`	`enableSyncPush bool`
`34`	`34`	`}`
`35`	`35`	`)`
`@@ -56,7 +56,7 @@ func NewPusher(addrs []string, topic string, opts ...PushOption) *Pusher {`
`56`	`56`	`topic: topic,`
`57`	`57`	`}`
`58`	`58`
`59`		`- // apply sync push`
	`59`	`+ // if enableSyncPush is true, return the pusher directly`
`60`	`60`	`if options.enableSyncPush {`
`61`	`61`	`return pusher`
`62`	`62`	`}`