plugin

Feb 9, 2023

Changes in this version

type MockLink

+ func (m *MockLink) State() *v1.Message

type MockLinkMockRecorder

+ func (mr *MockLinkMockRecorder) State() *gomock.Call

Oct 15, 2020

Changes in this version

+ type MockLink struct

+ func NewMockLink(ctrl *gomock.Controller) *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

+ type MockLinkMockRecorder struct

+ 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

+ type MockPubsub struct

+ func NewMockPubsub(ctrl *gomock.Controller) *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 struct

+ func (mr *MockPubsubMockRecorder) Close() *gomock.Call

+ func (mr *MockPubsubMockRecorder) Publish(topic, msg interface{}) *gomock.Call

+ func (mr *MockPubsubMockRecorder) Subscribe(topic interface{}) *gomock.Call

+ func (mr *MockPubsubMockRecorder) Unsubscribe(topic, ch interface{}) *gomock.Call