Chore: logging before produce

asheswook · asheswook · commit 5ba78b0d6a17 · 2024-07-24T14:48:20.000+09:00
diff --git a/internal/queue/kafka/operator.go b/internal/queue/kafka/operator.go
@@ -314,7 +314,7 @@ func (k *BytesProduceOperator) Produce(message []byte) error {
 		return err
 	}
 
-	if test.status == "success" {
+	if test.Status == "success" {
 		count.Add(1)
 	}
 
@@ -333,6 +333,5 @@ func (k *BytesProduceOperator) Produce(message []byte) error {
 }
 
 type testStruct struct {
-	requestId string
-	status    string
+	Status string `json:"status"`
 }

Original file line number	Diff line number	Diff line change
`@@ -314,7 +314,7 @@ func (k *BytesProduceOperator) Produce(message []byte) error {`
`314`	`314`	`return err`
`315`	`315`	`}`
`316`	`316`
`317`		`- if test.status == "success" {`
	`317`	`+ if test.Status == "success" {`
`318`	`318`	`count.Add(1)`
`319`	`319`	`}`
`320`	`320`
`@@ -333,6 +333,5 @@ func (k *BytesProduceOperator) Produce(message []byte) error {`
`333`	`333`	`}`
`334`	`334`
`335`	`335`	`type testStruct struct {`
`336`		`- requestId string`
`337`		`- status string`
	`336`	+ Status string `json:"status"`
`338`	`337`	`}`