mock

package
v0.13.0-nightly.20241025 Latest Latest
Warning

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

 Go to latest Published: Oct 24, 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 

type DLQHandlerCloseCall struct {
	*gomock.Call
}

DLQHandlerCloseCall wrap *gomock.Call

func (*DLQHandlerCloseCall) Do 

func (c *DLQHandlerCloseCall) Do(f func(context.Context) error) *DLQHandlerCloseCall

Do rewrite *gomock.Call.Do

func (*DLQHandlerCloseCall) DoAndReturn 

func (c *DLQHandlerCloseCall) DoAndReturn(f func(context.Context) error) *DLQHandlerCloseCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*DLQHandlerCloseCall) Return 

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 

type DLQHandlerOpenCall struct {
	*gomock.Call
}

DLQHandlerOpenCall wrap *gomock.Call

func (*DLQHandlerOpenCall) Do 

func (c *DLQHandlerOpenCall) Do(f func(context.Context) error) *DLQHandlerOpenCall

Do rewrite *gomock.Call.Do

func (*DLQHandlerOpenCall) DoAndReturn 

func (c *DLQHandlerOpenCall) DoAndReturn(f func(context.Context) error) *DLQHandlerOpenCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*DLQHandlerOpenCall) Return 

func (c *DLQHandlerOpenCall) Return(arg0 error) *DLQHandlerOpenCall

Return rewrite *gomock.Call.Return

type DLQHandlerWriteCall 

type DLQHandlerWriteCall struct {
	*gomock.Call
}

DLQHandlerWriteCall wrap *gomock.Call

func (*DLQHandlerWriteCall) Do 

func (c *DLQHandlerWriteCall) Do(f func(context.Context, opencdc.Record) error) *DLQHandlerWriteCall

Do rewrite *gomock.Call.Do

func (*DLQHandlerWriteCall) DoAndReturn 

func (c *DLQHandlerWriteCall) DoAndReturn(f func(context.Context, opencdc.Record) error) *DLQHandlerWriteCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*DLQHandlerWriteCall) Return 

func (c *DLQHandlerWriteCall) Return(arg0 error) *DLQHandlerWriteCall

Return rewrite *gomock.Call.Return

type Destination 

type Destination struct {
	// contains filtered or unexported fields
}

Destination is a mock of Destination interface.

func NewDestination 

func NewDestination(ctrl *gomock.Controller) *Destination

NewDestination creates a new mock instance.

func (*Destination) Ack 

func (m *Destination) Ack(arg0 context.Context) ([]connector.DestinationAck, error)

Ack mocks base method.

func (*Destination) EXPECT 

func (m *Destination) EXPECT() *DestinationMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*Destination) Errors 

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

Errors mocks base method.

func (*Destination) ID 

func (m *Destination) ID() string

ID mocks base method.

func (*Destination) Open 

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

Open mocks base method.

func (*Destination) Stop 

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

Stop mocks base method.

func (*Destination) Teardown 

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

Teardown mocks base method.

func (*Destination) Write 

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

Write mocks base method.

type DestinationAckCall 

type DestinationAckCall struct {
	*gomock.Call
}

DestinationAckCall wrap *gomock.Call

func (*DestinationAckCall) Do 

func (c *DestinationAckCall) Do(f func(context.Context) ([]connector.DestinationAck, error)) *DestinationAckCall

Do rewrite *gomock.Call.Do

func (*DestinationAckCall) DoAndReturn 

func (c *DestinationAckCall) DoAndReturn(f func(context.Context) ([]connector.DestinationAck, error)) *DestinationAckCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*DestinationAckCall) Return 

func (c *DestinationAckCall) Return(arg0 []connector.DestinationAck, arg1 error) *DestinationAckCall

Return rewrite *gomock.Call.Return

type DestinationErrorsCall 

type DestinationErrorsCall struct {
	*gomock.Call
}

DestinationErrorsCall wrap *gomock.Call

func (*DestinationErrorsCall) Do 

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

Do rewrite *gomock.Call.Do

func (*DestinationErrorsCall) DoAndReturn 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*DestinationErrorsCall) Return 

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

Return rewrite *gomock.Call.Return

type DestinationIDCall 

type DestinationIDCall struct {
	*gomock.Call
}

DestinationIDCall wrap *gomock.Call

func (*DestinationIDCall) Do 

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

Do rewrite *gomock.Call.Do

func (*DestinationIDCall) DoAndReturn 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*DestinationIDCall) Return 

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

Return rewrite *gomock.Call.Return

type DestinationMockRecorder 

type DestinationMockRecorder struct {
	// contains filtered or unexported fields
}

DestinationMockRecorder is the mock recorder for Destination.

func (*DestinationMockRecorder) Ack 

func (mr *DestinationMockRecorder) Ack(arg0 any) *DestinationAckCall

Ack indicates an expected call of Ack.

func (*DestinationMockRecorder) Errors 

func (mr *DestinationMockRecorder) Errors() *DestinationErrorsCall

Errors indicates an expected call of Errors.

