Documentation ¶
Overview ¶
Package mock is a generated GoMock package.
Package mock is a generated GoMock package.
Package mock is a generated GoMock package.
Package mock is a generated GoMock package.
Index ¶
- type DLQHandler
- type DLQHandlerCloseCall
- type DLQHandlerMockRecorder
- type DLQHandlerOpenCall
- type DLQHandlerWriteCall
- type Destination
- func (m *Destination) Ack(arg0 context.Context) ([]connector.DestinationAck, error)
- func (m *Destination) EXPECT() *DestinationMockRecorder
- func (m *Destination) Errors() <-chan error
- func (m *Destination) ID() string
- func (m *Destination) Open(arg0 context.Context) error
- func (m *Destination) Stop(arg0 context.Context, arg1 opencdc.Position) error
- func (m *Destination) Teardown(arg0 context.Context) error
- func (m *Destination) Write(arg0 context.Context, arg1 []opencdc.Record) error
- type DestinationAckCall
- func (c *DestinationAckCall) Do(f func(context.Context) ([]connector.DestinationAck, error)) *DestinationAckCall
- func (c *DestinationAckCall) DoAndReturn(f func(context.Context) ([]connector.DestinationAck, error)) *DestinationAckCall
- func (c *DestinationAckCall) Return(arg0 []connector.DestinationAck, arg1 error) *DestinationAckCall
- type DestinationErrorsCall
- type DestinationIDCall
- type DestinationMockRecorder
- func (mr *DestinationMockRecorder) Ack(arg0 any) *DestinationAckCall
- func (mr *DestinationMockRecorder) Errors() *DestinationErrorsCall
- func (mr *DestinationMockRecorder) ID() *DestinationIDCall
- func (mr *DestinationMockRecorder) Open(arg0 any) *DestinationOpenCall
- func (mr *DestinationMockRecorder) Stop(arg0, arg1 any) *DestinationStopCall
- func (mr *DestinationMockRecorder) Teardown(arg0 any) *DestinationTeardownCall
- func (mr *DestinationMockRecorder) Write(arg0, arg1 any) *DestinationWriteCall
- type DestinationOpenCall
- type DestinationStopCall
- type DestinationTeardownCall
- type DestinationWriteCall
- type Processor
- type ProcessorMockRecorder
- type ProcessorOpenCall
- type ProcessorProcessCall
- func (c *ProcessorProcessCall) Do(f func(context.Context, []opencdc.Record) []sdk.ProcessedRecord) *ProcessorProcessCall
- func (c *ProcessorProcessCall) DoAndReturn(f func(context.Context, []opencdc.Record) []sdk.ProcessedRecord) *ProcessorProcessCall
- func (c *ProcessorProcessCall) Return(arg0 []sdk.ProcessedRecord) *ProcessorProcessCall
- type ProcessorTeardownCall
- type Source
- func (m *Source) Ack(arg0 context.Context, arg1 []opencdc.Position) error
- func (m *Source) EXPECT() *SourceMockRecorder
- func (m *Source) Errors() <-chan error
- func (m *Source) ID() string
- func (m *Source) Open(arg0 context.Context) error
- func (m *Source) Read(arg0 context.Context) ([]opencdc.Record, error)
- func (m *Source) Stop(arg0 context.Context) (opencdc.Position, error)
- func (m *Source) Teardown(arg0 context.Context) error
- type SourceAckCall
- type SourceErrorsCall
- type SourceIDCall
- type SourceMockRecorder
- func (mr *SourceMockRecorder) Ack(arg0, arg1 any) *SourceAckCall
- func (mr *SourceMockRecorder) Errors() *SourceErrorsCall
- func (mr *SourceMockRecorder) ID() *SourceIDCall
- func (mr *SourceMockRecorder) Open(arg0 any) *SourceOpenCall
- func (mr *SourceMockRecorder) Read(arg0 any) *SourceReadCall
- func (mr *SourceMockRecorder) Stop(arg0 any) *SourceStopCall
- func (mr *SourceMockRecorder) Teardown(arg0 any) *SourceTeardownCall
- type SourceOpenCall
- type SourceReadCall
- type SourceStopCall
- type SourceTeardownCall
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DLQHandler ¶
type DLQHandler struct {
// contains filtered or unexported fields
}
DLQHandler is a mock of DLQHandler interface.
func NewDLQHandler ¶
func NewDLQHandler(ctrl *gomock.Controller) *DLQHandler
NewDLQHandler creates a new mock instance.
func (*DLQHandler) Close ¶
func (m *DLQHandler) Close(arg0 context.Context) error
Close mocks base method.
func (*DLQHandler) EXPECT ¶
func (m *DLQHandler) EXPECT() *DLQHandlerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type DLQHandlerCloseCall ¶ added in v0.11.0
DLQHandlerCloseCall wrap *gomock.Call
func (*DLQHandlerCloseCall) Do ¶ added in v0.11.0
func (c *DLQHandlerCloseCall) Do(f func(context.Context) error) *DLQHandlerCloseCall
Do rewrite *gomock.Call.Do
func (*DLQHandlerCloseCall) DoAndReturn ¶ added in v0.11.0
func (c *DLQHandlerCloseCall) DoAndReturn(f func(context.Context) error) *DLQHandlerCloseCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*DLQHandlerCloseCall) Return ¶ added in v0.11.0
func (c *DLQHandlerCloseCall) Return(arg0 error) *DLQHandlerCloseCall
Return rewrite *gomock.Call.Return
type DLQHandlerMockRecorder ¶
type DLQHandlerMockRecorder struct {
// contains filtered or unexported fields
}
DLQHandlerMockRecorder is the mock recorder for DLQHandler.
func (*DLQHandlerMockRecorder) Close ¶
func (mr *DLQHandlerMockRecorder) Close(arg0 any) *DLQHandlerCloseCall
Close indicates an expected call of Close.
func (*DLQHandlerMockRecorder) Open ¶
func (mr *DLQHandlerMockRecorder) Open(arg0 any) *DLQHandlerOpenCall
Open indicates an expected call of Open.
func (*DLQHandlerMockRecorder) Write ¶
func (mr *DLQHandlerMockRecorder) Write(arg0, arg1 any) *DLQHandlerWriteCall
Write indicates an expected call of Write.
type DLQHandlerOpenCall ¶ added in v0.11.0
DLQHandlerOpenCall wrap *gomock.Call
func (*DLQHandlerOpenCall) Do ¶ added in v0.11.0
func (c *DLQHandlerOpenCall) Do(f func(context.Context) error) *DLQHandlerOpenCall
Do rewrite *gomock.Call.Do
func (*DLQHandlerOpenCall) DoAndReturn ¶ added in v0.11.0
func (c *DLQHandlerOpenCall) DoAndReturn(f func(context.Context) error) *DLQHandlerOpenCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*DLQHandlerOpenCall) Return ¶ added in v0.11.0
func (c *DLQHandlerOpenCall) Return(arg0 error) *DLQHandlerOpenCall
Return rewrite *gomock.Call.Return
type DLQHandlerWriteCall ¶ added in v0.11.0
DLQHandlerWriteCall wrap *gomock.Call
func (*DLQHandlerWriteCall) Do ¶ added in v0.11.0
func (c *DLQHandlerWriteCall) Do(f func(context.Context, opencdc.Record) error) *DLQHandlerWriteCall
Do rewrite *gomock.Call.Do
func (*DLQHandlerWriteCall) DoAndReturn ¶ added in v0.11.0
func (c *DLQHandlerWriteCall) DoAndReturn(f func(context.Context, opencdc.Record) error) *DLQHandlerWriteCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*DLQHandlerWriteCall) Return ¶ added in v0.11.0
func (c *DLQHandlerWriteCall) Return(arg0 error) *DLQHandlerWriteCall
Return rewrite *gomock.Call.Return
type Destination ¶ added in v0.5.0
type Destination struct {
// contains filtered or unexported fields
}
Destination is a mock of Destination interface.
func NewDestination ¶ added in v0.5.0
func NewDestination(ctrl *gomock.Controller) *Destination
NewDestination creates a new mock instance.
func (*Destination) Ack ¶ added in v0.5.0
func (m *Destination) Ack(arg0 context.Context) ([]connector.DestinationAck, error)
Ack mocks base method.
func (*Destination) EXPECT ¶ added in v0.5.0
func (m *Destination) EXPECT() *DestinationMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*Destination) Errors ¶ added in v0.5.0
func (m *Destination) Errors() <-chan error
Errors mocks base method.
func (*Destination) Open ¶ added in v0.5.0
func (m *Destination) Open(arg0 context.Context) error
Open mocks base method.
type DestinationAckCall ¶ added in v0.11.0
DestinationAckCall wrap *gomock.Call
func (*DestinationAckCall) Do ¶ added in v0.11.0
func (c *DestinationAckCall) Do(f func(context.Context) ([]connector.DestinationAck, error)) *DestinationAckCall
Do rewrite *gomock.Call.Do
func (*DestinationAckCall) DoAndReturn ¶ added in v0.11.0
func (c *DestinationAckCall) DoAndReturn(f func(context.Context) ([]connector.DestinationAck, error)) *DestinationAckCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*DestinationAckCall) Return ¶ added in v0.11.0
func (c *DestinationAckCall) Return(arg0 []connector.DestinationAck, arg1 error) *DestinationAckCall
Return rewrite *gomock.Call.Return
type DestinationErrorsCall ¶ added in v0.11.0
DestinationErrorsCall wrap *gomock.Call
func (*DestinationErrorsCall) Do ¶ added in v0.11.0
func (c *DestinationErrorsCall) Do(f func() <-chan error) *DestinationErrorsCall
Do rewrite *gomock.Call.Do
func (*DestinationErrorsCall) DoAndReturn ¶ added in v0.11.0
func (c *DestinationErrorsCall) DoAndReturn(f func() <-chan error) *DestinationErrorsCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*DestinationErrorsCall) Return ¶ added in v0.11.0
func (c *DestinationErrorsCall) Return(arg0 <-chan error) *DestinationErrorsCall
Return rewrite *gomock.Call.Return
type DestinationIDCall ¶ added in v0.11.0
DestinationIDCall wrap *gomock.Call
func (*DestinationIDCall) Do ¶ added in v0.11.0
func (c *DestinationIDCall) Do(f func() string) *DestinationIDCall
Do rewrite *gomock.Call.Do
func (*DestinationIDCall) DoAndReturn ¶ added in v0.11.0
func (c *DestinationIDCall) DoAndReturn(f func() string) *DestinationIDCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*DestinationIDCall) Return ¶ added in v0.11.0
func (c *DestinationIDCall) Return(arg0 string) *DestinationIDCall
Return rewrite *gomock.Call.Return
type DestinationMockRecorder ¶ added in v0.5.0
type DestinationMockRecorder struct {
// contains filtered or unexported fields
}
DestinationMockRecorder is the mock recorder for Destination.
func (*DestinationMockRecorder) Ack ¶ added in v0.5.0
func (mr *DestinationMockRecorder) Ack(arg0 any) *DestinationAckCall
Ack indicates an expected call of Ack.
func (*DestinationMockRecorder) Errors ¶ added in v0.5.0
func (mr *DestinationMockRecorder) Errors() *DestinationErrorsCall
Errors indicates an expected call of Errors.
func (*DestinationMockRecorder) ID ¶ added in v0.5.0
func (mr *DestinationMockRecorder) ID() *DestinationIDCall
ID indicates an expected call of ID.
func (*DestinationMockRecorder) Open ¶ added in v0.5.0
func (mr *DestinationMockRecorder) Open(arg0 any) *DestinationOpenCall
Open indicates an expected call of Open.
func (*DestinationMockRecorder) Stop ¶ added in v0.5.0
func (mr *DestinationMockRecorder) Stop(arg0, arg1 any) *DestinationStopCall
Stop indicates an expected call of Stop.
func (*DestinationMockRecorder) Teardown ¶ added in v0.5.0
func (mr *DestinationMockRecorder) Teardown(arg0 any) *DestinationTeardownCall
Teardown indicates an expected call of Teardown.
func (*DestinationMockRecorder) Write ¶ added in v0.5.0
func (mr *DestinationMockRecorder) Write(arg0, arg1 any) *DestinationWriteCall
Write indicates an expected call of Write.
type DestinationOpenCall ¶ added in v0.11.0
DestinationOpenCall wrap *gomock.Call
func (*DestinationOpenCall) Do ¶ added in v0.11.0
func (c *DestinationOpenCall) Do(f func(context.Context) error) *DestinationOpenCall
Do rewrite *gomock.Call.Do
func (*DestinationOpenCall) DoAndReturn ¶ added in v0.11.0
func (c *DestinationOpenCall) DoAndReturn(f func(context.Context) error) *DestinationOpenCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*DestinationOpenCall) Return ¶ added in v0.11.0
func (c *DestinationOpenCall) Return(arg0 error) *DestinationOpenCall
Return rewrite *gomock.Call.Return
type DestinationStopCall ¶ added in v0.11.0
DestinationStopCall wrap *gomock.Call
func (*DestinationStopCall) Do ¶ added in v0.11.0
func (c *DestinationStopCall) Do(f func(context.Context, opencdc.Position) error) *DestinationStopCall
Do rewrite *gomock.Call.Do
func (*DestinationStopCall) DoAndReturn ¶ added in v0.11.0
func (c *DestinationStopCall) DoAndReturn(f func(context.Context, opencdc.Position) error) *DestinationStopCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*DestinationStopCall) Return ¶ added in v0.11.0
func (c *DestinationStopCall) Return(arg0 error) *DestinationStopCall
Return rewrite *gomock.Call.Return
type DestinationTeardownCall ¶ added in v0.11.0
DestinationTeardownCall wrap *gomock.Call
func (*DestinationTeardownCall) Do ¶ added in v0.11.0
func (c *DestinationTeardownCall) Do(f func(context.Context) error) *DestinationTeardownCall
Do rewrite *gomock.Call.Do
func (*DestinationTeardownCall) DoAndReturn ¶ added in v0.11.0
func (c *DestinationTeardownCall) DoAndReturn(f func(context.Context) error) *DestinationTeardownCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*DestinationTeardownCall) Return ¶ added in v0.11.0
func (c *DestinationTeardownCall) Return(arg0 error) *DestinationTeardownCall
Return rewrite *gomock.Call.Return
type DestinationWriteCall ¶ added in v0.11.0
DestinationWriteCall wrap *gomock.Call
func (*DestinationWriteCall) Do ¶ added in v0.11.0
func (c *DestinationWriteCall) Do(f func(context.Context, []opencdc.Record) error) *DestinationWriteCall
Do rewrite *gomock.Call.Do
func (*DestinationWriteCall) DoAndReturn ¶ added in v0.11.0
func (c *DestinationWriteCall) DoAndReturn(f func(context.Context, []opencdc.Record) error) *DestinationWriteCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*DestinationWriteCall) Return ¶ added in v0.11.0
func (c *DestinationWriteCall) Return(arg0 error) *DestinationWriteCall
Return rewrite *gomock.Call.Return
type Processor ¶ added in v0.9.0
type Processor struct {
// contains filtered or unexported fields
}
Processor is a mock of Processor interface.
func NewProcessor ¶ added in v0.9.0
func NewProcessor(ctrl *gomock.Controller) *Processor
NewProcessor creates a new mock instance.
func (*Processor) EXPECT ¶ added in v0.9.0
func (m *Processor) EXPECT() *ProcessorMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type ProcessorMockRecorder ¶ added in v0.9.0
type ProcessorMockRecorder struct {
// contains filtered or unexported fields
}
ProcessorMockRecorder is the mock recorder for Processor.
func (*ProcessorMockRecorder) Open ¶ added in v0.9.0
func (mr *ProcessorMockRecorder) Open(arg0 any) *ProcessorOpenCall
Open indicates an expected call of Open.
func (*ProcessorMockRecorder) Process ¶ added in v0.9.0
func (mr *ProcessorMockRecorder) Process(arg0, arg1 any) *ProcessorProcessCall
Process indicates an expected call of Process.
func (*ProcessorMockRecorder) Teardown ¶ added in v0.9.0
func (mr *ProcessorMockRecorder) Teardown(arg0 any) *ProcessorTeardownCall
Teardown indicates an expected call of Teardown.
type ProcessorOpenCall ¶ added in v0.11.0
ProcessorOpenCall wrap *gomock.Call
func (*ProcessorOpenCall) Do ¶ added in v0.11.0
func (c *ProcessorOpenCall) Do(f func(context.Context) error) *ProcessorOpenCall
Do rewrite *gomock.Call.Do
func (*ProcessorOpenCall) DoAndReturn ¶ added in v0.11.0
func (c *ProcessorOpenCall) DoAndReturn(f func(context.Context) error) *ProcessorOpenCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*ProcessorOpenCall) Return ¶ added in v0.11.0
func (c *ProcessorOpenCall) Return(arg0 error) *ProcessorOpenCall
Return rewrite *gomock.Call.Return
type ProcessorProcessCall ¶ added in v0.11.0
ProcessorProcessCall wrap *gomock.Call
func (*ProcessorProcessCall) Do ¶ added in v0.11.0
func (c *ProcessorProcessCall) Do(f func(context.Context, []opencdc.Record) []sdk.ProcessedRecord) *ProcessorProcessCall
Do rewrite *gomock.Call.Do
func (*ProcessorProcessCall) DoAndReturn ¶ added in v0.11.0
func (c *ProcessorProcessCall) DoAndReturn(f func(context.Context, []opencdc.Record) []sdk.ProcessedRecord) *ProcessorProcessCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*ProcessorProcessCall) Return ¶ added in v0.11.0
func (c *ProcessorProcessCall) Return(arg0 []sdk.ProcessedRecord) *ProcessorProcessCall
Return rewrite *gomock.Call.Return
type ProcessorTeardownCall ¶ added in v0.11.0
ProcessorTeardownCall wrap *gomock.Call
func (*ProcessorTeardownCall) Do ¶ added in v0.11.0
func (c *ProcessorTeardownCall) Do(f func(context.Context) error) *ProcessorTeardownCall
Do rewrite *gomock.Call.Do
func (*ProcessorTeardownCall) DoAndReturn ¶ added in v0.11.0
func (c *ProcessorTeardownCall) DoAndReturn(f func(context.Context) error) *ProcessorTeardownCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*ProcessorTeardownCall) Return ¶ added in v0.11.0
func (c *ProcessorTeardownCall) Return(arg0 error) *ProcessorTeardownCall
Return rewrite *gomock.Call.Return
type Source ¶ added in v0.5.0
type Source struct {
// contains filtered or unexported fields
}
Source is a mock of Source interface.
func NewSource ¶ added in v0.5.0
func NewSource(ctrl *gomock.Controller) *Source
NewSource creates a new mock instance.
func (*Source) EXPECT ¶ added in v0.5.0
func (m *Source) EXPECT() *SourceMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type SourceAckCall ¶ added in v0.11.0
SourceAckCall wrap *gomock.Call
func (*SourceAckCall) Do ¶ added in v0.11.0
func (c *SourceAckCall) Do(f func(context.Context, []opencdc.Position) error) *SourceAckCall
Do rewrite *gomock.Call.Do
func (*SourceAckCall) DoAndReturn ¶ added in v0.11.0
func (c *SourceAckCall) DoAndReturn(f func(context.Context, []opencdc.Position) error) *SourceAckCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*SourceAckCall) Return ¶ added in v0.11.0
func (c *SourceAckCall) Return(arg0 error) *SourceAckCall
Return rewrite *gomock.Call.Return
type SourceErrorsCall ¶ added in v0.11.0
SourceErrorsCall wrap *gomock.Call
func (*SourceErrorsCall) Do ¶ added in v0.11.0
func (c *SourceErrorsCall) Do(f func() <-chan error) *SourceErrorsCall
Do rewrite *gomock.Call.Do
func (*SourceErrorsCall) DoAndReturn ¶ added in v0.11.0
func (c *SourceErrorsCall) DoAndReturn(f func() <-chan error) *SourceErrorsCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*SourceErrorsCall) Return ¶ added in v0.11.0
func (c *SourceErrorsCall) Return(arg0 <-chan error) *SourceErrorsCall
Return rewrite *gomock.Call.Return
type SourceIDCall ¶ added in v0.11.0
SourceIDCall wrap *gomock.Call
func (*SourceIDCall) Do ¶ added in v0.11.0
func (c *SourceIDCall) Do(f func() string) *SourceIDCall
Do rewrite *gomock.Call.Do
func (*SourceIDCall) DoAndReturn ¶ added in v0.11.0
func (c *SourceIDCall) DoAndReturn(f func() string) *SourceIDCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*SourceIDCall) Return ¶ added in v0.11.0
func (c *SourceIDCall) Return(arg0 string) *SourceIDCall
Return rewrite *gomock.Call.Return
type SourceMockRecorder ¶ added in v0.5.0
type SourceMockRecorder struct {
// contains filtered or unexported fields
}
SourceMockRecorder is the mock recorder for Source.
func (*SourceMockRecorder) Ack ¶ added in v0.5.0
func (mr *SourceMockRecorder) Ack(arg0, arg1 any) *SourceAckCall
Ack indicates an expected call of Ack.
func (*SourceMockRecorder) Errors ¶ added in v0.5.0
func (mr *SourceMockRecorder) Errors() *SourceErrorsCall
Errors indicates an expected call of Errors.
func (*SourceMockRecorder) ID ¶ added in v0.5.0
func (mr *SourceMockRecorder) ID() *SourceIDCall
ID indicates an expected call of ID.
func (*SourceMockRecorder) Open ¶ added in v0.5.0
func (mr *SourceMockRecorder) Open(arg0 any) *SourceOpenCall
Open indicates an expected call of Open.
func (*SourceMockRecorder) Read ¶ added in v0.5.0
func (mr *SourceMockRecorder) Read(arg0 any) *SourceReadCall
Read indicates an expected call of Read.
func (*SourceMockRecorder) Stop ¶ added in v0.5.0
func (mr *SourceMockRecorder) Stop(arg0 any) *SourceStopCall
Stop indicates an expected call of Stop.
func (*SourceMockRecorder) Teardown ¶ added in v0.5.0
func (mr *SourceMockRecorder) Teardown(arg0 any) *SourceTeardownCall
Teardown indicates an expected call of Teardown.
type SourceOpenCall ¶ added in v0.11.0
SourceOpenCall wrap *gomock.Call
func (*SourceOpenCall) Do ¶ added in v0.11.0
func (c *SourceOpenCall) Do(f func(context.Context) error) *SourceOpenCall
Do rewrite *gomock.Call.Do
func (*SourceOpenCall) DoAndReturn ¶ added in v0.11.0
func (c *SourceOpenCall) DoAndReturn(f func(context.Context) error) *SourceOpenCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*SourceOpenCall) Return ¶ added in v0.11.0
func (c *SourceOpenCall) Return(arg0 error) *SourceOpenCall
Return rewrite *gomock.Call.Return
type SourceReadCall ¶ added in v0.11.0
SourceReadCall wrap *gomock.Call
func (*SourceReadCall) Do ¶ added in v0.11.0
func (c *SourceReadCall) Do(f func(context.Context) ([]opencdc.Record, error)) *SourceReadCall
Do rewrite *gomock.Call.Do
func (*SourceReadCall) DoAndReturn ¶ added in v0.11.0
func (c *SourceReadCall) DoAndReturn(f func(context.Context) ([]opencdc.Record, error)) *SourceReadCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*SourceReadCall) Return ¶ added in v0.11.0
func (c *SourceReadCall) Return(arg0 []opencdc.Record, arg1 error) *SourceReadCall
Return rewrite *gomock.Call.Return
type SourceStopCall ¶ added in v0.11.0
SourceStopCall wrap *gomock.Call
func (*SourceStopCall) Do ¶ added in v0.11.0
func (c *SourceStopCall) Do(f func(context.Context) (opencdc.Position, error)) *SourceStopCall
Do rewrite *gomock.Call.Do
func (*SourceStopCall) DoAndReturn ¶ added in v0.11.0
func (c *SourceStopCall) DoAndReturn(f func(context.Context) (opencdc.Position, error)) *SourceStopCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*SourceStopCall) Return ¶ added in v0.11.0
func (c *SourceStopCall) Return(arg0 opencdc.Position, arg1 error) *SourceStopCall
Return rewrite *gomock.Call.Return
type SourceTeardownCall ¶ added in v0.11.0
SourceTeardownCall wrap *gomock.Call
func (*SourceTeardownCall) Do ¶ added in v0.11.0
func (c *SourceTeardownCall) Do(f func(context.Context) error) *SourceTeardownCall
Do rewrite *gomock.Call.Do
func (*SourceTeardownCall) DoAndReturn ¶ added in v0.11.0
func (c *SourceTeardownCall) DoAndReturn(f func(context.Context) error) *SourceTeardownCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*SourceTeardownCall) Return ¶ added in v0.11.0
func (c *SourceTeardownCall) Return(arg0 error) *SourceTeardownCall
Return rewrite *gomock.Call.Return