Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

remote

package

Go to main page

Versions in this module

v2

v2.1.2

Jul 3, 2022

v2.1.2-rc1

Jul 3, 2022

v2.1.1

Jul 3, 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