mock

Nov 8, 2024

Changes in this version

+ type Destination struct

+ func NewDestination(ctrl *gomock.Controller) *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) Teardown(arg0 context.Context) error

+ func (m *Destination) Write(arg0 context.Context, arg1 []opencdc.Record) error

+ type DestinationAckCall struct

+ 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 struct

+ func (c *DestinationErrorsCall) Do(f func() <-chan error) *DestinationErrorsCall

+ func (c *DestinationErrorsCall) DoAndReturn(f func() <-chan error) *DestinationErrorsCall

+ func (c *DestinationErrorsCall) Return(arg0 <-chan error) *DestinationErrorsCall

+ type DestinationIDCall struct

+ func (c *DestinationIDCall) Do(f func() string) *DestinationIDCall

+ func (c *DestinationIDCall) DoAndReturn(f func() string) *DestinationIDCall

+ func (c *DestinationIDCall) Return(arg0 string) *DestinationIDCall

+ type DestinationMockRecorder struct

+ 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) Teardown(arg0 any) *DestinationTeardownCall

+ func (mr *DestinationMockRecorder) Write(arg0, arg1 any) *DestinationWriteCall

+ type DestinationOpenCall struct

+ func (c *DestinationOpenCall) Do(f func(context.Context) error) *DestinationOpenCall

+ func (c *DestinationOpenCall) DoAndReturn(f func(context.Context) error) *DestinationOpenCall

+ func (c *DestinationOpenCall) Return(arg0 error) *DestinationOpenCall

+ type DestinationTeardownCall struct

+ func (c *DestinationTeardownCall) Do(f func(context.Context) error) *DestinationTeardownCall

+ func (c *DestinationTeardownCall) DoAndReturn(f func(context.Context) error) *DestinationTeardownCall

+ func (c *DestinationTeardownCall) Return(arg0 error) *DestinationTeardownCall

+ type DestinationWriteCall struct

+ func (c *DestinationWriteCall) Do(f func(context.Context, []opencdc.Record) error) *DestinationWriteCall

+ func (c *DestinationWriteCall) DoAndReturn(f func(context.Context, []opencdc.Record) error) *DestinationWriteCall

+ func (c *DestinationWriteCall) Return(arg0 error) *DestinationWriteCall

+ type Processor struct

+ func NewProcessor(ctrl *gomock.Controller) *Processor

+ func (m *Processor) EXPECT() *ProcessorMockRecorder

+ func (m *Processor) Open(ctx context.Context) error

+ func (m *Processor) Process(arg0 context.Context, arg1 []opencdc.Record) []sdk.ProcessedRecord

+ func (m *Processor) Teardown(arg0 context.Context) error

+ type ProcessorMockRecorder struct

+ func (mr *ProcessorMockRecorder) Open(ctx any) *ProcessorOpenCall

+ func (mr *ProcessorMockRecorder) Process(arg0, arg1 any) *ProcessorProcessCall

+ func (mr *ProcessorMockRecorder) Teardown(arg0 any) *ProcessorTeardownCall

+ type ProcessorOpenCall struct

+ func (c *ProcessorOpenCall) Do(f func(context.Context) error) *ProcessorOpenCall

+ func (c *ProcessorOpenCall) DoAndReturn(f func(context.Context) error) *ProcessorOpenCall

+ func (c *ProcessorOpenCall) Return(arg0 error) *ProcessorOpenCall

+ type ProcessorProcessCall struct

+ 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 struct

+ func (c *ProcessorTeardownCall) Do(f func(context.Context) error) *ProcessorTeardownCall

+ func (c *ProcessorTeardownCall) DoAndReturn(f func(context.Context) error) *ProcessorTeardownCall

+ func (c *ProcessorTeardownCall) Return(arg0 error) *ProcessorTeardownCall

+ type Source struct

+ func NewSource(ctrl *gomock.Controller) *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) Teardown(arg0 context.Context) error

+ type SourceAckCall struct

+ func (c *SourceAckCall) Do(f func(context.Context, []opencdc.Position) error) *SourceAckCall

+ func (c *SourceAckCall) DoAndReturn(f func(context.Context, []opencdc.Position) error) *SourceAckCall

+ func (c *SourceAckCall) Return(arg0 error) *SourceAckCall

+ type SourceErrorsCall struct

+ func (c *SourceErrorsCall) Do(f func() <-chan error) *SourceErrorsCall

+ func (c *SourceErrorsCall) DoAndReturn(f func() <-chan error) *SourceErrorsCall

+ func (c *SourceErrorsCall) Return(arg0 <-chan error) *SourceErrorsCall

+ type SourceIDCall struct

+ func (c *SourceIDCall) Do(f func() string) *SourceIDCall

+ func (c *SourceIDCall) DoAndReturn(f func() string) *SourceIDCall

+ func (c *SourceIDCall) Return(arg0 string) *SourceIDCall

+ type SourceMockRecorder struct

+ 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) Teardown(arg0 any) *SourceTeardownCall

+ type SourceOpenCall struct

+ func (c *SourceOpenCall) Do(f func(context.Context) error) *SourceOpenCall

+ func (c *SourceOpenCall) DoAndReturn(f func(context.Context) error) *SourceOpenCall

+ func (c *SourceOpenCall) Return(arg0 error) *SourceOpenCall

+ type SourceReadCall struct

+ func (c *SourceReadCall) Do(f func(context.Context) ([]opencdc.Record, error)) *SourceReadCall

+ func (c *SourceReadCall) DoAndReturn(f func(context.Context) ([]opencdc.Record, error)) *SourceReadCall

+ func (c *SourceReadCall) Return(arg0 []opencdc.Record, arg1 error) *SourceReadCall

+ type SourceTeardownCall struct

+ func (c *SourceTeardownCall) Do(f func(context.Context) error) *SourceTeardownCall

+ func (c *SourceTeardownCall) DoAndReturn(f func(context.Context) error) *SourceTeardownCall

+ func (c *SourceTeardownCall) Return(arg0 error) *SourceTeardownCall