Documentation
¶
Overview ¶
Package plugin is a generated GoMock package.
Package plugin is a generated GoMock package.
Index ¶
- type MockLink
- func (m *MockLink) EXPECT() *MockLinkMockRecorder
- func (m *MockLink) IsAsyncSupported() bool
- func (m *MockLink) Receive() (<-chan *v1.Message, <-chan error)
- func (m *MockLink) Request(msg *v1.Message) (*v1.Message, error)
- func (m *MockLink) Send(msg *v1.Message) error
- func (m *MockLink) State() *v1.Message
- type MockLinkMockRecorder
- func (mr *MockLinkMockRecorder) IsAsyncSupported() *gomock.Call
- func (mr *MockLinkMockRecorder) Receive() *gomock.Call
- func (mr *MockLinkMockRecorder) Request(msg interface{}) *gomock.Call
- func (mr *MockLinkMockRecorder) Send(msg interface{}) *gomock.Call
- func (mr *MockLinkMockRecorder) State() *gomock.Call
- type MockPubsub
- func (m *MockPubsub) Close() error
- func (m *MockPubsub) EXPECT() *MockPubsubMockRecorder
- func (m *MockPubsub) Publish(topic string, msg interface{}) error
- func (m *MockPubsub) Subscribe(topic string) (<-chan interface{}, error)
- func (m *MockPubsub) Unsubscribe(topic string, ch <-chan interface{}) error
- type MockPubsubMockRecorder
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockLink ¶
type MockLink struct {
// contains filtered or unexported fields
}
MockLink is a mock of Link interface
func NewMockLink ¶
func NewMockLink(ctrl *gomock.Controller) *MockLink
NewMockLink creates a new mock instance
func (*MockLink) EXPECT ¶
func (m *MockLink) EXPECT() *MockLinkMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockLink) IsAsyncSupported ¶
IsAsyncSupported mocks base method
type MockLinkMockRecorder ¶
type MockLinkMockRecorder struct {
// contains filtered or unexported fields
}
MockLinkMockRecorder is the mock recorder for MockLink
func (*MockLinkMockRecorder) IsAsyncSupported ¶
func (mr *MockLinkMockRecorder) IsAsyncSupported() *gomock.Call
IsAsyncSupported indicates an expected call of IsAsyncSupported
func (*MockLinkMockRecorder) Receive ¶
func (mr *MockLinkMockRecorder) Receive() *gomock.Call
Receive indicates an expected call of Receive
func (*MockLinkMockRecorder) Request ¶
func (mr *MockLinkMockRecorder) Request(msg interface{}) *gomock.Call
Request indicates an expected call of Request
func (*MockLinkMockRecorder) Send ¶
func (mr *MockLinkMockRecorder) Send(msg interface{}) *gomock.Call
Send indicates an expected call of Send
func (*MockLinkMockRecorder) State ¶ added in v2.4.3
func (mr *MockLinkMockRecorder) State() *gomock.Call
State indicates an expected call of State
type MockPubsub ¶
type MockPubsub struct {
// contains filtered or unexported fields
}
MockPubsub is a mock of Pubsub interface
func NewMockPubsub ¶
func NewMockPubsub(ctrl *gomock.Controller) *MockPubsub
NewMockPubsub creates a new mock instance
func (*MockPubsub) EXPECT ¶
func (m *MockPubsub) EXPECT() *MockPubsubMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockPubsub) Publish ¶
func (m *MockPubsub) Publish(topic string, msg interface{}) error
Publish mocks base method
func (*MockPubsub) Subscribe ¶
func (m *MockPubsub) Subscribe(topic string) (<-chan interface{}, error)
Subscribe mocks base method
func (*MockPubsub) Unsubscribe ¶
func (m *MockPubsub) Unsubscribe(topic string, ch <-chan interface{}) error
Unsubscribe mocks base method
type MockPubsubMockRecorder ¶
type MockPubsubMockRecorder struct {
// contains filtered or unexported fields
}
MockPubsubMockRecorder is the mock recorder for MockPubsub
func (*MockPubsubMockRecorder) Close ¶
func (mr *MockPubsubMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close
func (*MockPubsubMockRecorder) Publish ¶
func (mr *MockPubsubMockRecorder) Publish(topic, msg interface{}) *gomock.Call
Publish indicates an expected call of Publish
func (*MockPubsubMockRecorder) Subscribe ¶
func (mr *MockPubsubMockRecorder) Subscribe(topic interface{}) *gomock.Call
Subscribe indicates an expected call of Subscribe
func (*MockPubsubMockRecorder) Unsubscribe ¶
func (mr *MockPubsubMockRecorder) Unsubscribe(topic, ch interface{}) *gomock.Call
Unsubscribe indicates an expected call of Unsubscribe
Source Files