func (*DestinationMockRecorder) ID 

func (mr *DestinationMockRecorder) ID() *DestinationIDCall

ID indicates an expected call of ID.

func (*DestinationMockRecorder) Open 

func (mr *DestinationMockRecorder) Open(arg0 any) *DestinationOpenCall

Open indicates an expected call of Open.

func (*DestinationMockRecorder) Stop 

func (mr *DestinationMockRecorder) Stop(arg0, arg1 any) *DestinationStopCall

Stop indicates an expected call of Stop.

func (*DestinationMockRecorder) Teardown 

func (mr *DestinationMockRecorder) Teardown(arg0 any) *DestinationTeardownCall

Teardown indicates an expected call of Teardown.

func (*DestinationMockRecorder) Write 

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

Write indicates an expected call of Write.

type DestinationOpenCall 

type DestinationOpenCall struct {
	*gomock.Call
}

DestinationOpenCall wrap *gomock.Call

func (*DestinationOpenCall) Do 

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

Do rewrite *gomock.Call.Do

func (*DestinationOpenCall) DoAndReturn 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*DestinationOpenCall) Return 

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

Return rewrite *gomock.Call.Return

type DestinationStopCall 

type DestinationStopCall struct {
	*gomock.Call
}

DestinationStopCall wrap *gomock.Call

func (*DestinationStopCall) Do 

func (c *DestinationStopCall) Do(f func(context.Context, opencdc.Position) error) *DestinationStopCall

Do rewrite *gomock.Call.Do

func (*DestinationStopCall) DoAndReturn 

func (c *DestinationStopCall) DoAndReturn(f func(context.Context, opencdc.Position) error) *DestinationStopCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*DestinationStopCall) Return 

func (c *DestinationStopCall) Return(arg0 error) *DestinationStopCall

Return rewrite *gomock.Call.Return

type DestinationTeardownCall 

type DestinationTeardownCall struct {
	*gomock.Call
}

DestinationTeardownCall wrap *gomock.Call

func (*DestinationTeardownCall) Do 

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

Do rewrite *gomock.Call.Do

func (*DestinationTeardownCall) DoAndReturn 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*DestinationTeardownCall) Return 

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

Return rewrite *gomock.Call.Return

type DestinationWriteCall 

type DestinationWriteCall struct {
	*gomock.Call
}

DestinationWriteCall wrap *gomock.Call

func (*DestinationWriteCall) Do 

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

Do rewrite *gomock.Call.Do

func (*DestinationWriteCall) DoAndReturn 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*DestinationWriteCall) Return 

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

Return rewrite *gomock.Call.Return

type Processor 

type Processor struct {
	// contains filtered or unexported fields
}

Processor is a mock of Processor interface.

func NewProcessor 

func NewProcessor(ctrl *gomock.Controller) *Processor

NewProcessor creates a new mock instance.

func (*Processor) EXPECT 

func (m *Processor) EXPECT() *ProcessorMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*Processor) Open 

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

Open mocks base method.

func (*Processor) Process 

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

Process mocks base method.

func (*Processor) Teardown 

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

Teardown mocks base method.

type ProcessorMockRecorder 

type ProcessorMockRecorder struct {
	// contains filtered or unexported fields
}

ProcessorMockRecorder is the mock recorder for Processor.

func (*ProcessorMockRecorder) Open 

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

Open indicates an expected call of Open.

func (*ProcessorMockRecorder) Process 

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

Process indicates an expected call of Process.

func (*ProcessorMockRecorder) Teardown 

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

Teardown indicates an expected call of Teardown.

type ProcessorOpenCall 

type ProcessorOpenCall struct {
	*gomock.Call
}

ProcessorOpenCall wrap *gomock.Call

func (*ProcessorOpenCall) Do 

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

Do rewrite *gomock.Call.Do

func (*ProcessorOpenCall) DoAndReturn 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ProcessorOpenCall) Return 

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

Return rewrite *gomock.Call.Return

type ProcessorProcessCall 

type ProcessorProcessCall struct {
	*gomock.Call
}

ProcessorProcessCall wrap *gomock.Call

func (*ProcessorProcessCall) Do 

func (c *ProcessorProcessCall) Do(f func(context.Context, []opencdc.Record) []sdk.ProcessedRecord) *ProcessorProcessCall

Do rewrite *gomock.Call.Do

func (*ProcessorProcessCall) DoAndReturn 

func (c *ProcessorProcessCall) DoAndReturn(f func(context.Context, []opencdc.Record) []sdk.ProcessedRecord) *ProcessorProcessCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ProcessorProcessCall) Return 

func (c *ProcessorProcessCall) Return(arg0 []sdk.ProcessedRecord) *ProcessorProcessCall

Return rewrite *gomock.Call.Return

type ProcessorTeardownCall 

type ProcessorTeardownCall struct {
	*gomock.Call
}

ProcessorTeardownCall wrap *gomock.Call

func (*ProcessorTeardownCall) Do 

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

Do rewrite *gomock.Call.Do

