mock

package
v0.3.0-nightly.20220819 Latest Latest
Warning

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

 Go to latest Published: Aug 15, 2022 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Overview

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 Builder 

type Builder struct {
	Ctrl             *gomock.Controller
	SetupSource      func(source *Source)
	SetupDestination func(source *Destination)
}

Builder is a builder that can build destination and source mocks.

func (Builder) Build 

func (b Builder) Build(t connector.Type, p connector.ProvisionType) (connector.Connector, error)

func (Builder) Init 

func (b Builder) Init(c connector.Connector, id string, cfg connector.Config) error

func (Builder) NewDestinationMock 

func (b Builder) NewDestinationMock(id string, d connector.Config) *Destination

func (Builder) NewSourceMock 

func (b Builder) NewSourceMock(id string, d connector.Config) *Source

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

func (m *Destination) Ack(arg0 context.Context) (record.Position, error)

Ack mocks base method.

func (*Destination) Config 

func (m *Destination) Config() connector.Config

Config mocks base method.

func (*Destination) CreatedAt added in v0.2.1 

func (m *Destination) CreatedAt() time.Time

CreatedAt 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) IsRunning 

func (m *Destination) IsRunning() bool

IsRunning mocks base method.

func (*Destination) MarshalJSON 

func (m *Destination) MarshalJSON() ([]byte, error)

func (*Destination) Open 

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

Open mocks base method.

func (*Destination) ProvisionedBy added in v0.3.0 

func (m *Destination) ProvisionedBy() connector.ProvisionType

ProvisionedBy mocks base method.

func (*Destination) SetConfig 

func (m *Destination) SetConfig(arg0 connector.Config)

SetConfig mocks base method.

func (*Destination) SetState 

func (m *Destination) SetState(arg0 connector.DestinationState)

SetState mocks base method.

func (*Destination) SetUpdatedAt added in v0.2.1 

func (m *Destination) SetUpdatedAt(arg0 time.Time)

SetUpdatedAt mocks base method.

func (*Destination) State 

func (m *Destination) State() connector.DestinationState

State mocks base method.

func (*Destination) Stop added in v0.3.0 

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

Stop mocks base method.

func (*Destination) Teardown 

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

Teardown mocks base method.

func (*Destination) Type 

func (m *Destination) Type() connector.Type

Type mocks base method.

func (*Destination) UnmarshalJSON 

func (m *Destination) UnmarshalJSON(b []byte) error

func (*Destination) UpdatedAt added in v0.2.1 

func (m *Destination) UpdatedAt() time.Time

UpdatedAt mocks base method.

func (*Destination) Validate 

func (m *Destination) Validate(arg0 context.Context, arg1 map[string]string) error

Validate mocks base method.

func (*Destination) Write 

func (m *Destination) Write(arg0 context.Context, arg1 record.Record) error

Write mocks base method.

type DestinationMockRecorder 

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

DestinationMockRecorder is the mock recorder for Destination.

func (*DestinationMockRecorder) Ack added in v0.2.0 

func (mr *DestinationMockRecorder) Ack(arg0 interface{}) *gomock.Call

Ack indicates an expected call of Ack.

func (*DestinationMockRecorder) Config 

func (mr *DestinationMockRecorder) Config() *gomock.Call

Config indicates an expected call of Config.

func (*DestinationMockRecorder) CreatedAt added in v0.2.1 

func (mr *DestinationMockRecorder) CreatedAt() *gomock.Call

CreatedAt indicates an expected call of CreatedAt.

func (*DestinationMockRecorder) Errors 

func (mr *DestinationMockRecorder) Errors() *gomock.Call

Errors indicates an expected call of Errors.

func (*DestinationMockRecorder) ID 

func (mr *DestinationMockRecorder) ID() *gomock.Call

ID indicates an expected call of ID.

func (*DestinationMockRecorder) IsRunning 

func (mr *DestinationMockRecorder) IsRunning() *gomock.Call

IsRunning indicates an expected call of IsRunning.

func (*DestinationMockRecorder) Open 

func (mr *DestinationMockRecorder) Open(arg0 interface{}) *gomock.Call

Open indicates an expected call of Open.

func (*DestinationMockRecorder) ProvisionedBy added in v0.3.0 

func (mr *DestinationMockRecorder) ProvisionedBy() *gomock.Call

ProvisionedBy indicates an expected call of ProvisionedBy.

func (*DestinationMockRecorder) SetConfig 

func (mr *DestinationMockRecorder) SetConfig(arg0 interface{}) *gomock.Call

SetConfig indicates an expected call of SetConfig.

func (*DestinationMockRecorder) SetState 

func (mr *DestinationMockRecorder) SetState(arg0 interface{}) *gomock.Call

SetState indicates an expected call of SetState.

func (*DestinationMockRecorder) SetUpdatedAt added in v0.2.1 

func (mr *DestinationMockRecorder) SetUpdatedAt(arg0 interface{}) *gomock.Call

SetUpdatedAt indicates an expected call of SetUpdatedAt.

func (*DestinationMockRecorder) State 

func (mr *DestinationMockRecorder) State() *gomock.Call

State indicates an expected call of State.

func (*DestinationMockRecorder) Stop added in v0.3.0 

func (mr *DestinationMockRecorder) Stop(arg0, arg1 interface{}) *gomock.Call

Stop indicates an expected call of Stop.

func (*DestinationMockRecorder) Teardown 

func (mr *DestinationMockRecorder) Teardown(arg0 interface{}) *gomock.Call

Teardown indicates an expected call of Teardown.

func (*DestinationMockRecorder) Type 

func (mr *DestinationMockRecorder) Type() *gomock.Call

