mock

package
v0.7.0-nightly.20230422 Latest Latest
Warning

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

 Go to latest Published: Apr 19, 2023 License: Apache-2.0 Imports: 4 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.

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

Write mocks base method.

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

Close indicates an expected call of Close.

func (*DLQHandlerMockRecorder) Open 

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

Open indicates an expected call of Open.

func (*DLQHandlerMockRecorder) Write 

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

Write indicates an expected call of Write.

type Destination added in v0.5.0 

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

Destination is a mock of Destination interface.

func NewDestination added in v0.5.0 

func NewDestination(ctrl *gomock.Controller) *Destination

NewDestination creates a new mock instance.

func (*Destination) Ack added in v0.5.0 

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

Ack mocks base method.

func (*Destination) EXPECT added in v0.5.0 

func (m *Destination) EXPECT() *DestinationMockRecorder

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

func (*Destination) Errors added in v0.5.0 

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

Errors mocks base method.

func (*Destination) ID added in v0.5.0 

func (m *Destination) ID() string

ID mocks base method.

func (*Destination) Open added in v0.5.0 

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

Open mocks base method.

func (*Destination) Stop added in v0.5.0 

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

Stop mocks base method.

func (*Destination) Teardown added in v0.5.0 

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

Teardown mocks base method.

func (*Destination) Write added in v0.5.0 

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

Write mocks base method.

type DestinationMockRecorder added in v0.5.0 

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

DestinationMockRecorder is the mock recorder for Destination.

func (*DestinationMockRecorder) Ack added in v0.5.0 

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

Ack indicates an expected call of Ack.

func (*DestinationMockRecorder) Errors added in v0.5.0 

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

Errors indicates an expected call of Errors.

func (*DestinationMockRecorder) ID added in v0.5.0 

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

ID indicates an expected call of ID.

func (*DestinationMockRecorder) Open added in v0.5.0 

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

Open indicates an expected call of Open.

func (*DestinationMockRecorder) Stop added in v0.5.0 

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

Stop indicates an expected call of Stop.

func (*DestinationMockRecorder) Teardown added in v0.5.0 

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

Teardown indicates an expected call of Teardown.

func (*DestinationMockRecorder) Write added in v0.5.0 

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

Write indicates an expected call of Write.

type Source added in v0.5.0 

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

Source is a mock of Source interface.

func NewSource added in v0.5.0 

func NewSource(ctrl *gomock.Controller) *Source

NewSource creates a new mock instance.

func (*Source) Ack added in v0.5.0 

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

Ack mocks base method.

func (*Source) EXPECT added in v0.5.0 

func (m *Source) EXPECT() *SourceMockRecorder

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

func (*Source) Errors added in v0.5.0 

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

Errors mocks base method.

func (*Source) ID added in v0.5.0 

func (m *Source) ID() string

ID mocks base method.

func (*Source) Open added in v0.5.0 

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

Open mocks base method.

func (*Source) Read added in v0.5.0 

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

Read mocks base method.

func (*Source) Stop added in v0.5.0 

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

Stop mocks base method.

func (*Source) Teardown added in v0.5.0 

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

Teardown mocks base method.

type SourceMockRecorder added in v0.5.0 

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

SourceMockRecorder is the mock recorder for Source.

func (*SourceMockRecorder) Ack added in v0.5.0 

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

Ack indicates an expected call of Ack.

func (*SourceMockRecorder) Errors added in v0.5.0 

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

Errors indicates an expected call of Errors.

func (*SourceMockRecorder) ID added in v0.5.0 

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

ID indicates an expected call of ID.

func (*SourceMockRecorder) Open added in v0.5.0 

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

Open indicates an expected call of Open.

func (*SourceMockRecorder) Read added in v0.5.0 

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

Read indicates an expected call of Read.

func (*SourceMockRecorder) Stop added in v0.5.0 

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

Stop indicates an expected call of Stop.

func (*SourceMockRecorder) Teardown added in v0.5.0 

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

Teardown indicates an expected call of Teardown.

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.