func (*ProcessorTeardownCall) DoAndReturn 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ProcessorTeardownCall) Return 

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

Return rewrite *gomock.Call.Return

type Source 

type Source struct {
	// contains filtered or unexported fields
}

Source is a mock of Source interface.

func NewSource 

func NewSource(ctrl *gomock.Controller) *Source

NewSource creates a new mock instance.

func (*Source) Ack 

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

Ack mocks base method.

func (*Source) EXPECT 

func (m *Source) EXPECT() *SourceMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*Source) Errors 

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

Errors mocks base method.

func (*Source) ID 

func (m *Source) ID() string

ID mocks base method.

func (*Source) Open 

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

Open mocks base method.

func (*Source) Read 

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

Read mocks base method.

func (*Source) Stop 

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

Stop mocks base method.

func (*Source) Teardown 

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

Teardown mocks base method.

type SourceAckCall 

type SourceAckCall struct {
	*gomock.Call
}

SourceAckCall wrap *gomock.Call

func (*SourceAckCall) Do 

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

Do rewrite *gomock.Call.Do

func (*SourceAckCall) DoAndReturn 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*SourceAckCall) Return 

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

Return rewrite *gomock.Call.Return

type SourceErrorsCall 

type SourceErrorsCall struct {
	*gomock.Call
}

SourceErrorsCall wrap *gomock.Call

func (*SourceErrorsCall) Do 

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

Do rewrite *gomock.Call.Do

func (*SourceErrorsCall) DoAndReturn 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*SourceErrorsCall) Return 

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

Return rewrite *gomock.Call.Return

type SourceIDCall 

type SourceIDCall struct {
	*gomock.Call
}

SourceIDCall wrap *gomock.Call

func (*SourceIDCall) Do 

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

Do rewrite *gomock.Call.Do

func (*SourceIDCall) DoAndReturn 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*SourceIDCall) Return 

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

Return rewrite *gomock.Call.Return

type SourceMockRecorder 

type SourceMockRecorder struct {
	// contains filtered or unexported fields
}

SourceMockRecorder is the mock recorder for Source.

func (*SourceMockRecorder) Ack 

func (mr *SourceMockRecorder) Ack(arg0, arg1 any) *SourceAckCall

Ack indicates an expected call of Ack.

func (*SourceMockRecorder) Errors 

func (mr *SourceMockRecorder) Errors() *SourceErrorsCall

Errors indicates an expected call of Errors.

func (*SourceMockRecorder) ID 

func (mr *SourceMockRecorder) ID() *SourceIDCall

ID indicates an expected call of ID.

func (*SourceMockRecorder) Open 

func (mr *SourceMockRecorder) Open(arg0 any) *SourceOpenCall

Open indicates an expected call of Open.

func (*SourceMockRecorder) Read 

func (mr *SourceMockRecorder) Read(arg0 any) *SourceReadCall

Read indicates an expected call of Read.

func (*SourceMockRecorder) Stop 

func (mr *SourceMockRecorder) Stop(arg0 any) *SourceStopCall

Stop indicates an expected call of Stop.

func (*SourceMockRecorder) Teardown 

func (mr *SourceMockRecorder) Teardown(arg0 any) *SourceTeardownCall

Teardown indicates an expected call of Teardown.

type SourceOpenCall 

type SourceOpenCall struct {
	*gomock.Call
}

SourceOpenCall wrap *gomock.Call

func (*SourceOpenCall) Do 

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

Do rewrite *gomock.Call.Do

func (*SourceOpenCall) DoAndReturn 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*SourceOpenCall) Return 

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

Return rewrite *gomock.Call.Return

type SourceReadCall 

type SourceReadCall struct {
	*gomock.Call
}

SourceReadCall wrap *gomock.Call

func (*SourceReadCall) Do 

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

Do rewrite *gomock.Call.Do

func (*SourceReadCall) DoAndReturn 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*SourceReadCall) Return 

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

Return rewrite *gomock.Call.Return

type SourceStopCall 

type SourceStopCall struct {
	*gomock.Call
}

SourceStopCall wrap *gomock.Call

func (*SourceStopCall) Do 

func (c *SourceStopCall) Do(f func(context.Context) (opencdc.Position, error)) *SourceStopCall

Do rewrite *gomock.Call.Do

func (*SourceStopCall) DoAndReturn 

func (c *SourceStopCall) DoAndReturn(f func(context.Context) (opencdc.Position, error)) *SourceStopCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*SourceStopCall) Return 

func (c *SourceStopCall) Return(arg0 opencdc.Position, arg1 error) *SourceStopCall

Return rewrite *gomock.Call.Return

type SourceTeardownCall 

type SourceTeardownCall struct {
	*gomock.Call
}

SourceTeardownCall wrap *gomock.Call

func (*SourceTeardownCall) Do 

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

Do rewrite *gomock.Call.Do

func (*SourceTeardownCall) DoAndReturn 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*SourceTeardownCall) Return 

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

Return rewrite *gomock.Call.Return

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.