Documentation
¶
Overview ¶
Package transport is a generated GoMock package.
Package transport is a generated GoMock package.
Index ¶
- type MockIncomingPkg
- func (m *MockIncomingPkg) Ack(arg0 ...transport.AcknowledgmentOption) error
- func (m *MockIncomingPkg) EXPECT() *MockIncomingPkgMockRecorder
- func (m *MockIncomingPkg) Headers() map[string]interface{}
- func (m *MockIncomingPkg) Nack(arg0 ...transport.AcknowledgmentOption) error
- func (m *MockIncomingPkg) Origin() string
- func (m *MockIncomingPkg) Payload() []byte
- func (m *MockIncomingPkg) PublishedAt() time.Time
- func (m *MockIncomingPkg) ReceivedAt() time.Time
- func (m *MockIncomingPkg) Reject(arg0 ...transport.AcknowledgmentOption) error
- func (m *MockIncomingPkg) UID() string
- type MockIncomingPkgMockRecorder
- func (mr *MockIncomingPkgMockRecorder) Ack(arg0 ...interface{}) *gomock.Call
- func (mr *MockIncomingPkgMockRecorder) Headers() *gomock.Call
- func (mr *MockIncomingPkgMockRecorder) Nack(arg0 ...interface{}) *gomock.Call
- func (mr *MockIncomingPkgMockRecorder) Origin() *gomock.Call
- func (mr *MockIncomingPkgMockRecorder) Payload() *gomock.Call
- func (mr *MockIncomingPkgMockRecorder) PublishedAt() *gomock.Call
- func (mr *MockIncomingPkgMockRecorder) ReceivedAt() *gomock.Call
- func (mr *MockIncomingPkgMockRecorder) Reject(arg0 ...interface{}) *gomock.Call
- func (mr *MockIncomingPkgMockRecorder) UID() *gomock.Call
- type MockTransport
- func (m *MockTransport) Consume(arg0 context.Context, arg1 []transport.Queue, arg2 ...transport.ConsumeOpt) (<-chan transport.IncomingPkg, error)
- func (m *MockTransport) CreateQueue(arg0 context.Context, arg1 transport.Queue, arg2 ...transport.QueueBind) error
- func (m *MockTransport) CreateTopic(arg0 context.Context, arg1 transport.Topic) error
- func (m *MockTransport) Disconnect(arg0 context.Context) error
- func (m *MockTransport) EXPECT() *MockTransportMockRecorder
- func (m *MockTransport) Send(arg0 context.Context, arg1 transport.OutboundPkg, arg2 ...transport.SendOpt) error
- type MockTransportMockRecorder
- func (mr *MockTransportMockRecorder) Consume(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockTransportMockRecorder) CreateQueue(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockTransportMockRecorder) CreateTopic(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockTransportMockRecorder) Disconnect(arg0 interface{}) *gomock.Call
- func (mr *MockTransportMockRecorder) Send(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockIncomingPkg ¶
type MockIncomingPkg struct {
// contains filtered or unexported fields
}
MockIncomingPkg is a mock of IncomingPkg interface.
func NewMockIncomingPkg ¶
func NewMockIncomingPkg(ctrl *gomock.Controller) *MockIncomingPkg
NewMockIncomingPkg creates a new mock instance.
func (*MockIncomingPkg) Ack ¶
func (m *MockIncomingPkg) Ack(arg0 ...transport.AcknowledgmentOption) error
Ack mocks base method.
func (*MockIncomingPkg) EXPECT ¶
func (m *MockIncomingPkg) EXPECT() *MockIncomingPkgMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockIncomingPkg) Headers ¶
func (m *MockIncomingPkg) Headers() map[string]interface{}
Headers mocks base method.
func (*MockIncomingPkg) Nack ¶
func (m *MockIncomingPkg) Nack(arg0 ...transport.AcknowledgmentOption) error
Nack mocks base method.
func (*MockIncomingPkg) Origin ¶
func (m *MockIncomingPkg) Origin() string
Origin mocks base method.
func (*MockIncomingPkg) Payload ¶
func (m *MockIncomingPkg) Payload() []byte
Payload mocks base method.
func (*MockIncomingPkg) PublishedAt ¶
func (m *MockIncomingPkg) PublishedAt() time.Time
PublishedAt mocks base method.
func (*MockIncomingPkg) ReceivedAt ¶
func (m *MockIncomingPkg) ReceivedAt() time.Time
ReceivedAt mocks base method.
func (*MockIncomingPkg) Reject ¶
func (m *MockIncomingPkg) Reject(arg0 ...transport.AcknowledgmentOption) error
Reject mocks base method.
type MockIncomingPkgMockRecorder ¶
type MockIncomingPkgMockRecorder struct {
// contains filtered or unexported fields
}
MockIncomingPkgMockRecorder is the mock recorder for MockIncomingPkg.
func (*MockIncomingPkgMockRecorder) Ack ¶
func (mr *MockIncomingPkgMockRecorder) Ack(arg0 ...interface{}) *gomock.Call
Ack indicates an expected call of Ack.
func (*MockIncomingPkgMockRecorder) Headers ¶
func (mr *MockIncomingPkgMockRecorder) Headers() *gomock.Call
Headers indicates an expected call of Headers.
func (*MockIncomingPkgMockRecorder) Nack ¶
func (mr *MockIncomingPkgMockRecorder) Nack(arg0 ...interface{}) *gomock.Call
Nack indicates an expected call of Nack.
func (*MockIncomingPkgMockRecorder) Origin ¶
func (mr *MockIncomingPkgMockRecorder) Origin() *gomock.Call
Origin indicates an expected call of Origin.
func (*MockIncomingPkgMockRecorder) Payload ¶
func (mr *MockIncomingPkgMockRecorder) Payload() *gomock.Call
Payload indicates an expected call of Payload.
func (*MockIncomingPkgMockRecorder) PublishedAt ¶
func (mr *MockIncomingPkgMockRecorder) PublishedAt() *gomock.Call
PublishedAt indicates an expected call of PublishedAt.
func (*MockIncomingPkgMockRecorder) ReceivedAt ¶
func (mr *MockIncomingPkgMockRecorder) ReceivedAt() *gomock.Call
ReceivedAt indicates an expected call of ReceivedAt.
func (*MockIncomingPkgMockRecorder) Reject ¶
func (mr *MockIncomingPkgMockRecorder) Reject(arg0 ...interface{}) *gomock.Call
Reject indicates an expected call of Reject.
func (*MockIncomingPkgMockRecorder) UID ¶
func (mr *MockIncomingPkgMockRecorder) UID() *gomock.Call
UID indicates an expected call of UID.
type MockTransport ¶
type MockTransport struct {
// contains filtered or unexported fields
}
MockTransport is a mock of Transport interface.
func NewMockTransport ¶
func NewMockTransport(ctrl *gomock.Controller) *MockTransport
NewMockTransport creates a new mock instance.
func (*MockTransport) Consume ¶
func (m *MockTransport) Consume(arg0 context.Context, arg1 []transport.Queue, arg2 ...transport.ConsumeOpt) (<-chan transport.IncomingPkg, error)
Consume mocks base method.
func (*MockTransport) CreateQueue ¶
func (m *MockTransport) CreateQueue(arg0 context.Context, arg1 transport.Queue, arg2 ...transport.QueueBind) error
CreateQueue mocks base method.
func (*MockTransport) CreateTopic ¶
CreateTopic mocks base method.
func (*MockTransport) Disconnect ¶
func (m *MockTransport) Disconnect(arg0 context.Context) error
Disconnect mocks base method.
func (*MockTransport) EXPECT ¶
func (m *MockTransport) EXPECT() *MockTransportMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockTransport) Send ¶
func (m *MockTransport) Send(arg0 context.Context, arg1 transport.OutboundPkg, arg2 ...transport.SendOpt) error
Send mocks base method.
type MockTransportMockRecorder ¶
type MockTransportMockRecorder struct {
// contains filtered or unexported fields
}
MockTransportMockRecorder is the mock recorder for MockTransport.
func (*MockTransportMockRecorder) Consume ¶
func (mr *MockTransportMockRecorder) Consume(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
Consume indicates an expected call of Consume.
func (*MockTransportMockRecorder) CreateQueue ¶
func (mr *MockTransportMockRecorder) CreateQueue(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
CreateQueue indicates an expected call of CreateQueue.
func (*MockTransportMockRecorder) CreateTopic ¶
func (mr *MockTransportMockRecorder) CreateTopic(arg0, arg1 interface{}) *gomock.Call
CreateTopic indicates an expected call of CreateTopic.
func (*MockTransportMockRecorder) Disconnect ¶
func (mr *MockTransportMockRecorder) Disconnect(arg0 interface{}) *gomock.Call
Disconnect indicates an expected call of Disconnect.
func (*MockTransportMockRecorder) Send ¶
func (mr *MockTransportMockRecorder) Send(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
Send indicates an expected call of Send.
Source Files