mock

package
v0.13.0-nightly.20241105 Latest Latest
Warning

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

 Go to latest Published: Nov 4, 2024 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Overview

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 Processor 

type Processor struct {
	sdk.UnimplementedProcessor
	// 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) Configure 

func (m *Processor) Configure(arg0 context.Context, arg1 config.Config) error

Configure mocks base method.

func (*Processor) EXPECT 

func (m *Processor) EXPECT() *ProcessorMockRecorder

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

func (*Processor) MiddlewareOptions added in v0.11.0 

func (m *Processor) MiddlewareOptions() []sdk.ProcessorMiddlewareOption

MiddlewareOptions mocks base method.

func (*Processor) Open 

func (m *Processor) Open(arg0 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) Specification 

func (m *Processor) Specification() (sdk.Specification, error)

Specification mocks base method.

func (*Processor) Teardown 

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

Teardown mocks base method.

type ProcessorConfigureCall added in v0.11.0 

type ProcessorConfigureCall struct {
	*gomock.Call
}

ProcessorConfigureCall wrap *gomock.Call

func (*ProcessorConfigureCall) Do added in v0.11.0 

func (c *ProcessorConfigureCall) Do(f func(context.Context, config.Config) error) *ProcessorConfigureCall

Do rewrite *gomock.Call.Do

func (*ProcessorConfigureCall) DoAndReturn added in v0.11.0 

func (c *ProcessorConfigureCall) DoAndReturn(f func(context.Context, config.Config) error) *ProcessorConfigureCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ProcessorConfigureCall) Return added in v0.11.0 

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

Return rewrite *gomock.Call.Return

type ProcessorMiddlewareOptionsCall added in v0.11.0 

type ProcessorMiddlewareOptionsCall struct {
	*gomock.Call
}

ProcessorMiddlewareOptionsCall wrap *gomock.Call

func (*ProcessorMiddlewareOptionsCall) Do added in v0.11.0 

func (c *ProcessorMiddlewareOptionsCall) Do(f func() []sdk.ProcessorMiddlewareOption) *ProcessorMiddlewareOptionsCall

Do rewrite *gomock.Call.Do

func (*ProcessorMiddlewareOptionsCall) DoAndReturn added in v0.11.0 

func (c *ProcessorMiddlewareOptionsCall) DoAndReturn(f func() []sdk.ProcessorMiddlewareOption) *ProcessorMiddlewareOptionsCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ProcessorMiddlewareOptionsCall) Return added in v0.11.0 

func (c *ProcessorMiddlewareOptionsCall) Return(arg0 []sdk.ProcessorMiddlewareOption) *ProcessorMiddlewareOptionsCall

Return rewrite *gomock.Call.Return

type ProcessorMockRecorder 

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

ProcessorMockRecorder is the mock recorder for Processor.

func (*ProcessorMockRecorder) Configure 

func (mr *ProcessorMockRecorder) Configure(arg0, arg1 any) *ProcessorConfigureCall

Configure indicates an expected call of Configure.

func (*ProcessorMockRecorder) MiddlewareOptions added in v0.11.0 

func (mr *ProcessorMockRecorder) MiddlewareOptions() *ProcessorMiddlewareOptionsCall

MiddlewareOptions indicates an expected call of MiddlewareOptions.

func (*ProcessorMockRecorder) Open 

func (mr *ProcessorMockRecorder) Open(arg0 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) Specification 

func (mr *ProcessorMockRecorder) Specification() *ProcessorSpecificationCall

Specification indicates an expected call of Specification.

func (*ProcessorMockRecorder) Teardown 

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 

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 

type ProcessorProcessCall struct {
	*gomock.Call
}

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 ProcessorSpecificationCall added in v0.11.0 

type ProcessorSpecificationCall struct {
	*gomock.Call
}

ProcessorSpecificationCall wrap *gomock.Call

func (*ProcessorSpecificationCall) Do added in v0.11.0 

func (c *ProcessorSpecificationCall) Do(f func() (sdk.Specification, error)) *ProcessorSpecificationCall

Do rewrite *gomock.Call.Do

func (*ProcessorSpecificationCall) DoAndReturn added in v0.11.0 

func (c *ProcessorSpecificationCall) DoAndReturn(f func() (sdk.Specification, error)) *ProcessorSpecificationCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ProcessorSpecificationCall) Return added in v0.11.0 

