change plugin logic

ming535 · ming535 · commit 831b2d594048 · 2019-02-26T11:41:08.000+08:00
diff --git a/main.go b/main.go
@@ -29,7 +29,10 @@ func (f *myFilter) Configure(data map[string]interface{}) error {
 }
 
 func (f *myFilter) Filter(msg *core.Msg) (bool, error) {
-	msg.DmlMsg.Data["v"] = 100
+	for k := range msg.DmlMsg.Data {
+		msg.DmlMsg.Data[k] = "hello grpc"
+	}
+
 	return true, nil
 }
 

Original file line number	Diff line number	Diff line change
`@@ -29,7 +29,10 @@ func (f *myFilter) Configure(data map[string]interface{}) error {`
`29`	`29`	`}`
`30`	`30`
`31`	`31`	`func (f myFilter) Filter(msg core.Msg) (bool, error) {`
`32`		`- msg.DmlMsg.Data["v"] = 100`
	`32`	`+ for k := range msg.DmlMsg.Data {`
	`33`	`+ msg.DmlMsg.Data[k] = "hello grpc"`
	`34`	`+ }`
	`35`	`+`
`33`	`36`	`return true, nil`
`34`	`37`	`}`
`35`	`38`