Documentation
¶
Overview ¶
Package mock is a generated GoMock package.
Package mock is a generated GoMock package.
Package mock is a generated GoMock package.
Index ¶
- type DLQHandler
- type DLQHandlerMockRecorder
- type Destination
- func (m *Destination) Ack(arg0 context.Context) (record.Position, error)
- func (m *Destination) EXPECT() *DestinationMockRecorder
- func (m *Destination) Errors() <-chan error
- func (m *Destination) ID() string
- func (m *Destination) Open(arg0 context.Context) error
- func (m *Destination) Stop(arg0 context.Context, arg1 record.Position) error
- func (m *Destination) Teardown(arg0 context.Context) error
- func (m *Destination) Write(arg0 context.Context, arg1 record.Record) error
- type DestinationMockRecorder
- func (mr *DestinationMockRecorder) Ack(arg0 any) *gomock.Call
- func (mr *DestinationMockRecorder) Errors() *gomock.Call
- func (mr *DestinationMockRecorder) ID() *gomock.Call
- func (mr *DestinationMockRecorder) Open(arg0 any) *gomock.Call
- func (mr *DestinationMockRecorder) Stop(arg0, arg1 any) *gomock.Call
- func (mr *DestinationMockRecorder) Teardown(arg0 any) *gomock.Call
- func (mr *DestinationMockRecorder) Write(arg0, arg1 any) *gomock.Call
- type Source
- func (m *Source) Ack(arg0 context.Context, arg1 record.Position) error
- func (m *Source) EXPECT() *SourceMockRecorder
- func (m *Source) Errors() <-chan error
- func (m *Source) ID() string
- func (m *Source) Open(arg0 context.Context) error
- func (m *Source) Read(arg0 context.Context) (record.Record, error)
- func (m *Source) Stop(arg0 context.Context) (record.Position, error)
- func (m *Source) Teardown(arg0 context.Context) error
- type SourceMockRecorder
- func (mr *SourceMockRecorder) Ack(arg0, arg1 any) *gomock.Call
- func (mr *SourceMockRecorder) Errors() *gomock.Call
- func (mr *SourceMockRecorder) ID() *gomock.Call
- func (mr *SourceMockRecorder) Open(arg0 any) *gomock.Call
- func (mr *SourceMockRecorder) Read(arg0 any) *gomock.Call
- func (mr *SourceMockRecorder) Stop(arg0 any) *gomock.Call
- func (mr *SourceMockRecorder) Teardown(arg0 any) *gomock.Call
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.
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 any) *gomock.Call
Close indicates an expected call of Close.
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) 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) Open ¶ added in v0.5.0
func (m *Destination) Open(arg0 context.Context) error
Open 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 any) *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 any) *gomock.Call
Open indicates an expected call of Open.
func (*DestinationMockRecorder) Stop ¶ added in v0.5.0
func (mr *DestinationMockRecorder) Stop(arg0, arg1 any) *gomock.Call
Stop indicates an expected call of Stop.
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) EXPECT ¶ added in v0.5.0
func (m *Source) EXPECT() *SourceMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
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 any) *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 any) *gomock.Call
Open indicates an expected call of Open.
func (*SourceMockRecorder) Read ¶ added in v0.5.0
func (mr *SourceMockRecorder) Read(arg0 any) *gomock.Call
Read indicates an expected call of Read.
Source Files