minor rewrite

datazip-inc · Nov 7, 2024 · 402b11b · 402b11b
1 parent e8d5350
commit 402b11b
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/protocol/writers.go b/protocol/writers.go
@@ -32,7 +32,7 @@ func NewWriter(ctx context.Context, config *types.WriterConfig) (*WriterPool, er
 	}
 
 	adapter := newfunc()
-	if err := utils.Unmarshal(config.AdapterConfig, adapter.GetConfigRef()); err != nil {
+	if err := utils.Unmarshal(config.WriterConfig, adapter.GetConfigRef()); err != nil {
 		return nil, err
 	}
 
@@ -45,7 +45,7 @@ func NewWriter(ctx context.Context, config *types.WriterConfig) (*WriterPool, er
 	return &WriterPool{
 		recordCount:   atomic.Int64{},
 		threadCounter: atomic.Int64{},
-		config:        config.AdapterConfig,
+		config:        config.WriterConfig,
 		init:          newfunc,
 		group:         group,
 		groupCtx:      ctx,

diff --git a/types/adapter.go b/types/adapter.go
@@ -10,6 +10,6 @@ const (
 
 // TODO: Add validations
 type WriterConfig struct {
-	Type          AdapterType `json:"type"`
-	AdapterConfig any         `json:"adapter"`
+	Type         AdapterType `json:"type"`
+	WriterConfig any         `json:"writer"`
 }