formant adjustment

filter/filter_impl/seata_filter.go

@@ -29,7 +29,7 @@ import (
 )
 
 const (
-	SEATA = "SEATA"
+	SEATA     = "SEATA"
 	SEATA_XID = "SEATA_XID"
 )
 
@@ -38,18 +38,18 @@ func init() {
 }
 
 // SeataFilter when use seata-golang, use this filter to transfer xid
-type SeataFilter struct {}
+type SeataFilter struct{}
 
 // When use Seata, transfer xid by attachments
 // Invoke Get Xid by attachment key `SEATA_XID`
 func (sf *SeataFilter) Invoke(ctx context.Context, invoker protocol.Invoker, invocation protocol.Invocation) protocol.Result {
 	logger.Infof("invoking seata filter.")
-	xid := invocation.AttachmentsByKey(SEATA_XID,"")
+	xid := invocation.AttachmentsByKey(SEATA_XID, "")
 	if xid != "" {
 		logger.Debugf("Method: %v,Xid: %v", invocation.MethodName(), xid)
-		return invoker.Invoke(context.WithValue(ctx,SEATA_XID, xid), invocation)
+		return invoker.Invoke(context.WithValue(ctx, SEATA_XID, xid), invocation)
 	}
-	return invoker.Invoke(ctx,invocation)
+	return invoker.Invoke(ctx, invocation)
 }
 
 // OnResponse dummy process, returns the result directly
@@ -60,4 +60,4 @@ func (sf *SeataFilter) OnResponse(ctx context.Context, result protocol.Result, i
 // GetSeataFilter create SeataFilter instance
 func GetSeataFilter() filter.Filter {
 	return &SeataFilter{}
-}
\ No newline at end of file
+}

filter/filter_impl/seata_filter_test.go

@@ -40,7 +40,7 @@ func (iv *testMockSeataInvoker) Invoke(ctx context.Context, _ protocol.Invocatio
 	if val != nil {
 		xid, ok := val.(string)
 		if ok {
-			return &protocol.RPCResult{Rest:xid}
+			return &protocol.RPCResult{Rest: xid}
 		}
 	}
 	return &protocol.RPCResult{}
@@ -53,4 +53,3 @@ func TestSeataFilter_Invoke(t *testing.T) {
 	}))
 	assert.Equal(t, "10.30.21.227:8091:2000047792", result.Result())
 }
-