mock

package
v0.3.0-nightly.20220720 Latest Latest
Warning

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

 Go to latest Published: Jul 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) (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) 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) 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) 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) 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) 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) 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) 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.