mock

Documentation

Overview

Package mock is a generated GoMock package.

Package mock is a generated GoMock package.

Index

• type Processor
  • func NewProcessor(ctrl *gomock.Controller) *Processor
  • func (m *Processor) Configure(arg0 context.Context, arg1 map[string]string) error
  • func (m *Processor) EXPECT() *ProcessorMockRecorder
  • func (m *Processor) Open(arg0 context.Context) error
  • func (m *Processor) Process(arg0 context.Context, arg1 []opencdc.Record) []sdk.ProcessedRecord
  • func (m *Processor) Specification() (sdk.Specification, error)
  • func (m *Processor) Teardown(arg0 context.Context) error
• type ProcessorMockRecorder
  • func (mr *ProcessorMockRecorder) Configure(arg0, arg1 any) *gomock.Call
  • func (mr *ProcessorMockRecorder) Open(arg0 any) *gomock.Call
  • func (mr *ProcessorMockRecorder) Process(arg0, arg1 any) *gomock.Call
  • func (mr *ProcessorMockRecorder) Specification() *gomock.Call
  • func (mr *ProcessorMockRecorder) Teardown(arg0 any) *gomock.Call
• type Registry
  • func NewRegistry(ctrl *gomock.Controller) *Registry
  • func (m *Registry) EXPECT() *RegistryMockRecorder
  • func (m *Registry) List() map[plugin.FullName]sdk.Specification
  • func (m *Registry) NewProcessor(ctx context.Context, fullName plugin.FullName, id string) (sdk.Processor, error)
• type RegistryMockRecorder
  • func (mr *RegistryMockRecorder) List() *gomock.Call
  • func (mr *RegistryMockRecorder) NewProcessor(ctx, fullName, id any) *gomock.Call
• type StandaloneRegistry
  • func NewStandaloneRegistry(ctrl *gomock.Controller) *StandaloneRegistry
  • func (m *StandaloneRegistry) EXPECT() *StandaloneRegistryMockRecorder
  • func (m *StandaloneRegistry) List() map[plugin.FullName]sdk.Specification
  • func (m *StandaloneRegistry) NewProcessor(ctx context.Context, fullName plugin.FullName, id string) (sdk.Processor, error)
  • func (m *StandaloneRegistry) Register(ctx context.Context, path string) (plugin.FullName, error)
• type StandaloneRegistryMockRecorder
  • func (mr *StandaloneRegistryMockRecorder) List() *gomock.Call
  • func (mr *StandaloneRegistryMockRecorder) NewProcessor(ctx, fullName, id any) *gomock.Call
  • func (mr *StandaloneRegistryMockRecorder) Register(ctx, path any) *gomock.Call

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 map[string]string) 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) 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 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) *gomock.Call

Configure indicates an expected call of Configure.

func (*ProcessorMockRecorder) Open

func (mr *ProcessorMockRecorder) Open(arg0 any) *gomock.Call

Open indicates an expected call of Open.

func (*ProcessorMockRecorder) Process

func (mr *ProcessorMockRecorder) Process(arg0, arg1 any) *gomock.Call

Process indicates an expected call of Process.

func (*ProcessorMockRecorder) Specification

func (mr *ProcessorMockRecorder) Specification() *gomock.Call

Specification indicates an expected call of Specification.

func (*ProcessorMockRecorder) Teardown

func (mr *ProcessorMockRecorder) Teardown(arg0 any) *gomock.Call

Teardown indicates an expected call of Teardown.

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 RegistryMockRecorder

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

RegistryMockRecorder is the mock recorder for Registry.

func (*RegistryMockRecorder) List

func (mr *RegistryMockRecorder) List() *gomock.Call

List indicates an expected call of List.

func (*RegistryMockRecorder) NewProcessor

func (mr *RegistryMockRecorder) NewProcessor(ctx, fullName, id any) *gomock.Call

NewProcessor indicates an expected call of NewProcessor.

type StandaloneRegistry

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

StandaloneRegistry is a mock of standaloneRegistry interface.

func NewStandaloneRegistry

func NewStandaloneRegistry(ctrl *gomock.Controller) *StandaloneRegistry

NewStandaloneRegistry creates a new mock instance.

func (*StandaloneRegistry) EXPECT

func (m *StandaloneRegistry) EXPECT() *StandaloneRegistryMockRecorder

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

func (*StandaloneRegistry) List

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

List mocks base method.

func (*StandaloneRegistry) NewProcessor

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

NewProcessor mocks base method.

func (*StandaloneRegistry) Register

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

Register mocks base method.

type StandaloneRegistryMockRecorder

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

StandaloneRegistryMockRecorder is the mock recorder for StandaloneRegistry.

func (*StandaloneRegistryMockRecorder) List

func (mr *StandaloneRegistryMockRecorder) List() *gomock.Call

List indicates an expected call of List.

func (*StandaloneRegistryMockRecorder) NewProcessor

func (mr *StandaloneRegistryMockRecorder) NewProcessor(ctx, fullName, id any) *gomock.Call

NewProcessor indicates an expected call of NewProcessor.

func (*StandaloneRegistryMockRecorder) Register

func (mr *StandaloneRegistryMockRecorder) Register(ctx, path any) *gomock.Call

Register indicates an expected call of Register.