mock

package
v0.12.0-nightly.20240824 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 23, 2024 License: Apache-2.0 Imports: 6 Imported by: 0

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

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.

func (*DLQHandler) Open

func (m *DLQHandler) Open(arg0 context.Context) error

Open mocks base method.

func (*DLQHandler) Write

func (m *DLQHandler) Write(arg0 context.Context, arg1 opencdc.Record) error

Write mocks base method.

type DLQHandlerCloseCall added in v0.11.0

type DLQHandlerCloseCall struct {
	*gomock.Call
}

DLQHandlerCloseCall wrap *gomock.Call

func (*DLQHandlerCloseCall) Do added in v0.11.0

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

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

Close indicates an expected call of Close.

func (*DLQHandlerMockRecorder) Open

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

type DLQHandlerOpenCall struct {
	*gomock.Call
}

DLQHandlerOpenCall wrap *gomock.Call

func (*DLQHandlerOpenCall) Do added in v0.11.0

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

type DLQHandlerWriteCall struct {
	*gomock.Call
}

DLQHandlerWriteCall wrap *gomock.Call

func (*DLQHandlerWriteCall) Do added in v0.11.0

Do rewrite *gomock.Call.Do

func (*DLQHandlerWriteCall) DoAndReturn added in v0.11.0

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*DLQHandlerWriteCall) Return added in v0.11.0

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

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) ID added in v0.5.0

func (m *Destination) ID() string

ID mocks base method.

func (*Destination) Open added in v0.5.0

func (m *Destination) Open(arg0 context.Context) error

Open mocks base method.

func (*Destination) Stop added in v0.5.0

func (m *Destination) Stop(arg0 context.Context, arg1 opencdc.Position) error

Stop mocks base method.

func (*Destination) Teardown added in v0.5.0

func (m *Destination) Teardown(arg0 context.Context) error

Teardown mocks base method.

func (*Destination) Write added in v0.5.0

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

Write mocks base method.

type DestinationAckCall added in v0.11.0

type DestinationAckCall struct {
	*gomock.Call
}

DestinationAckCall wrap *gomock.Call

func (*DestinationAckCall) Do added in v0.11.0

Do rewrite *gomock.Call.Do

func (*DestinationAckCall) DoAndReturn added in v0.11.0

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*DestinationAckCall) Return added in v0.11.0

Return rewrite *gomock.Call.Return

type DestinationErrorsCall added in v0.11.0

type DestinationErrorsCall struct {
	*gomock.Call
}

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

type DestinationIDCall struct {
	*gomock.Call
}

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

Ack indicates an expected call of Ack.

func (*DestinationMockRecorder) Errors added in v0.5.0

Errors indicates an expected call of Errors.

func (*DestinationMockRecorder) ID added in v0.5.0

ID indicates an expected call of ID.

func (*DestinationMockRecorder) Open added in v0.5.0

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

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

type DestinationOpenCall struct {
	*gomock.Call
}

DestinationOpenCall wrap *gomock.Call

func (*DestinationOpenCall) Do added in v0.11.0

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

Return rewrite *gomock.Call.Return

type DestinationStopCall added in v0.11.0

type DestinationStopCall struct {
	*gomock.Call
}

DestinationStopCall wrap *gomock.Call

func (*DestinationStopCall) Do added in v0.11.0

Do rewrite *gomock.Call.Do

func (*DestinationStopCall) DoAndReturn added in v0.11.0

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*DestinationStopCall) Return added in v0.11.0

Return rewrite *gomock.Call.Return

type DestinationTeardownCall added in v0.11.0

type DestinationTeardownCall struct {
	*gomock.Call
}

DestinationTeardownCall wrap *gomock.Call

func (*DestinationTeardownCall) Do added in v0.11.0

Do rewrite *gomock.Call.Do

func (*DestinationTeardownCall) DoAndReturn added in v0.11.0

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*DestinationTeardownCall) Return added in v0.11.0

Return rewrite *gomock.Call.Return

type DestinationWriteCall added in v0.11.0

type DestinationWriteCall struct {
	*gomock.Call
}

DestinationWriteCall wrap *gomock.Call

func (*DestinationWriteCall) Do added in v0.11.0

Do rewrite *gomock.Call.Do

func (*DestinationWriteCall) DoAndReturn added in v0.11.0

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*DestinationWriteCall) Return added in v0.11.0

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.

func (*Processor) Open added in v0.9.0

func (m *Processor) Open(arg0 context.Context) error

Open mocks base method.

func (*Processor) Process added in v0.9.0

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

Process mocks base method.

func (*Processor) Teardown added in v0.9.0

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

Teardown mocks base method.

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

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

type ProcessorOpenCall struct {
	*gomock.Call
}

ProcessorOpenCall wrap *gomock.Call

func (*ProcessorOpenCall) Do added in v0.11.0

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

type ProcessorProcessCall struct {
	*gomock.Call
}

ProcessorProcessCall wrap *gomock.Call

func (*ProcessorProcessCall) Do added in v0.11.0

Do rewrite *gomock.Call.Do

func (*ProcessorProcessCall) DoAndReturn added in v0.11.0

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ProcessorProcessCall) Return added in v0.11.0

Return rewrite *gomock.Call.Return

type ProcessorTeardownCall added in v0.11.0

type ProcessorTeardownCall struct {
	*gomock.Call
}

ProcessorTeardownCall wrap *gomock.Call

func (*ProcessorTeardownCall) Do added in v0.11.0

Do rewrite *gomock.Call.Do

func (*ProcessorTeardownCall) DoAndReturn added in v0.11.0

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ProcessorTeardownCall) Return added in v0.11.0

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) Ack added in v0.5.0

func (m *Source) Ack(arg0 context.Context, arg1 []opencdc.Position) error

Ack mocks base method.

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.

func (*Source) Errors added in v0.5.0

func (m *Source) Errors() <-chan error

Errors mocks base method.

func (*Source) ID added in v0.5.0

func (m *Source) ID() string

ID mocks base method.

func (*Source) Open added in v0.5.0

func (m *Source) Open(arg0 context.Context) error

Open mocks base method.

func (*Source) Read added in v0.5.0

func (m *Source) Read(arg0 context.Context) ([]opencdc.Record, error)

Read mocks base method.

func (*Source) Stop added in v0.5.0

func (m *Source) Stop(arg0 context.Context) (opencdc.Position, error)

Stop mocks base method.

func (*Source) Teardown added in v0.5.0

func (m *Source) Teardown(arg0 context.Context) error

Teardown mocks base method.

type SourceAckCall added in v0.11.0

type SourceAckCall struct {
	*gomock.Call
}

SourceAckCall wrap *gomock.Call

func (*SourceAckCall) Do added in v0.11.0

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

type SourceErrorsCall struct {
	*gomock.Call
}

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

type SourceIDCall struct {
	*gomock.Call
}

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

type SourceOpenCall struct {
	*gomock.Call
}

SourceOpenCall wrap *gomock.Call

func (*SourceOpenCall) Do added in v0.11.0

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

type SourceReadCall struct {
	*gomock.Call
}

SourceReadCall wrap *gomock.Call

func (*SourceReadCall) Do added in v0.11.0

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

type SourceStopCall struct {
	*gomock.Call
}

SourceStopCall wrap *gomock.Call

func (*SourceStopCall) Do added in v0.11.0

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

type SourceTeardownCall struct {
	*gomock.Call
}

SourceTeardownCall wrap *gomock.Call

func (*SourceTeardownCall) Do added in v0.11.0

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL