Documentation ¶
Index ¶
- func Response(service string, response []MockResponse) client.Option
- type MockClient
- func (m *MockClient) Call(ctx context.Context, req client.Request, rsp interface{}, ...) error
- func (m *MockClient) CallRemote(ctx context.Context, addr string, req client.Request, rsp interface{}, ...) error
- func (m *MockClient) Init(opts ...client.Option) error
- func (m *MockClient) NewJsonRequest(service, method string, req interface{}, reqOpts ...client.RequestOption) client.Request
- func (m *MockClient) NewProtoRequest(service, method string, req interface{}, reqOpts ...client.RequestOption) client.Request
- func (m *MockClient) NewPublication(topic string, msg interface{}) client.Publication
- func (m *MockClient) NewRequest(service, method string, req interface{}, reqOpts ...client.RequestOption) client.Request
- func (m *MockClient) Options() client.Options
- func (m *MockClient) Publish(ctx context.Context, p client.Publication, opts ...client.PublishOption) error
- func (m *MockClient) Stream(ctx context.Context, req client.Request, opts ...client.CallOption) (client.Streamer, error)
- func (m *MockClient) StreamRemote(ctx context.Context, addr string, req client.Request, ...) (client.Streamer, error)
- func (m *MockClient) String() string
- type MockResponse
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type MockClient ¶
type MockClient struct { Client client.Client Opts client.Options sync.Mutex Response map[string][]MockResponse }
func NewClient ¶
func NewClient(opts ...client.Option) *MockClient
func (*MockClient) Call ¶
func (m *MockClient) Call(ctx context.Context, req client.Request, rsp interface{}, opts ...client.CallOption) error
func (*MockClient) CallRemote ¶
func (m *MockClient) CallRemote(ctx context.Context, addr string, req client.Request, rsp interface{}, opts ...client.CallOption) error
func (*MockClient) NewJsonRequest ¶
func (m *MockClient) NewJsonRequest(service, method string, req interface{}, reqOpts ...client.RequestOption) client.Request
func (*MockClient) NewProtoRequest ¶
func (m *MockClient) NewProtoRequest(service, method string, req interface{}, reqOpts ...client.RequestOption) client.Request
func (*MockClient) NewPublication ¶
func (m *MockClient) NewPublication(topic string, msg interface{}) client.Publication
func (*MockClient) NewRequest ¶
func (m *MockClient) NewRequest(service, method string, req interface{}, reqOpts ...client.RequestOption) client.Request
func (*MockClient) Options ¶
func (m *MockClient) Options() client.Options
func (*MockClient) Publish ¶
func (m *MockClient) Publish(ctx context.Context, p client.Publication, opts ...client.PublishOption) error
func (*MockClient) Stream ¶
func (m *MockClient) Stream(ctx context.Context, req client.Request, opts ...client.CallOption) (client.Streamer, error)
func (*MockClient) StreamRemote ¶
func (*MockClient) String ¶
func (m *MockClient) String() string
type MockResponse ¶
Click to show internal directories.
Click to hide internal directories.