diff --git a/filter/filter_impl/active_filter_test.go b/filter/filter_impl/active_filter_test.go index d73a392b862eb3d5204a155cc8c0cf39104280aa..5d3ac9d95303e6abf0488c1186533796fd44feea 100644 --- a/filter/filter_impl/active_filter_test.go +++ b/filter/filter_impl/active_filter_test.go @@ -28,7 +28,7 @@ func TestActiveFilter_Invoke(t *testing.T) { invoker := mock.NewMockInvoker(ctrl) invoker.EXPECT().Invoke(gomock.Any()).Return(nil) invoker.EXPECT().GetUrl().Return(url).Times(1) - filter.Invoke(context.TODO(), invoker, invoc) + filter.Invoke(context.TODO(), invoker, invoc) assert.True(t, invoc.AttachmentsByKey(dubboInvokeStartTime, "") != "") } diff --git a/filter/filter_impl/hystrix_filter_test.go b/filter/filter_impl/hystrix_filter_test.go index 6c4dda00ab9a771b308b4e4bdc1eadf5e5362788..f876c616d2ef50ee70e3bf8b6c8c7e7cb7caab57 100644 --- a/filter/filter_impl/hystrix_filter_test.go +++ b/filter/filter_impl/hystrix_filter_test.go @@ -145,7 +145,7 @@ func (iv *testMockFailInvoker) Invoke(ctx context.Context, invocation protocol.I func TestHystrixFilter_Invoke_Success(t *testing.T) { hf := &HystrixFilter{} - result := hf.Invoke(context.TODO(), &testMockSuccessInvoker{}, &invocation.RPCInvocation{}) + result := hf.Invoke(context.TODO(), &testMockSuccessInvoker{}, &invocation.RPCInvocation{}) assert.NotNil(t, result) assert.NoError(t, result.Error()) assert.NotNil(t, result.Result()) @@ -153,7 +153,7 @@ func TestHystrixFilter_Invoke_Success(t *testing.T) { func TestHystrixFilter_Invoke_Fail(t *testing.T) { hf := &HystrixFilter{} - result := hf.Invoke(context.TODO(), &testMockFailInvoker{}, &invocation.RPCInvocation{}) + result := hf.Invoke(context.TODO(), &testMockFailInvoker{}, &invocation.RPCInvocation{}) assert.NotNil(t, result) assert.Error(t, result.Error()) } @@ -165,7 +165,7 @@ func TestHystricFilter_Invoke_CircuitBreak(t *testing.T) { resChan := make(chan protocol.Result, 50) for i := 0; i < 50; i++ { go func() { - result := hf.Invoke(context.TODO(), &testMockFailInvoker{}, &invocation.RPCInvocation{}) + result := hf.Invoke(context.TODO(), &testMockFailInvoker{}, &invocation.RPCInvocation{}) resChan <- result }() } @@ -190,7 +190,7 @@ func TestHystricFilter_Invoke_CircuitBreak_Omit_Exception(t *testing.T) { resChan := make(chan protocol.Result, 50) for i := 0; i < 50; i++ { go func() { - result := hf.Invoke(context.TODO(), &testMockFailInvoker{}, &invocation.RPCInvocation{}) + result := hf.Invoke(context.TODO(), &testMockFailInvoker{}, &invocation.RPCInvocation{}) resChan <- result }() }