func (c *ProcessorSpecificationCall) Return(arg0 sdk.Specification, arg1 error) *ProcessorSpecificationCall

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 

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 ProcessormustEmbedUnimplementedProcessorCall added in v0.11.0 

type ProcessormustEmbedUnimplementedProcessorCall struct {
	*gomock.Call
}

ProcessormustEmbedUnimplementedProcessorCall wrap *gomock.Call

func (*ProcessormustEmbedUnimplementedProcessorCall) Do added in v0.11.0 

func (c *ProcessormustEmbedUnimplementedProcessorCall) Do(f func()) *ProcessormustEmbedUnimplementedProcessorCall

Do rewrite *gomock.Call.Do

func (*ProcessormustEmbedUnimplementedProcessorCall) DoAndReturn added in v0.11.0 

func (c *ProcessormustEmbedUnimplementedProcessorCall) DoAndReturn(f func()) *ProcessormustEmbedUnimplementedProcessorCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ProcessormustEmbedUnimplementedProcessorCall) Return added in v0.11.0 

func (c *ProcessormustEmbedUnimplementedProcessorCall) Return() *ProcessormustEmbedUnimplementedProcessorCall

Return rewrite *gomock.Call.Return

type Registry 

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

Registry is a mock of registry interface.

func NewRegistry 

func NewRegistry(ctrl *gomock.Controller) *Registry

NewRegistry creates a new mock instance.

func (*Registry) EXPECT 

func (m *Registry) EXPECT() *RegistryMockRecorder

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

func (*Registry) List 

func (m *Registry) List() map[plugin.FullName]sdk.Specification

List mocks base method.

func (*Registry) NewProcessor 

func (m *Registry) NewProcessor(ctx context.Context, fullName plugin.FullName, id string) (sdk.Processor, error)

NewProcessor mocks base method.

type RegistryListCall added in v0.11.0 

type RegistryListCall struct {
	*gomock.Call
}

RegistryListCall wrap *gomock.Call

func (*RegistryListCall) Do added in v0.11.0 

func (c *RegistryListCall) Do(f func() map[plugin.FullName]sdk.Specification) *RegistryListCall

Do rewrite *gomock.Call.Do

func (*RegistryListCall) DoAndReturn added in v0.11.0 

func (c *RegistryListCall) DoAndReturn(f func() map[plugin.FullName]sdk.Specification) *RegistryListCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*RegistryListCall) Return added in v0.11.0 

func (c *RegistryListCall) Return(arg0 map[plugin.FullName]sdk.Specification) *RegistryListCall

Return rewrite *gomock.Call.Return

type RegistryMockRecorder 

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

RegistryMockRecorder is the mock recorder for Registry.

func (*RegistryMockRecorder) List 

func (mr *RegistryMockRecorder) List() *RegistryListCall

List indicates an expected call of List.

func (*RegistryMockRecorder) NewProcessor 

func (mr *RegistryMockRecorder) NewProcessor(ctx, fullName, id any) *RegistryNewProcessorCall

NewProcessor indicates an expected call of NewProcessor.

type RegistryNewProcessorCall added in v0.11.0 

type RegistryNewProcessorCall struct {
	*gomock.Call
}

RegistryNewProcessorCall wrap *gomock.Call

func (*RegistryNewProcessorCall) Do added in v0.11.0 

func (c *RegistryNewProcessorCall) Do(f func(context.Context, plugin.FullName, string) (sdk.Processor, error)) *RegistryNewProcessorCall

Do rewrite *gomock.Call.Do

func (*RegistryNewProcessorCall) DoAndReturn added in v0.11.0 

func (c *RegistryNewProcessorCall) DoAndReturn(f func(context.Context, plugin.FullName, string) (sdk.Processor, error)) *RegistryNewProcessorCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*RegistryNewProcessorCall) Return added in v0.11.0 

func (c *RegistryNewProcessorCall) Return(arg0 sdk.Processor, arg1 error) *RegistryNewProcessorCall

Return rewrite *gomock.Call.Return

type StandaloneRegistry added in v0.9.1 

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

StandaloneRegistry is a mock of standaloneRegistry interface.

func NewStandaloneRegistry added in v0.9.1 

func NewStandaloneRegistry(ctrl *gomock.Controller) *StandaloneRegistry

NewStandaloneRegistry creates a new mock instance.

func (*StandaloneRegistry) EXPECT added in v0.9.1 

func (m *StandaloneRegistry) EXPECT() *StandaloneRegistryMockRecorder

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

