Documentation
¶
Overview ¶
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Index ¶
- type MockSourcer
- type MockSourcerMockRecorder
- type MockStorager
- type MockStoragerMockRecorder
- type MockStreamer
- func (m *MockStreamer) Check(ctx context.Context, msg eventstream.Message) bool
- func (m *MockStreamer) Close() error
- func (m *MockStreamer) EXPECT() *MockStreamerMockRecorder
- func (m *MockStreamer) ID() string
- func (m *MockStreamer) Put(ctx context.Context, msg eventstream.Message) error
- func (m *MockStreamer) Run(ctx context.Context) error
- type MockStreamerMockRecorder
- func (mr *MockStreamerMockRecorder) Check(ctx, msg any) *gomock.Call
- func (mr *MockStreamerMockRecorder) Close() *gomock.Call
- func (mr *MockStreamerMockRecorder) ID() *gomock.Call
- func (mr *MockStreamerMockRecorder) Put(ctx, msg any) *gomock.Call
- func (mr *MockStreamerMockRecorder) Run(ctx any) *gomock.Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockSourcer ¶
type MockSourcer struct {
// contains filtered or unexported fields
}
MockSourcer is a mock of Sourcer interface
func NewMockSourcer ¶
func NewMockSourcer(ctrl *gomock.Controller) *MockSourcer
NewMockSourcer creates a new mock instance
func (*MockSourcer) EXPECT ¶
func (m *MockSourcer) EXPECT() *MockSourcerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockSourcer) Start ¶
func (m *MockSourcer) Start(ctx context.Context) error
Start mocks base method
func (*MockSourcer) Subscribe ¶
func (m *MockSourcer) Subscribe(ctx context.Context, streams ...eventstream.Streamer) error
Subscribe mocks base method
type MockSourcerMockRecorder ¶
type MockSourcerMockRecorder struct {
// contains filtered or unexported fields
}
MockSourcerMockRecorder is the mock recorder for MockSourcer
func (*MockSourcerMockRecorder) Close ¶
func (mr *MockSourcerMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close
func (*MockSourcerMockRecorder) Start ¶
func (mr *MockSourcerMockRecorder) Start(ctx interface{}) *gomock.Call
Start indicates an expected call of Start
func (*MockSourcerMockRecorder) Subscribe ¶
func (mr *MockSourcerMockRecorder) Subscribe(ctx interface{}, streams ...interface{}) *gomock.Call
Subscribe indicates an expected call of Subscribe
type MockStorager ¶
type MockStorager struct {
// contains filtered or unexported fields
}
MockStorager is a mock of Storager interface
func NewMockStorager ¶
func NewMockStorager(ctrl *gomock.Controller) *MockStorager
NewMockStorager creates a new mock instance
func (*MockStorager) EXPECT ¶
func (m *MockStorager) EXPECT() *MockStoragerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockStorager) Stream ¶
func (m *MockStorager) Stream(opts ...any) (eventstream.Streamer, error)
Stream mocks base method
type MockStoragerMockRecorder ¶
type MockStoragerMockRecorder struct {
// contains filtered or unexported fields
}
MockStoragerMockRecorder is the mock recorder for MockStorager
func (*MockStoragerMockRecorder) Close ¶
func (mr *MockStoragerMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close
func (*MockStoragerMockRecorder) Stream ¶
func (mr *MockStoragerMockRecorder) Stream(opts ...interface{}) *gomock.Call
Stream indicates an expected call of Stream
type MockStreamer ¶
type MockStreamer struct {
// contains filtered or unexported fields
}
MockStreamer is a mock of Streamer interface
func NewMockStreamer ¶
func NewMockStreamer(ctrl *gomock.Controller) *MockStreamer
NewMockStreamer creates a new mock instance
func (*MockStreamer) Check ¶
func (m *MockStreamer) Check(ctx context.Context, msg eventstream.Message) bool
Check mocks base method
func (*MockStreamer) EXPECT ¶
func (m *MockStreamer) EXPECT() *MockStreamerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockStreamer) Put ¶
func (m *MockStreamer) Put(ctx context.Context, msg eventstream.Message) error
Put mocks base method
type MockStreamerMockRecorder ¶
type MockStreamerMockRecorder struct {
// contains filtered or unexported fields
}
MockStreamerMockRecorder is the mock recorder for MockStreamer
func (*MockStreamerMockRecorder) Check ¶
func (mr *MockStreamerMockRecorder) Check(ctx, msg any) *gomock.Call
Check indicates an expected call of Check
func (*MockStreamerMockRecorder) Close ¶
func (mr *MockStreamerMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close
func (*MockStreamerMockRecorder) ID ¶
func (mr *MockStreamerMockRecorder) ID() *gomock.Call
ID indicates an expected call of ID
Source Files