|
|
@ -96,19 +96,6 @@ func TestDepositServer_Deposit(t *testing.T) {
|
|
|
|
return invoker(ctx, method, req, reply, cc, opts...)
|
|
|
|
return invoker(ctx, method, req, reply, cc, opts...)
|
|
|
|
}),
|
|
|
|
}),
|
|
|
|
)
|
|
|
|
)
|
|
|
|
retryClient := MustNewClient(
|
|
|
|
|
|
|
|
RpcClientConf{
|
|
|
|
|
|
|
|
Endpoints: []string{"foo"},
|
|
|
|
|
|
|
|
App: "foo",
|
|
|
|
|
|
|
|
Token: "bar",
|
|
|
|
|
|
|
|
Timeout: 1000,
|
|
|
|
|
|
|
|
},
|
|
|
|
|
|
|
|
WithDialOption(grpc.WithContextDialer(dialer())),
|
|
|
|
|
|
|
|
WithUnaryClientInterceptor(func(ctx context.Context, method string, req, reply interface{},
|
|
|
|
|
|
|
|
cc *grpc.ClientConn, invoker grpc.UnaryInvoker, opts ...grpc.CallOption) error {
|
|
|
|
|
|
|
|
return invoker(ctx, method, req, reply, cc, opts...)
|
|
|
|
|
|
|
|
}),
|
|
|
|
|
|
|
|
)
|
|
|
|
|
|
|
|
tarConfClient := MustNewClient(
|
|
|
|
tarConfClient := MustNewClient(
|
|
|
|
RpcClientConf{
|
|
|
|
RpcClientConf{
|
|
|
|
Target: "foo",
|
|
|
|
Target: "foo",
|
|
|
@ -133,7 +120,6 @@ func TestDepositServer_Deposit(t *testing.T) {
|
|
|
|
clients := []Client{
|
|
|
|
clients := []Client{
|
|
|
|
directClient,
|
|
|
|
directClient,
|
|
|
|
nonBlockClient,
|
|
|
|
nonBlockClient,
|
|
|
|
retryClient,
|
|
|
|
|
|
|
|
tarConfClient,
|
|
|
|
tarConfClient,
|
|
|
|
targetClient,
|
|
|
|
targetClient,
|
|
|
|
}
|
|
|
|
}
|
|
|
|