rename

m3db · Oct 6, 2021 · 2300ea9 · 2300ea9
1 parent 79e89eb
commit 2300ea9
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/src/msg/producer/writer/options.go b/src/msg/producer/writer/options.go
@@ -51,7 +51,7 @@ const (
 	// to lower values like 1k ~ 8k.
 	defaultConnectionBufferSize = 2 << 15 // ~65kb
 
-	defaultRetryInitialBackoff = time.Second * 5
+	defaultWriterRetryInitialBackoff = time.Second * 5
 )
 
 // ConnectionOptions configs the connections.
@@ -400,7 +400,7 @@ type writerOptions struct {
 // NewOptions creates Options.
 func NewOptions() Options {
 	messageRetryOpts := retry.NewOptions().
-		SetInitialBackoff(defaultRetryInitialBackoff)
+		SetInitialBackoff(defaultWriterRetryInitialBackoff)
 	return &writerOptions{
 		topicWatchInitTimeout:             defaultTopicWatchInitTimeout,
 		placementOpts:                     placement.NewOptions(),

diff --git a/src/msg/producer/writer/options_test.go b/src/msg/producer/writer/options_test.go
@@ -56,7 +56,7 @@ func TestOptions(t *testing.T) {
 	require.Nil(t, opts.SetInstrumentOptions(nil).InstrumentOptions())
 
 	require.NotNil(t, opts.MessageRetryOptions())
-	require.Equal(t, defaultRetryInitialBackoff, opts.MessageRetryOptions().InitialBackoff())
+	require.Equal(t, defaultWriterRetryInitialBackoff, opts.MessageRetryOptions().InitialBackoff())
 }
 
 func TestConnectionOptions(t *testing.T) {