func (*StandaloneRegistry) List added in v0.9.1 

func (m *StandaloneRegistry) List() map[plugin.FullName]sdk.Specification

List mocks base method.

func (*StandaloneRegistry) NewProcessor added in v0.9.1 

func (m *StandaloneRegistry) NewProcessor(ctx context.Context, fullName plugin.FullName, id string) (sdk.Processor, error)

NewProcessor mocks base method.

func (*StandaloneRegistry) Register added in v0.9.1 

func (m *StandaloneRegistry) Register(ctx context.Context, path string) (plugin.FullName, error)

Register mocks base method.

type StandaloneRegistryListCall added in v0.11.0 

type StandaloneRegistryListCall struct {
	*gomock.Call
}

StandaloneRegistryListCall wrap *gomock.Call

func (*StandaloneRegistryListCall) Do added in v0.11.0 

func (c *StandaloneRegistryListCall) Do(f func() map[plugin.FullName]sdk.Specification) *StandaloneRegistryListCall

Do rewrite *gomock.Call.Do

func (*StandaloneRegistryListCall) DoAndReturn added in v0.11.0 

func (c *StandaloneRegistryListCall) DoAndReturn(f func() map[plugin.FullName]sdk.Specification) *StandaloneRegistryListCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*StandaloneRegistryListCall) Return added in v0.11.0 

func (c *StandaloneRegistryListCall) Return(arg0 map[plugin.FullName]sdk.Specification) *StandaloneRegistryListCall

Return rewrite *gomock.Call.Return

type StandaloneRegistryMockRecorder added in v0.9.1 

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

StandaloneRegistryMockRecorder is the mock recorder for StandaloneRegistry.

func (*StandaloneRegistryMockRecorder) List added in v0.9.1 

func (mr *StandaloneRegistryMockRecorder) List() *StandaloneRegistryListCall

List indicates an expected call of List.

func (*StandaloneRegistryMockRecorder) NewProcessor added in v0.9.1 

func (mr *StandaloneRegistryMockRecorder) NewProcessor(ctx, fullName, id any) *StandaloneRegistryNewProcessorCall

NewProcessor indicates an expected call of NewProcessor.

func (*StandaloneRegistryMockRecorder) Register added in v0.9.1 

func (mr *StandaloneRegistryMockRecorder) Register(ctx, path any) *StandaloneRegistryRegisterCall

Register indicates an expected call of Register.

type StandaloneRegistryNewProcessorCall added in v0.11.0 

type StandaloneRegistryNewProcessorCall struct {
	*gomock.Call
}

StandaloneRegistryNewProcessorCall wrap *gomock.Call

func (*StandaloneRegistryNewProcessorCall) Do added in v0.11.0 

func (c *StandaloneRegistryNewProcessorCall) Do(f func(context.Context, plugin.FullName, string) (sdk.Processor, error)) *StandaloneRegistryNewProcessorCall

Do rewrite *gomock.Call.Do

func (*StandaloneRegistryNewProcessorCall) DoAndReturn added in v0.11.0 

func (c *StandaloneRegistryNewProcessorCall) DoAndReturn(f func(context.Context, plugin.FullName, string) (sdk.Processor, error)) *StandaloneRegistryNewProcessorCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*StandaloneRegistryNewProcessorCall) Return added in v0.11.0 

func (c *StandaloneRegistryNewProcessorCall) Return(arg0 sdk.Processor, arg1 error) *StandaloneRegistryNewProcessorCall

Return rewrite *gomock.Call.Return

type StandaloneRegistryRegisterCall added in v0.11.0 

type StandaloneRegistryRegisterCall struct {
	*gomock.Call
}

StandaloneRegistryRegisterCall wrap *gomock.Call

func (*StandaloneRegistryRegisterCall) Do added in v0.11.0 

func (c *StandaloneRegistryRegisterCall) Do(f func(context.Context, string) (plugin.FullName, error)) *StandaloneRegistryRegisterCall

Do rewrite *gomock.Call.Do

func (*StandaloneRegistryRegisterCall) DoAndReturn added in v0.11.0 

func (c *StandaloneRegistryRegisterCall) DoAndReturn(f func(context.Context, string) (plugin.FullName, error)) *StandaloneRegistryRegisterCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*StandaloneRegistryRegisterCall) Return added in v0.11.0 

func (c *StandaloneRegistryRegisterCall) Return(arg0 plugin.FullName, arg1 error) *StandaloneRegistryRegisterCall

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.