Type indicates an expected call of Type.

func (*DestinationMockRecorder) UpdatedAt added in v0.2.1 

func (mr *DestinationMockRecorder) UpdatedAt() *gomock.Call

UpdatedAt indicates an expected call of UpdatedAt.

func (*DestinationMockRecorder) Validate 

func (mr *DestinationMockRecorder) Validate(arg0, arg1 interface{}) *gomock.Call

Validate indicates an expected call of Validate.

func (*DestinationMockRecorder) Write 

func (mr *DestinationMockRecorder) Write(arg0, arg1 interface{}) *gomock.Call

Write indicates an expected call of Write.

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 record.Position) error

Ack mocks base method.

func (*Source) Config 

func (m *Source) Config() connector.Config

Config mocks base method.

func (*Source) CreatedAt added in v0.2.1 

func (m *Source) CreatedAt() time.Time

CreatedAt 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) IsRunning 

func (m *Source) IsRunning() bool

IsRunning mocks base method.

func (*Source) MarshalJSON 

func (m *Source) MarshalJSON() ([]byte, error)

func (*Source) Open 

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

Open mocks base method.

func (*Source) ProvisionedBy added in v0.3.0 

func (m *Source) ProvisionedBy() connector.ProvisionType

ProvisionedBy mocks base method.

func (*Source) Read 

func (m *Source) Read(arg0 context.Context) (record.Record, error)

Read mocks base method.

func (*Source) SetConfig 

func (m *Source) SetConfig(arg0 connector.Config)

SetConfig mocks base method.

func (*Source) SetState 

func (m *Source) SetState(arg0 connector.SourceState)

SetState mocks base method.

func (*Source) SetUpdatedAt added in v0.2.1 

func (m *Source) SetUpdatedAt(arg0 time.Time)

SetUpdatedAt mocks base method.

func (*Source) State 

func (m *Source) State() connector.SourceState

State mocks base method.

func (*Source) Stop added in v0.2.0 

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

Stop mocks base method.

func (*Source) Teardown 

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

Teardown mocks base method.

func (*Source) Type 

func (m *Source) Type() connector.Type

Type mocks base method.

func (*Source) UnmarshalJSON 

func (m *Source) UnmarshalJSON(b []byte) error

func (*Source) UpdatedAt added in v0.2.1 

func (m *Source) UpdatedAt() time.Time

UpdatedAt mocks base method.

func (*Source) Validate 

func (m *Source) Validate(arg0 context.Context, arg1 map[string]string) error

Validate mocks base method.

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 interface{}) *gomock.Call

Ack indicates an expected call of Ack.

func (*SourceMockRecorder) Config 

func (mr *SourceMockRecorder) Config() *gomock.Call

Config indicates an expected call of Config.

func (*SourceMockRecorder) CreatedAt added in v0.2.1 

func (mr *SourceMockRecorder) CreatedAt() *gomock.Call

CreatedAt indicates an expected call of CreatedAt.

func (*SourceMockRecorder) Errors 

func (mr *SourceMockRecorder) Errors() *gomock.Call

Errors indicates an expected call of Errors.

func (*SourceMockRecorder) ID 

func (mr *SourceMockRecorder) ID() *gomock.Call

ID indicates an expected call of ID.

func (*SourceMockRecorder) IsRunning 

func (mr *SourceMockRecorder) IsRunning() *gomock.Call

IsRunning indicates an expected call of IsRunning.

func (*SourceMockRecorder) Open 

func (mr *SourceMockRecorder) Open(arg0 interface{}) *gomock.Call

Open indicates an expected call of Open.

func (*SourceMockRecorder) ProvisionedBy added in v0.3.0 

func (mr *SourceMockRecorder) ProvisionedBy() *gomock.Call

ProvisionedBy indicates an expected call of ProvisionedBy.

func (*SourceMockRecorder) Read 

func (mr *SourceMockRecorder) Read(arg0 interface{}) *gomock.Call

Read indicates an expected call of Read.

func (*SourceMockRecorder) SetConfig 

func (mr *SourceMockRecorder) SetConfig(arg0 interface{}) *gomock.Call

SetConfig indicates an expected call of SetConfig.

func (*SourceMockRecorder) SetState 

func (mr *SourceMockRecorder) SetState(arg0 interface{}) *gomock.Call

SetState indicates an expected call of SetState.

func (*SourceMockRecorder) SetUpdatedAt added in v0.2.1 

func (mr *SourceMockRecorder) SetUpdatedAt(arg0 interface{}) *gomock.Call

SetUpdatedAt indicates an expected call of SetUpdatedAt.

func (*SourceMockRecorder) State 

func (mr *SourceMockRecorder) State() *gomock.Call

State indicates an expected call of State.

func (*SourceMockRecorder) Stop added in v0.2.0 

func (mr *SourceMockRecorder) Stop(arg0 interface{}) *gomock.Call

Stop indicates an expected call of Stop.

func (*SourceMockRecorder) Teardown 

func (mr *SourceMockRecorder) Teardown(arg0 interface{}) *gomock.Call

Teardown indicates an expected call of Teardown.

func (*SourceMockRecorder) Type 

func (mr *SourceMockRecorder) Type() *gomock.Call

Type indicates an expected call of Type.

func (*SourceMockRecorder) UpdatedAt added in v0.2.1 

func (mr *SourceMockRecorder) UpdatedAt() *gomock.Call

UpdatedAt indicates an expected call of UpdatedAt.

func (*SourceMockRecorder) Validate 

func (mr *SourceMockRecorder) Validate(arg0, arg1 interface{}) *gomock.Call

Validate indicates an expected call of Validate.

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.