Versions in this module Expand all Collapse all v2 v2.1.2 Sep 9, 2022 v2.1.1 Sep 9, 2022 Changes in this version + const JsonCodecs + const RPCOneWay + const RPCType + const ResponseType + const RocketMQCodecs + var DefaultRemotingClientConfig = RemotingClientConfig + func ACLInterceptor(credentials primitive.Credentials) primitive.Interceptor + func NewRemotingClient(config *RemotingClientConfig) *remotingClient + type ClientRequestFunc func(*RemotingCommand, net.Addr) *RemotingCommand + type CustomHeader interface + Encode func() map[string]string + type LanguageCode byte + func (lc *LanguageCode) UnmarshalJSON(b []byte) error + func (lc LanguageCode) MarshalJSON() ([]byte, error) + func (lc LanguageCode) String() string + type MockRemotingClient struct + func NewMockRemotingClient(ctrl *gomock.Controller) *MockRemotingClient + func (m *MockRemotingClient) EXPECT() *MockRemotingClientMockRecorder + func (m *MockRemotingClient) InvokeAsync(ctx context.Context, addr string, request *RemotingCommand, ...) error + func (m *MockRemotingClient) InvokeOneWay(ctx context.Context, addr string, request *RemotingCommand) error + func (m *MockRemotingClient) InvokeSync(ctx context.Context, addr string, request *RemotingCommand) (*RemotingCommand, error) + func (m *MockRemotingClient) RegisterInterceptor(interceptors ...primitive.Interceptor) + func (m *MockRemotingClient) RegisterRequestFunc(code int16, f ClientRequestFunc) + func (m *MockRemotingClient) ShutDown() + type MockRemotingClientMockRecorder struct + func (mr *MockRemotingClientMockRecorder) InvokeAsync(ctx, addr, request, callback interface{}) *gomock.Call + func (mr *MockRemotingClientMockRecorder) InvokeOneWay(ctx, addr, request interface{}) *gomock.Call + func (mr *MockRemotingClientMockRecorder) InvokeSync(ctx, addr, request interface{}) *gomock.Call + func (mr *MockRemotingClientMockRecorder) RegisterInterceptor(interceptors ...interface{}) *gomock.Call + func (mr *MockRemotingClientMockRecorder) RegisterRequestFunc(code, f interface{}) *gomock.Call + func (mr *MockRemotingClientMockRecorder) ShutDown() *gomock.Call + type RPCHook interface + DoAfterResponse func(string, *RemotingCommand) + DoBeforeRequest func(string, *RemotingCommand) + type RemotingClient interface + InvokeAsync func(ctx context.Context, addr string, request *RemotingCommand, ...) error + InvokeOneWay func(ctx context.Context, addr string, request *RemotingCommand) error + InvokeSync func(ctx context.Context, addr string, request *RemotingCommand) (*RemotingCommand, error) + RegisterInterceptor func(interceptors ...primitive.Interceptor) + RegisterRequestFunc func(code int16, f ClientRequestFunc) + ShutDown func() + type RemotingClientConfig struct + type RemotingCommand struct + Body []byte + Code int16 + ExtFields map[string]string + Flag int32 + Language LanguageCode + Opaque int32 + Remark string + Version int16 + func NewRemotingCommand(code int16, header CustomHeader, body []byte) *RemotingCommand + func (command *RemotingCommand) String() string + func (command *RemotingCommand) WriteTo(w io.Writer) error + type ResponseFuture struct + Done chan bool + Err error + Opaque int32 + ResponseCommand *RemotingCommand + func NewResponseFuture(ctx context.Context, opaque int32, callback func(*ResponseFuture)) *ResponseFuture + type TcpOption struct + ConnectionTimeout time.Duration + KeepAliveDuration time.Duration + ReadTimeout time.Duration + WriteTimeout time.Duration