Documentation
¶
Overview ¶
Package streammock is a generated GoMock package.
Index ¶
- type MockWriter
- type MockWriterMockRecorder
- type MockWriterWriteBatchCall
- func (c *MockWriterWriteBatchCall) Do(f func(context.Context, string, []stream.Message) (int, error)) *MockWriterWriteBatchCall
- func (c *MockWriterWriteBatchCall) DoAndReturn(f func(context.Context, string, []stream.Message) (int, error)) *MockWriterWriteBatchCall
- func (c *MockWriterWriteBatchCall) Return(arg0 int, arg1 error) *MockWriterWriteBatchCall
- type MockWriterWriteCall
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockWriter ¶
type MockWriter struct {
// contains filtered or unexported fields
}
MockWriter is a mock of Writer interface.
func NewMockWriter ¶
func NewMockWriter(ctrl *gomock.Controller) *MockWriter
NewMockWriter creates a new mock instance.
func (*MockWriter) EXPECT ¶
func (m *MockWriter) EXPECT() *MockWriterMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockWriter) WriteBatch ¶
func (m *MockWriter) WriteBatch(ctx context.Context, name string, messages []stream.Message) (int, error)
WriteBatch mocks base method.
type MockWriterMockRecorder ¶
type MockWriterMockRecorder struct {
// contains filtered or unexported fields
}
MockWriterMockRecorder is the mock recorder for MockWriter.
func (*MockWriterMockRecorder) Write ¶
func (mr *MockWriterMockRecorder) Write(ctx, name, message any) *MockWriterWriteCall
Write indicates an expected call of Write.
func (*MockWriterMockRecorder) WriteBatch ¶
func (mr *MockWriterMockRecorder) WriteBatch(ctx, name, messages any) *MockWriterWriteBatchCall
WriteBatch indicates an expected call of WriteBatch.
type MockWriterWriteBatchCall ¶
MockWriterWriteBatchCall wrap *gomock.Call
func (*MockWriterWriteBatchCall) Do ¶
func (c *MockWriterWriteBatchCall) Do(f func(context.Context, string, []stream.Message) (int, error)) *MockWriterWriteBatchCall
Do rewrite *gomock.Call.Do
func (*MockWriterWriteBatchCall) DoAndReturn ¶
func (c *MockWriterWriteBatchCall) DoAndReturn(f func(context.Context, string, []stream.Message) (int, error)) *MockWriterWriteBatchCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockWriterWriteBatchCall) Return ¶
func (c *MockWriterWriteBatchCall) Return(arg0 int, arg1 error) *MockWriterWriteBatchCall
Return rewrite *gomock.Call.Return
type MockWriterWriteCall ¶
MockWriterWriteCall wrap *gomock.Call
func (*MockWriterWriteCall) Do ¶
func (c *MockWriterWriteCall) Do(f func(context.Context, string, stream.Message) error) *MockWriterWriteCall
Do rewrite *gomock.Call.Do
func (*MockWriterWriteCall) DoAndReturn ¶
func (c *MockWriterWriteCall) DoAndReturn(f func(context.Context, string, stream.Message) error) *MockWriterWriteCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockWriterWriteCall) Return ¶
func (c *MockWriterWriteCall) Return(arg0 error) *MockWriterWriteCall
Return rewrite *gomock.Call.Return
Source Files