mocks

package
v0.55.0 Latest Latest
Warning

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

 Go to latest Published: Feb 18, 2026 License: MIT Imports: 3 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AcknowledgeableInput 

type AcknowledgeableInput struct {
	mock.Mock
}

AcknowledgeableInput is an autogenerated mock type for the AcknowledgeableInput type

func NewAcknowledgeableInput 

func NewAcknowledgeableInput(t interface {
	mock.TestingT
	Cleanup(func())
}) *AcknowledgeableInput

NewAcknowledgeableInput creates a new instance of AcknowledgeableInput. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*AcknowledgeableInput) Ack 

func (_m *AcknowledgeableInput) Ack(ctx context.Context, msg *stream.Message, ack bool) error

Ack provides a mock function with given fields: ctx, msg, ack

func (*AcknowledgeableInput) AckBatch 

func (_m *AcknowledgeableInput) AckBatch(ctx context.Context, msgs []*stream.Message, acks []bool) error

AckBatch provides a mock function with given fields: ctx, msgs, acks

func (*AcknowledgeableInput) Data 

func (_m *AcknowledgeableInput) Data() <-chan *stream.Message

Data provides a mock function with no fields

func (*AcknowledgeableInput) EXPECT 

func (_m *AcknowledgeableInput) EXPECT() *AcknowledgeableInput_Expecter

func (*AcknowledgeableInput) IsHealthy added in v0.40.17 

func (_m *AcknowledgeableInput) IsHealthy() bool

IsHealthy provides a mock function with no fields

func (*AcknowledgeableInput) Run 

func (_m *AcknowledgeableInput) Run(ctx context.Context) error

Run provides a mock function with given fields: ctx

func (*AcknowledgeableInput) Stop 

func (_m *AcknowledgeableInput) Stop(ctx context.Context)

Stop provides a mock function with given fields: ctx

type AcknowledgeableInput_AckBatch_Call 

type AcknowledgeableInput_AckBatch_Call struct {
	*mock.Call
}

AcknowledgeableInput_AckBatch_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'AckBatch'

func (*AcknowledgeableInput_AckBatch_Call) Return 

func (_c *AcknowledgeableInput_AckBatch_Call) Return(_a0 error) *AcknowledgeableInput_AckBatch_Call

func (*AcknowledgeableInput_AckBatch_Call) Run 

func (_c *AcknowledgeableInput_AckBatch_Call) Run(run func(ctx context.Context, msgs []*stream.Message, acks []bool)) *AcknowledgeableInput_AckBatch_Call

func (*AcknowledgeableInput_AckBatch_Call) RunAndReturn 

func (_c *AcknowledgeableInput_AckBatch_Call) RunAndReturn(run func(context.Context, []*stream.Message, []bool) error) *AcknowledgeableInput_AckBatch_Call

type AcknowledgeableInput_Ack_Call 

type AcknowledgeableInput_Ack_Call struct {
	*mock.Call
}

AcknowledgeableInput_Ack_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Ack'

func (*AcknowledgeableInput_Ack_Call) Return 

func (_c *AcknowledgeableInput_Ack_Call) Return(_a0 error) *AcknowledgeableInput_Ack_Call

func (*AcknowledgeableInput_Ack_Call) Run 

func (_c *AcknowledgeableInput_Ack_Call) Run(run func(ctx context.Context, msg *stream.Message, ack bool)) *AcknowledgeableInput_Ack_Call

func (*AcknowledgeableInput_Ack_Call) RunAndReturn 

func (_c *AcknowledgeableInput_Ack_Call) RunAndReturn(run func(context.Context, *stream.Message, bool) error) *AcknowledgeableInput_Ack_Call

type AcknowledgeableInput_Data_Call 

type AcknowledgeableInput_Data_Call struct {
	*mock.Call
}

AcknowledgeableInput_Data_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Data'

func (*AcknowledgeableInput_Data_Call) Return 

func (_c *AcknowledgeableInput_Data_Call) Return(_a0 <-chan *stream.Message) *AcknowledgeableInput_Data_Call

func (*AcknowledgeableInput_Data_Call) Run 

func (_c *AcknowledgeableInput_Data_Call) Run(run func()) *AcknowledgeableInput_Data_Call

func (*AcknowledgeableInput_Data_Call) RunAndReturn 

func (_c *AcknowledgeableInput_Data_Call) RunAndReturn(run func() <-chan *stream.Message) *AcknowledgeableInput_Data_Call

type AcknowledgeableInput_Expecter 

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

func (*AcknowledgeableInput_Expecter) Ack 

func (_e *AcknowledgeableInput_Expecter) Ack(ctx interface{}, msg interface{}, ack interface{}) *AcknowledgeableInput_Ack_Call

Ack is a helper method to define mock.On call

  • ctx context.Context
  • msg *stream.Message
  • ack bool

func (*AcknowledgeableInput_Expecter) AckBatch 

func (_e *AcknowledgeableInput_Expecter) AckBatch(ctx interface{}, msgs interface{}, acks interface{}) *AcknowledgeableInput_AckBatch_Call

AckBatch is a helper method to define mock.On call

  • ctx context.Context
  • msgs []*stream.Message
  • acks []bool

func (*AcknowledgeableInput_Expecter) Data 

func (_e *AcknowledgeableInput_Expecter) Data() *AcknowledgeableInput_Data_Call

Data is a helper method to define mock.On call

func (*AcknowledgeableInput_Expecter) IsHealthy added in v0.40.17 

func (_e *AcknowledgeableInput_Expecter) IsHealthy() *AcknowledgeableInput_IsHealthy_Call

IsHealthy is a helper method to define mock.On call

func (*AcknowledgeableInput_Expecter) Run 

func (_e *AcknowledgeableInput_Expecter) Run(ctx interface{}) *AcknowledgeableInput_Run_Call

Run is a helper method to define mock.On call

  • ctx context.Context

func (*AcknowledgeableInput_Expecter) Stop 

func (_e *AcknowledgeableInput_Expecter) Stop(ctx interface{}) *AcknowledgeableInput_Stop_Call

Stop is a helper method to define mock.On call

  • ctx context.Context

type AcknowledgeableInput_IsHealthy_Call added in v0.40.17 

type AcknowledgeableInput_IsHealthy_Call struct {
	*mock.Call
}

AcknowledgeableInput_IsHealthy_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'IsHealthy'

func (*AcknowledgeableInput_IsHealthy_Call) Return added in v0.40.17 

func (_c *AcknowledgeableInput_IsHealthy_Call) Return(_a0 bool) *AcknowledgeableInput_IsHealthy_Call

func (*AcknowledgeableInput_IsHealthy_Call) Run added in v0.40.17 

func (_c *AcknowledgeableInput_IsHealthy_Call) Run(run func()) *AcknowledgeableInput_IsHealthy_Call

func (*AcknowledgeableInput_IsHealthy_Call) RunAndReturn added in v0.40.17 

func (_c *AcknowledgeableInput_IsHealthy_Call) RunAndReturn(run func() bool) *AcknowledgeableInput_IsHealthy_Call

type AcknowledgeableInput_Run_Call 

type AcknowledgeableInput_Run_Call struct {
	*mock.Call
}

AcknowledgeableInput_Run_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Run'

func (*AcknowledgeableInput_Run_Call) Return 

func (_c *AcknowledgeableInput_Run_Call) Return(_a0 error) *AcknowledgeableInput_Run_Call

func (*AcknowledgeableInput_Run_Call) Run 

func (_c *AcknowledgeableInput_Run_Call) Run(run func(ctx context.Context)) *AcknowledgeableInput_Run_Call

func (*AcknowledgeableInput_Run_Call) RunAndReturn 

func (_c *AcknowledgeableInput_Run_Call) RunAndReturn(run func(context.Context) error) *AcknowledgeableInput_Run_Call

type AcknowledgeableInput_Stop_Call 

type AcknowledgeableInput_Stop_Call struct {
	*mock.Call
}

AcknowledgeableInput_Stop_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Stop'

func (*AcknowledgeableInput_Stop_Call) Return 

func (_c *AcknowledgeableInput_Stop_Call) Return() *AcknowledgeableInput_Stop_Call

func (*AcknowledgeableInput_Stop_Call) Run 

func (_c *AcknowledgeableInput_Stop_Call) Run(run func(ctx context.Context)) *AcknowledgeableInput_Stop_Call

func (*AcknowledgeableInput_Stop_Call) RunAndReturn 

func (_c *AcknowledgeableInput_Stop_Call) RunAndReturn(run func(context.Context)) *AcknowledgeableInput_Stop_Call

type BatchConsumerCallback 

type BatchConsumerCallback[M interface{}] struct {
	mock.Mock
}

BatchConsumerCallback is an autogenerated mock type for the BatchConsumerCallback type

func NewBatchConsumerCallback 

func NewBatchConsumerCallback[M interface{}](t interface {
	mock.TestingT
	Cleanup(func())
}) *BatchConsumerCallback[M]

NewBatchConsumerCallback creates a new instance of BatchConsumerCallback. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*BatchConsumerCallback[M]) Consume 

func (_m *BatchConsumerCallback[M]) Consume(ctx context.Context, models []M, attributes []map[string]string) ([]bool, error)

Consume provides a mock function with given fields: ctx, models, attributes

func (*BatchConsumerCallback[M]) EXPECT 

func (_m *BatchConsumerCallback[M]) EXPECT() *BatchConsumerCallback_Expecter[M]

type BatchConsumerCallback_Consume_Call 

type BatchConsumerCallback_Consume_Call[M interface{}] struct {
	*mock.Call
}

BatchConsumerCallback_Consume_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Consume'

func (*BatchConsumerCallback_Consume_Call[M]) Return 

func (_c *BatchConsumerCallback_Consume_Call[M]) Return(_a0 []bool, _a1 error) *BatchConsumerCallback_Consume_Call[M]

func (*BatchConsumerCallback_Consume_Call[M]) Run 

func (_c *BatchConsumerCallback_Consume_Call[M]) Run(run func(ctx context.Context, models []M, attributes []map[string]string)) *BatchConsumerCallback_Consume_Call[M]

func (*BatchConsumerCallback_Consume_Call[M]) RunAndReturn 

func (_c *BatchConsumerCallback_Consume_Call[M]) RunAndReturn(run func(context.Context, []M, []map[string]string) ([]bool, error)) *BatchConsumerCallback_Consume_Call[M]

type BatchConsumerCallback_Expecter 

type BatchConsumerCallback_Expecter[M interface{}] struct {
	// contains filtered or unexported fields
}

func (*BatchConsumerCallback_Expecter[M]) Consume 

func (_e *BatchConsumerCallback_Expecter[M]) Consume(ctx interface{}, models interface{}, attributes interface{}) *BatchConsumerCallback_Consume_Call[M]

Consume is a helper method to define mock.On call

  • ctx context.Context
  • models []M
  • attributes []map[string]string

type ConsumerCallback 

type ConsumerCallback[M interface{}] struct {
	mock.Mock
}

ConsumerCallback is an autogenerated mock type for the ConsumerCallback type

func NewConsumerCallback 

func NewConsumerCallback[M interface{}](t interface {
	mock.TestingT
	Cleanup(func())
}) *ConsumerCallback[M]

NewConsumerCallback creates a new instance of ConsumerCallback. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*ConsumerCallback[M]) Consume 

func (_m *ConsumerCallback[M]) Consume(ctx context.Context, model M, attributes map[string]string) (bool, error)

Consume provides a mock function with given fields: ctx, model, attributes

func (*ConsumerCallback[M]) EXPECT 

func (_m *ConsumerCallback[M]) EXPECT() *ConsumerCallback_Expecter[M]

type ConsumerCallback_Consume_Call 

type ConsumerCallback_Consume_Call[M interface{}] struct {
	*mock.Call
}

ConsumerCallback_Consume_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Consume'

func (*ConsumerCallback_Consume_Call[M]) Return 

func (_c *ConsumerCallback_Consume_Call[M]) Return(_a0 bool, _a1 error) *ConsumerCallback_Consume_Call[M]

func (*ConsumerCallback_Consume_Call[M]) Run 

func (_c *ConsumerCallback_Consume_Call[M]) Run(run func(ctx context.Context, model M, attributes map[string]string)) *ConsumerCallback_Consume_Call[M]

func (*ConsumerCallback_Consume_Call[M]) RunAndReturn 

func (_c *ConsumerCallback_Consume_Call[M]) RunAndReturn(run func(context.Context, M, map[string]string) (bool, error)) *ConsumerCallback_Consume_Call[M]

type ConsumerCallback_Expecter 

type ConsumerCallback_Expecter[M interface{}] struct {
	// contains filtered or unexported fields
}

func (*ConsumerCallback_Expecter[M]) Consume 

func (_e *ConsumerCallback_Expecter[M]) Consume(ctx interface{}, model interface{}, attributes interface{}) *ConsumerCallback_Consume_Call[M]

Consume is a helper method to define mock.On call

  • ctx context.Context
  • model M
  • attributes map[string]string

type Input 

type Input struct {
	mock.Mock
}

Input is an autogenerated mock type for the Input type

func NewInput 

func NewInput(t interface {
	mock.TestingT
	Cleanup(func())
}) *Input

NewInput creates a new instance of Input. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*Input) Data 

func (_m *Input) Data() <-chan *stream.Message

Data provides a mock function with no fields

func (*Input) EXPECT 

func (_m *Input) EXPECT() *Input_Expecter

func (*Input) IsHealthy added in v0.40.17 

func (_m *Input) IsHealthy() bool

IsHealthy provides a mock function with no fields

func (*Input) Run 

func (_m *Input) Run(ctx context.Context) error

Run provides a mock function with given fields: ctx

func (*Input) Stop 

func (_m *Input) Stop(ctx context.Context)

Stop provides a mock function with given fields: ctx

type Input_Data_Call 

type Input_Data_Call struct {
	*mock.Call
}

Input_Data_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Data'

func (*Input_Data_Call) Return 

func (_c *Input_Data_Call) Return(_a0 <-chan *stream.Message) *Input_Data_Call

func (*Input_Data_Call) Run 

func (_c *Input_Data_Call) Run(run func()) *Input_Data_Call

func (*Input_Data_Call) RunAndReturn 

func (_c *Input_Data_Call) RunAndReturn(run func() <-chan *stream.Message) *Input_Data_Call

type Input_Expecter 

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

func (*Input_Expecter) Data 

func (_e *Input_Expecter) Data() *Input_Data_Call

Data is a helper method to define mock.On call

func (*Input_Expecter) IsHealthy added in v0.40.17 

func (_e *Input_Expecter) IsHealthy() *Input_IsHealthy_Call

IsHealthy is a helper method to define mock.On call

func (*Input_Expecter) Run 

func (_e *Input_Expecter) Run(ctx interface{}) *Input_Run_Call

Run is a helper method to define mock.On call

  • ctx context.Context

func (*Input_Expecter) Stop 

func (_e *Input_Expecter) Stop(ctx interface{}) *Input_Stop_Call

Stop is a helper method to define mock.On call

  • ctx context.Context

type Input_IsHealthy_Call added in v0.40.17 

type Input_IsHealthy_Call struct {
	*mock.Call
}

Input_IsHealthy_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'IsHealthy'

func (*Input_IsHealthy_Call) Return added in v0.40.17 

func (_c *Input_IsHealthy_Call) Return(_a0 bool) *Input_IsHealthy_Call

func (*Input_IsHealthy_Call) Run added in v0.40.17 

func (_c *Input_IsHealthy_Call) Run(run func()) *Input_IsHealthy_Call

func (*Input_IsHealthy_Call) RunAndReturn added in v0.40.17 

func (_c *Input_IsHealthy_Call) RunAndReturn(run func() bool) *Input_IsHealthy_Call

type Input_Run_Call 

type Input_Run_Call struct {
	*mock.Call
}

Input_Run_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Run'

func (*Input_Run_Call) Return 

func (_c *Input_Run_Call) Return(_a0 error) *Input_Run_Call

func (*Input_Run_Call) Run 

func (_c *Input_Run_Call) Run(run func(ctx context.Context)) *Input_Run_Call

func (*Input_Run_Call) RunAndReturn 

func (_c *Input_Run_Call) RunAndReturn(run func(context.Context) error) *Input_Run_Call

type Input_Stop_Call 

type Input_Stop_Call struct {
	*mock.Call
}

Input_Stop_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Stop'

func (*Input_Stop_Call) Return 

func (_c *Input_Stop_Call) Return() *Input_Stop_Call

func (*Input_Stop_Call) Run 

func (_c *Input_Stop_Call) Run(run func(ctx context.Context)) *Input_Stop_Call

func (*Input_Stop_Call) RunAndReturn 

func (_c *Input_Stop_Call) RunAndReturn(run func(context.Context)) *Input_Stop_Call

type KinsumerAutoscaleOrchestrator added in v0.34.1 

type KinsumerAutoscaleOrchestrator struct {
	mock.Mock
}

KinsumerAutoscaleOrchestrator is an autogenerated mock type for the KinsumerAutoscaleOrchestrator type

func NewKinsumerAutoscaleOrchestrator added in v0.34.1 

func NewKinsumerAutoscaleOrchestrator(t interface {
	mock.TestingT
	Cleanup(func())
}) *KinsumerAutoscaleOrchestrator

NewKinsumerAutoscaleOrchestrator creates a new instance of KinsumerAutoscaleOrchestrator. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*KinsumerAutoscaleOrchestrator) EXPECT added in v0.34.1 

func (_m *KinsumerAutoscaleOrchestrator) EXPECT() *KinsumerAutoscaleOrchestrator_Expecter

func (*KinsumerAutoscaleOrchestrator) GetCurrentTaskCount added in v0.34.1 

func (_m *KinsumerAutoscaleOrchestrator) GetCurrentTaskCount(ctx context.Context) (int32, error)

GetCurrentTaskCount provides a mock function with given fields: ctx

func (*KinsumerAutoscaleOrchestrator) UpdateTaskCount added in v0.34.1 

func (_m *KinsumerAutoscaleOrchestrator) UpdateTaskCount(ctx context.Context, taskCount int32) error

UpdateTaskCount provides a mock function with given fields: ctx, taskCount

type KinsumerAutoscaleOrchestrator_Expecter added in v0.34.1 

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

func (*KinsumerAutoscaleOrchestrator_Expecter) GetCurrentTaskCount added in v0.34.1 

func (_e *KinsumerAutoscaleOrchestrator_Expecter) GetCurrentTaskCount(ctx interface{}) *KinsumerAutoscaleOrchestrator_GetCurrentTaskCount_Call

GetCurrentTaskCount is a helper method to define mock.On call

  • ctx context.Context

func (*KinsumerAutoscaleOrchestrator_Expecter) UpdateTaskCount added in v0.34.1 

func (_e *KinsumerAutoscaleOrchestrator_Expecter) UpdateTaskCount(ctx interface{}, taskCount interface{}) *KinsumerAutoscaleOrchestrator_UpdateTaskCount_Call

UpdateTaskCount is a helper method to define mock.On call

  • ctx context.Context
  • taskCount int32

type KinsumerAutoscaleOrchestrator_GetCurrentTaskCount_Call added in v0.34.1 

type KinsumerAutoscaleOrchestrator_GetCurrentTaskCount_Call struct {
	*mock.Call
}

KinsumerAutoscaleOrchestrator_GetCurrentTaskCount_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetCurrentTaskCount'

func (*KinsumerAutoscaleOrchestrator_GetCurrentTaskCount_Call) Return added in v0.34.1 

func (_c *KinsumerAutoscaleOrchestrator_GetCurrentTaskCount_Call) Return(_a0 int32, _a1 error) *KinsumerAutoscaleOrchestrator_GetCurrentTaskCount_Call

func (*KinsumerAutoscaleOrchestrator_GetCurrentTaskCount_Call) Run added in v0.34.1 

func (_c *KinsumerAutoscaleOrchestrator_GetCurrentTaskCount_Call) Run(run func(ctx context.Context)) *KinsumerAutoscaleOrchestrator_GetCurrentTaskCount_Call

func (*KinsumerAutoscaleOrchestrator_GetCurrentTaskCount_Call) RunAndReturn added in v0.34.1 

func (_c *KinsumerAutoscaleOrchestrator_GetCurrentTaskCount_Call) RunAndReturn(run func(context.Context) (int32, error)) *KinsumerAutoscaleOrchestrator_GetCurrentTaskCount_Call

type KinsumerAutoscaleOrchestrator_UpdateTaskCount_Call added in v0.34.1 

type KinsumerAutoscaleOrchestrator_UpdateTaskCount_Call struct {
	*mock.Call
}

KinsumerAutoscaleOrchestrator_UpdateTaskCount_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateTaskCount'

func (*KinsumerAutoscaleOrchestrator_UpdateTaskCount_Call) Return added in v0.34.1 

func (_c *KinsumerAutoscaleOrchestrator_UpdateTaskCount_Call) Return(_a0 error) *KinsumerAutoscaleOrchestrator_UpdateTaskCount_Call

func (*KinsumerAutoscaleOrchestrator_UpdateTaskCount_Call) Run added in v0.34.1 

func (_c *KinsumerAutoscaleOrchestrator_UpdateTaskCount_Call) Run(run func(ctx context.Context, taskCount int32)) *KinsumerAutoscaleOrchestrator_UpdateTaskCount_Call

func (*KinsumerAutoscaleOrchestrator_UpdateTaskCount_Call) RunAndReturn added in v0.34.1 

func (_c *KinsumerAutoscaleOrchestrator_UpdateTaskCount_Call) RunAndReturn(run func(context.Context, int32) error) *KinsumerAutoscaleOrchestrator_UpdateTaskCount_Call

type MessageEncoder 

type MessageEncoder struct {
	mock.Mock
}

MessageEncoder is an autogenerated mock type for the MessageEncoder type

func NewMessageEncoder 

func NewMessageEncoder(t interface {
	mock.TestingT
	Cleanup(func())
}) *MessageEncoder

NewMessageEncoder creates a new instance of MessageEncoder. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*MessageEncoder) Decode 

func (_m *MessageEncoder) Decode(ctx context.Context, msg *stream.Message, out interface{}) (context.Context, map[string]string, error)

Decode provides a mock function with given fields: ctx, msg, out

func (*MessageEncoder) EXPECT 

func (_m *MessageEncoder) EXPECT() *MessageEncoder_Expecter

func (*MessageEncoder) Encode 

func (_m *MessageEncoder) Encode(ctx context.Context, data interface{}, attributeSets ...map[string]string) (*stream.Message, error)

Encode provides a mock function with given fields: ctx, data, attributeSets

type MessageEncoder_Decode_Call 

type MessageEncoder_Decode_Call struct {
	*mock.Call
}

MessageEncoder_Decode_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Decode'

func (*MessageEncoder_Decode_Call) Return 

func (_c *MessageEncoder_Decode_Call) Return(_a0 context.Context, _a1 map[string]string, _a2 error) *MessageEncoder_Decode_Call

func (*MessageEncoder_Decode_Call) Run 

func (_c *MessageEncoder_Decode_Call) Run(run func(ctx context.Context, msg *stream.Message, out interface{})) *MessageEncoder_Decode_Call

func (*MessageEncoder_Decode_Call) RunAndReturn 

func (_c *MessageEncoder_Decode_Call) RunAndReturn(run func(context.Context, *stream.Message, interface{}) (context.Context, map[string]string, error)) *MessageEncoder_Decode_Call

type MessageEncoder_Encode_Call 

type MessageEncoder_Encode_Call struct {
	*mock.Call
}

MessageEncoder_Encode_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Encode'

func (*MessageEncoder_Encode_Call) Return 

func (_c *MessageEncoder_Encode_Call) Return(_a0 *stream.Message, _a1 error) *MessageEncoder_Encode_Call

func (*MessageEncoder_Encode_Call) Run 

func (_c *MessageEncoder_Encode_Call) Run(run func(ctx context.Context, data interface{}, attributeSets ...map[string]string)) *MessageEncoder_Encode_Call

func (*MessageEncoder_Encode_Call) RunAndReturn 

func (_c *MessageEncoder_Encode_Call) RunAndReturn(run func(context.Context, interface{}, ...map[string]string) (*stream.Message, error)) *MessageEncoder_Encode_Call

type MessageEncoder_Expecter 

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

func (*MessageEncoder_Expecter) Decode 

func (_e *MessageEncoder_Expecter) Decode(ctx interface{}, msg interface{}, out interface{}) *MessageEncoder_Decode_Call

Decode is a helper method to define mock.On call

  • ctx context.Context
  • msg *stream.Message
  • out interface{}

func (*MessageEncoder_Expecter) Encode 

func (_e *MessageEncoder_Expecter) Encode(ctx interface{}, data interface{}, attributeSets ...interface{}) *MessageEncoder_Encode_Call

Encode is a helper method to define mock.On call

  • ctx context.Context
  • data interface{}
  • attributeSets ...map[string]string

type Output 

type Output struct {
	mock.Mock
}

Output is an autogenerated mock type for the Output type

func NewOutput 

func NewOutput(t interface {
	mock.TestingT
	Cleanup(func())
}) *Output

NewOutput creates a new instance of Output. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*Output) EXPECT 

func (_m *Output) EXPECT() *Output_Expecter

func (*Output) Write 

func (_m *Output) Write(ctx context.Context, batch []stream.WritableMessage) error

Write provides a mock function with given fields: ctx, batch

func (*Output) WriteOne 

func (_m *Output) WriteOne(ctx context.Context, msg stream.WritableMessage) error

WriteOne provides a mock function with given fields: ctx, msg

type Output_Expecter 

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

func (*Output_Expecter) Write 

func (_e *Output_Expecter) Write(ctx interface{}, batch interface{}) *Output_Write_Call

Write is a helper method to define mock.On call

  • ctx context.Context
  • batch []stream.WritableMessage

func (*Output_Expecter) WriteOne 

func (_e *Output_Expecter) WriteOne(ctx interface{}, msg interface{}) *Output_WriteOne_Call

WriteOne is a helper method to define mock.On call

  • ctx context.Context
  • msg stream.WritableMessage

type Output_WriteOne_Call 

type Output_WriteOne_Call struct {
	*mock.Call
}

Output_WriteOne_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'WriteOne'

func (*Output_WriteOne_Call) Return 

func (_c *Output_WriteOne_Call) Return(_a0 error) *Output_WriteOne_Call

func (*Output_WriteOne_Call) Run 

func (_c *Output_WriteOne_Call) Run(run func(ctx context.Context, msg stream.WritableMessage)) *Output_WriteOne_Call

func (*Output_WriteOne_Call) RunAndReturn 

func (_c *Output_WriteOne_Call) RunAndReturn(run func(context.Context, stream.WritableMessage) error) *Output_WriteOne_Call

type Output_Write_Call 

type Output_Write_Call struct {
	*mock.Call
}

Output_Write_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Write'

func (*Output_Write_Call) Return 

func (_c *Output_Write_Call) Return(_a0 error) *Output_Write_Call

func (*Output_Write_Call) Run 

func (_c *Output_Write_Call) Run(run func(ctx context.Context, batch []stream.WritableMessage)) *Output_Write_Call

func (*Output_Write_Call) RunAndReturn 

func (_c *Output_Write_Call) RunAndReturn(run func(context.Context, []stream.WritableMessage) error) *Output_Write_Call

type PartitionerRand 

type PartitionerRand struct {
	mock.Mock
}

PartitionerRand is an autogenerated mock type for the PartitionerRand type

func NewPartitionerRand 

func NewPartitionerRand(t interface {
	mock.TestingT
	Cleanup(func())
}) *PartitionerRand

NewPartitionerRand creates a new instance of PartitionerRand. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*PartitionerRand) EXPECT 

func (_m *PartitionerRand) EXPECT() *PartitionerRand_Expecter

func (*PartitionerRand) Intn 

func (_m *PartitionerRand) Intn(n int) int

Intn provides a mock function with given fields: n

type PartitionerRand_Expecter 

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

func (*PartitionerRand_Expecter) Intn 

func (_e *PartitionerRand_Expecter) Intn(n interface{}) *PartitionerRand_Intn_Call

Intn is a helper method to define mock.On call

  • n int

type PartitionerRand_Intn_Call 

type PartitionerRand_Intn_Call struct {
	*mock.Call
}

PartitionerRand_Intn_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Intn'

func (*PartitionerRand_Intn_Call) Return 

func (_c *PartitionerRand_Intn_Call) Return(_a0 int) *PartitionerRand_Intn_Call

func (*PartitionerRand_Intn_Call) Run 

func (_c *PartitionerRand_Intn_Call) Run(run func(n int)) *PartitionerRand_Intn_Call

func (*PartitionerRand_Intn_Call) RunAndReturn 

func (_c *PartitionerRand_Intn_Call) RunAndReturn(run func(int) int) *PartitionerRand_Intn_Call

type Producer 

type Producer struct {
	mock.Mock
}

Producer is an autogenerated mock type for the Producer type

func NewProducer 

func NewProducer(t interface {
	mock.TestingT
	Cleanup(func())
}) *Producer

NewProducer creates a new instance of Producer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*Producer) EXPECT 

func (_m *Producer) EXPECT() *Producer_Expecter

func (*Producer) Write 

func (_m *Producer) Write(ctx context.Context, models interface{}, attributeSets ...map[string]string) error

Write provides a mock function with given fields: ctx, models, attributeSets

func (*Producer) WriteOne 

func (_m *Producer) WriteOne(ctx context.Context, model interface{}, attributeSets ...map[string]string) error

WriteOne provides a mock function with given fields: ctx, model, attributeSets

type ProducerDaemonAggregator 

type ProducerDaemonAggregator struct {
	mock.Mock
}

ProducerDaemonAggregator is an autogenerated mock type for the ProducerDaemonAggregator type

func NewProducerDaemonAggregator 

func NewProducerDaemonAggregator(t interface {
	mock.TestingT
	Cleanup(func())
}) *ProducerDaemonAggregator

NewProducerDaemonAggregator creates a new instance of ProducerDaemonAggregator. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*ProducerDaemonAggregator) EXPECT 

func (_m *ProducerDaemonAggregator) EXPECT() *ProducerDaemonAggregator_Expecter

func (*ProducerDaemonAggregator) Flush 

func (_m *ProducerDaemonAggregator) Flush() ([]stream.AggregateFlush, error)

Flush provides a mock function with no fields

func (*ProducerDaemonAggregator) Write 

func (_m *ProducerDaemonAggregator) Write(ctx context.Context, msg *stream.Message) ([]stream.AggregateFlush, error)

Write provides a mock function with given fields: ctx, msg

type ProducerDaemonAggregator_Expecter 

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

func (*ProducerDaemonAggregator_Expecter) Flush 

func (_e *ProducerDaemonAggregator_Expecter) Flush() *ProducerDaemonAggregator_Flush_Call

Flush is a helper method to define mock.On call

func (*ProducerDaemonAggregator_Expecter) Write 

func (_e *ProducerDaemonAggregator_Expecter) Write(ctx interface{}, msg interface{}) *ProducerDaemonAggregator_Write_Call

Write is a helper method to define mock.On call

  • ctx context.Context
  • msg *stream.Message

type ProducerDaemonAggregator_Flush_Call 

type ProducerDaemonAggregator_Flush_Call struct {
	*mock.Call
}

ProducerDaemonAggregator_Flush_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Flush'

func (*ProducerDaemonAggregator_Flush_Call) Return 

func (_c *ProducerDaemonAggregator_Flush_Call) Return(_a0 []stream.AggregateFlush, _a1 error) *ProducerDaemonAggregator_Flush_Call

func (*ProducerDaemonAggregator_Flush_Call) Run 

func (_c *ProducerDaemonAggregator_Flush_Call) Run(run func()) *ProducerDaemonAggregator_Flush_Call

func (*ProducerDaemonAggregator_Flush_Call) RunAndReturn 

func (_c *ProducerDaemonAggregator_Flush_Call) RunAndReturn(run func() ([]stream.AggregateFlush, error)) *ProducerDaemonAggregator_Flush_Call

type ProducerDaemonAggregator_Write_Call 

type ProducerDaemonAggregator_Write_Call struct {
	*mock.Call
}

ProducerDaemonAggregator_Write_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Write'

func (*ProducerDaemonAggregator_Write_Call) Return 

func (_c *ProducerDaemonAggregator_Write_Call) Return(_a0 []stream.AggregateFlush, _a1 error) *ProducerDaemonAggregator_Write_Call

func (*ProducerDaemonAggregator_Write_Call) Run 

func (_c *ProducerDaemonAggregator_Write_Call) Run(run func(ctx context.Context, msg *stream.Message)) *ProducerDaemonAggregator_Write_Call

func (*ProducerDaemonAggregator_Write_Call) RunAndReturn 

func (_c *ProducerDaemonAggregator_Write_Call) RunAndReturn(run func(context.Context, *stream.Message) ([]stream.AggregateFlush, error)) *ProducerDaemonAggregator_Write_Call

type ProducerDaemonBatcher 

type ProducerDaemonBatcher struct {
	mock.Mock
}

ProducerDaemonBatcher is an autogenerated mock type for the ProducerDaemonBatcher type

func NewProducerDaemonBatcher 

func NewProducerDaemonBatcher(t interface {
	mock.TestingT
	Cleanup(func())
}) *ProducerDaemonBatcher

NewProducerDaemonBatcher creates a new instance of ProducerDaemonBatcher. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*ProducerDaemonBatcher) Append 

func (_m *ProducerDaemonBatcher) Append(msg *stream.Message) ([]stream.WritableMessage, error)

Append provides a mock function with given fields: msg

func (*ProducerDaemonBatcher) EXPECT 

func (_m *ProducerDaemonBatcher) EXPECT() *ProducerDaemonBatcher_Expecter

func (*ProducerDaemonBatcher) Flush 

func (_m *ProducerDaemonBatcher) Flush() []stream.WritableMessage

Flush provides a mock function with no fields

type ProducerDaemonBatcher_Append_Call 

type ProducerDaemonBatcher_Append_Call struct {
	*mock.Call
}

ProducerDaemonBatcher_Append_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Append'

func (*ProducerDaemonBatcher_Append_Call) Return 

func (_c *ProducerDaemonBatcher_Append_Call) Return(_a0 []stream.WritableMessage, _a1 error) *ProducerDaemonBatcher_Append_Call

func (*ProducerDaemonBatcher_Append_Call) Run 

func (_c *ProducerDaemonBatcher_Append_Call) Run(run func(msg *stream.Message)) *ProducerDaemonBatcher_Append_Call

func (*ProducerDaemonBatcher_Append_Call) RunAndReturn 

func (_c *ProducerDaemonBatcher_Append_Call) RunAndReturn(run func(*stream.Message) ([]stream.WritableMessage, error)) *ProducerDaemonBatcher_Append_Call

type ProducerDaemonBatcher_Expecter 

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

func (*ProducerDaemonBatcher_Expecter) Append 

func (_e *ProducerDaemonBatcher_Expecter) Append(msg interface{}) *ProducerDaemonBatcher_Append_Call

Append is a helper method to define mock.On call

  • msg *stream.Message

func (*ProducerDaemonBatcher_Expecter) Flush 

func (_e *ProducerDaemonBatcher_Expecter) Flush() *ProducerDaemonBatcher_Flush_Call

Flush is a helper method to define mock.On call

type ProducerDaemonBatcher_Flush_Call 

type ProducerDaemonBatcher_Flush_Call struct {
	*mock.Call
}

ProducerDaemonBatcher_Flush_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Flush'

func (*ProducerDaemonBatcher_Flush_Call) Return 

func (_c *ProducerDaemonBatcher_Flush_Call) Return(_a0 []stream.WritableMessage) *ProducerDaemonBatcher_Flush_Call

func (*ProducerDaemonBatcher_Flush_Call) Run 

func (_c *ProducerDaemonBatcher_Flush_Call) Run(run func()) *ProducerDaemonBatcher_Flush_Call

func (*ProducerDaemonBatcher_Flush_Call) RunAndReturn 

func (_c *ProducerDaemonBatcher_Flush_Call) RunAndReturn(run func() []stream.WritableMessage) *ProducerDaemonBatcher_Flush_Call

type Producer_Expecter 

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

func (*Producer_Expecter) Write 

func (_e *Producer_Expecter) Write(ctx interface{}, models interface{}, attributeSets ...interface{}) *Producer_Write_Call

Write is a helper method to define mock.On call

  • ctx context.Context
  • models interface{}
  • attributeSets ...map[string]string

func (*Producer_Expecter) WriteOne 

func (_e *Producer_Expecter) WriteOne(ctx interface{}, model interface{}, attributeSets ...interface{}) *Producer_WriteOne_Call

WriteOne is a helper method to define mock.On call

  • ctx context.Context
  • model interface{}
  • attributeSets ...map[string]string

type Producer_WriteOne_Call 

type Producer_WriteOne_Call struct {
	*mock.Call
}

Producer_WriteOne_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'WriteOne'

func (*Producer_WriteOne_Call) Return 

func (_c *Producer_WriteOne_Call) Return(_a0 error) *Producer_WriteOne_Call

func (*Producer_WriteOne_Call) Run 

func (_c *Producer_WriteOne_Call) Run(run func(ctx context.Context, model interface{}, attributeSets ...map[string]string)) *Producer_WriteOne_Call

func (*Producer_WriteOne_Call) RunAndReturn 

func (_c *Producer_WriteOne_Call) RunAndReturn(run func(context.Context, interface{}, ...map[string]string) error) *Producer_WriteOne_Call

type Producer_Write_Call 

type Producer_Write_Call struct {
	*mock.Call
}

Producer_Write_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Write'

func (*Producer_Write_Call) Return 

func (_c *Producer_Write_Call) Return(_a0 error) *Producer_Write_Call

func (*Producer_Write_Call) Run 

func (_c *Producer_Write_Call) Run(run func(ctx context.Context, models interface{}, attributeSets ...map[string]string)) *Producer_Write_Call

func (*Producer_Write_Call) RunAndReturn 

func (_c *Producer_Write_Call) RunAndReturn(run func(context.Context, interface{}, ...map[string]string) error) *Producer_Write_Call

type RetryHandler 

type RetryHandler struct {
	mock.Mock
}

RetryHandler is an autogenerated mock type for the RetryHandler type

func NewRetryHandler 

func NewRetryHandler(t interface {
	mock.TestingT
	Cleanup(func())
}) *RetryHandler

NewRetryHandler creates a new instance of RetryHandler. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*RetryHandler) EXPECT 

func (_m *RetryHandler) EXPECT() *RetryHandler_Expecter

func (*RetryHandler) Put 

func (_m *RetryHandler) Put(ctx context.Context, msg *stream.Message) error

Put provides a mock function with given fields: ctx, msg

type RetryHandler_Expecter 

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

func (*RetryHandler_Expecter) Put 

func (_e *RetryHandler_Expecter) Put(ctx interface{}, msg interface{}) *RetryHandler_Put_Call

Put is a helper method to define mock.On call

  • ctx context.Context
  • msg *stream.Message

type RetryHandler_Put_Call 

type RetryHandler_Put_Call struct {
	*mock.Call
}

RetryHandler_Put_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Put'

func (*RetryHandler_Put_Call) Return 

func (_c *RetryHandler_Put_Call) Return(_a0 error) *RetryHandler_Put_Call

func (*RetryHandler_Put_Call) Run 

func (_c *RetryHandler_Put_Call) Run(run func(ctx context.Context, msg *stream.Message)) *RetryHandler_Put_Call

func (*RetryHandler_Put_Call) RunAndReturn 

func (_c *RetryHandler_Put_Call) RunAndReturn(run func(context.Context, *stream.Message) error) *RetryHandler_Put_Call

type RunnableBatchConsumerCallback 

type RunnableBatchConsumerCallback[M interface{}] struct {
	mock.Mock
}

RunnableBatchConsumerCallback is an autogenerated mock type for the RunnableBatchConsumerCallback type

func NewRunnableBatchConsumerCallback 

func NewRunnableBatchConsumerCallback[M interface{}](t interface {
	mock.TestingT
	Cleanup(func())
}) *RunnableBatchConsumerCallback[M]

NewRunnableBatchConsumerCallback creates a new instance of RunnableBatchConsumerCallback. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*RunnableBatchConsumerCallback[M]) Consume 

func (_m *RunnableBatchConsumerCallback[M]) Consume(ctx context.Context, models []M, attributes []map[string]string) ([]bool, error)

Consume provides a mock function with given fields: ctx, models, attributes

func (*RunnableBatchConsumerCallback[M]) EXPECT 

func (_m *RunnableBatchConsumerCallback[M]) EXPECT() *RunnableBatchConsumerCallback_Expecter[M]

func (*RunnableBatchConsumerCallback[M]) Run 

func (_m *RunnableBatchConsumerCallback[M]) Run(ctx context.Context) error

Run provides a mock function with given fields: ctx

type RunnableBatchConsumerCallback_Consume_Call 

type RunnableBatchConsumerCallback_Consume_Call[M interface{}] struct {
	*mock.Call
}

RunnableBatchConsumerCallback_Consume_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Consume'

func (*RunnableBatchConsumerCallback_Consume_Call[M]) Return 

func (_c *RunnableBatchConsumerCallback_Consume_Call[M]) Return(_a0 []bool, _a1 error) *RunnableBatchConsumerCallback_Consume_Call[M]

func (*RunnableBatchConsumerCallback_Consume_Call[M]) Run 

func (_c *RunnableBatchConsumerCallback_Consume_Call[M]) Run(run func(ctx context.Context, models []M, attributes []map[string]string)) *RunnableBatchConsumerCallback_Consume_Call[M]

func (*RunnableBatchConsumerCallback_Consume_Call[M]) RunAndReturn 

func (_c *RunnableBatchConsumerCallback_Consume_Call[M]) RunAndReturn(run func(context.Context, []M, []map[string]string) ([]bool, error)) *RunnableBatchConsumerCallback_Consume_Call[M]

type RunnableBatchConsumerCallback_Expecter 

type RunnableBatchConsumerCallback_Expecter[M interface{}] struct {
	// contains filtered or unexported fields
}

func (*RunnableBatchConsumerCallback_Expecter[M]) Consume 

func (_e *RunnableBatchConsumerCallback_Expecter[M]) Consume(ctx interface{}, models interface{}, attributes interface{}) *RunnableBatchConsumerCallback_Consume_Call[M]

Consume is a helper method to define mock.On call

  • ctx context.Context
  • models []M
  • attributes []map[string]string

func (*RunnableBatchConsumerCallback_Expecter[M]) Run 

func (_e *RunnableBatchConsumerCallback_Expecter[M]) Run(ctx interface{}) *RunnableBatchConsumerCallback_Run_Call[M]

Run is a helper method to define mock.On call

  • ctx context.Context

type RunnableBatchConsumerCallback_Run_Call 

type RunnableBatchConsumerCallback_Run_Call[M interface{}] struct {
	*mock.Call
}

RunnableBatchConsumerCallback_Run_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Run'

func (*RunnableBatchConsumerCallback_Run_Call[M]) Return 

func (_c *RunnableBatchConsumerCallback_Run_Call[M]) Return(_a0 error) *RunnableBatchConsumerCallback_Run_Call[M]

func (*RunnableBatchConsumerCallback_Run_Call[M]) Run 

func (_c *RunnableBatchConsumerCallback_Run_Call[M]) Run(run func(ctx context.Context)) *RunnableBatchConsumerCallback_Run_Call[M]

func (*RunnableBatchConsumerCallback_Run_Call[M]) RunAndReturn 

func (_c *RunnableBatchConsumerCallback_Run_Call[M]) RunAndReturn(run func(context.Context) error) *RunnableBatchConsumerCallback_Run_Call[M]

type RunnableCallback 

type RunnableCallback struct {
	mock.Mock
}

RunnableCallback is an autogenerated mock type for the RunnableCallback type

func NewRunnableCallback 

func NewRunnableCallback(t interface {
	mock.TestingT
	Cleanup(func())
}) *RunnableCallback

NewRunnableCallback creates a new instance of RunnableCallback. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*RunnableCallback) EXPECT 

func (_m *RunnableCallback) EXPECT() *RunnableCallback_Expecter

func (*RunnableCallback) Run 

func (_m *RunnableCallback) Run(ctx context.Context) error

Run provides a mock function with given fields: ctx

type RunnableCallback_Expecter 

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

func (*RunnableCallback_Expecter) Run 

func (_e *RunnableCallback_Expecter) Run(ctx interface{}) *RunnableCallback_Run_Call

Run is a helper method to define mock.On call

  • ctx context.Context

type RunnableCallback_Run_Call 

type RunnableCallback_Run_Call struct {
	*mock.Call
}

RunnableCallback_Run_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Run'

func (*RunnableCallback_Run_Call) Return 

func (_c *RunnableCallback_Run_Call) Return(_a0 error) *RunnableCallback_Run_Call

func (*RunnableCallback_Run_Call) Run 

func (_c *RunnableCallback_Run_Call) Run(run func(ctx context.Context)) *RunnableCallback_Run_Call

func (*RunnableCallback_Run_Call) RunAndReturn 

func (_c *RunnableCallback_Run_Call) RunAndReturn(run func(context.Context) error) *RunnableCallback_Run_Call

type RunnableConsumerCallback 

type RunnableConsumerCallback[M interface{}] struct {
	mock.Mock
}

RunnableConsumerCallback is an autogenerated mock type for the RunnableConsumerCallback type

func NewRunnableConsumerCallback 

func NewRunnableConsumerCallback[M interface{}](t interface {
	mock.TestingT
	Cleanup(func())
}) *RunnableConsumerCallback[M]

NewRunnableConsumerCallback creates a new instance of RunnableConsumerCallback. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*RunnableConsumerCallback[M]) Consume 

func (_m *RunnableConsumerCallback[M]) Consume(ctx context.Context, model M, attributes map[string]string) (bool, error)

Consume provides a mock function with given fields: ctx, model, attributes

func (*RunnableConsumerCallback[M]) EXPECT 

func (_m *RunnableConsumerCallback[M]) EXPECT() *RunnableConsumerCallback_Expecter[M]

func (*RunnableConsumerCallback[M]) Run 

func (_m *RunnableConsumerCallback[M]) Run(ctx context.Context) error

Run provides a mock function with given fields: ctx

type RunnableConsumerCallback_Consume_Call 

type RunnableConsumerCallback_Consume_Call[M interface{}] struct {
	*mock.Call
}

RunnableConsumerCallback_Consume_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Consume'

func (*RunnableConsumerCallback_Consume_Call[M]) Return 

func (_c *RunnableConsumerCallback_Consume_Call[M]) Return(_a0 bool, _a1 error) *RunnableConsumerCallback_Consume_Call[M]

func (*RunnableConsumerCallback_Consume_Call[M]) Run 

func (_c *RunnableConsumerCallback_Consume_Call[M]) Run(run func(ctx context.Context, model M, attributes map[string]string)) *RunnableConsumerCallback_Consume_Call[M]

func (*RunnableConsumerCallback_Consume_Call[M]) RunAndReturn 

func (_c *RunnableConsumerCallback_Consume_Call[M]) RunAndReturn(run func(context.Context, M, map[string]string) (bool, error)) *RunnableConsumerCallback_Consume_Call[M]

type RunnableConsumerCallback_Expecter 

type RunnableConsumerCallback_Expecter[M interface{}] struct {
	// contains filtered or unexported fields
}

func (*RunnableConsumerCallback_Expecter[M]) Consume 

func (_e *RunnableConsumerCallback_Expecter[M]) Consume(ctx interface{}, model interface{}, attributes interface{}) *RunnableConsumerCallback_Consume_Call[M]

Consume is a helper method to define mock.On call

  • ctx context.Context
  • model M
  • attributes map[string]string

func (*RunnableConsumerCallback_Expecter[M]) Run 

func (_e *RunnableConsumerCallback_Expecter[M]) Run(ctx interface{}) *RunnableConsumerCallback_Run_Call[M]

Run is a helper method to define mock.On call

  • ctx context.Context

type RunnableConsumerCallback_Run_Call 

type RunnableConsumerCallback_Run_Call[M interface{}] struct {
	*mock.Call
}

RunnableConsumerCallback_Run_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Run'

func (*RunnableConsumerCallback_Run_Call[M]) Return 

func (_c *RunnableConsumerCallback_Run_Call[M]) Return(_a0 error) *RunnableConsumerCallback_Run_Call[M]

func (*RunnableConsumerCallback_Run_Call[M]) Run 

func (_c *RunnableConsumerCallback_Run_Call[M]) Run(run func(ctx context.Context)) *RunnableConsumerCallback_Run_Call[M]

func (*RunnableConsumerCallback_Run_Call[M]) RunAndReturn 

func (_c *RunnableConsumerCallback_Run_Call[M]) RunAndReturn(run func(context.Context) error) *RunnableConsumerCallback_Run_Call[M]

type RunnableUntypedBatchConsumerCallback added in v0.41.0 

type RunnableUntypedBatchConsumerCallback struct {
	mock.Mock
}

RunnableUntypedBatchConsumerCallback is an autogenerated mock type for the RunnableUntypedBatchConsumerCallback type

func NewRunnableUntypedBatchConsumerCallback added in v0.41.0 

func NewRunnableUntypedBatchConsumerCallback(t interface {
	mock.TestingT
	Cleanup(func())
}) *RunnableUntypedBatchConsumerCallback

NewRunnableUntypedBatchConsumerCallback creates a new instance of RunnableUntypedBatchConsumerCallback. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*RunnableUntypedBatchConsumerCallback) Consume added in v0.41.0 

func (_m *RunnableUntypedBatchConsumerCallback) Consume(ctx context.Context, models []interface{}, attributes []map[string]string) ([]bool, error)

Consume provides a mock function with given fields: ctx, models, attributes

func (*RunnableUntypedBatchConsumerCallback) EXPECT added in v0.41.0 

func (_m *RunnableUntypedBatchConsumerCallback) EXPECT() *RunnableUntypedBatchConsumerCallback_Expecter

func (*RunnableUntypedBatchConsumerCallback) GetModel added in v0.41.0 

func (_m *RunnableUntypedBatchConsumerCallback) GetModel(attributes map[string]string) (interface{}, error)

GetModel provides a mock function with given fields: attributes

func (*RunnableUntypedBatchConsumerCallback) Run added in v0.41.0 

func (_m *RunnableUntypedBatchConsumerCallback) Run(ctx context.Context) error

Run provides a mock function with given fields: ctx

type RunnableUntypedBatchConsumerCallback_Consume_Call added in v0.41.0 

type RunnableUntypedBatchConsumerCallback_Consume_Call struct {
	*mock.Call
}

RunnableUntypedBatchConsumerCallback_Consume_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Consume'

func (*RunnableUntypedBatchConsumerCallback_Consume_Call) Return added in v0.41.0 

func (_c *RunnableUntypedBatchConsumerCallback_Consume_Call) Return(_a0 []bool, _a1 error) *RunnableUntypedBatchConsumerCallback_Consume_Call

func (*RunnableUntypedBatchConsumerCallback_Consume_Call) Run added in v0.41.0 

func (_c *RunnableUntypedBatchConsumerCallback_Consume_Call) Run(run func(ctx context.Context, models []interface{}, attributes []map[string]string)) *RunnableUntypedBatchConsumerCallback_Consume_Call

func (*RunnableUntypedBatchConsumerCallback_Consume_Call) RunAndReturn added in v0.41.0 

func (_c *RunnableUntypedBatchConsumerCallback_Consume_Call) RunAndReturn(run func(context.Context, []interface{}, []map[string]string) ([]bool, error)) *RunnableUntypedBatchConsumerCallback_Consume_Call

type RunnableUntypedBatchConsumerCallback_Expecter added in v0.41.0 

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

func (*RunnableUntypedBatchConsumerCallback_Expecter) Consume added in v0.41.0 

func (_e *RunnableUntypedBatchConsumerCallback_Expecter) Consume(ctx interface{}, models interface{}, attributes interface{}) *RunnableUntypedBatchConsumerCallback_Consume_Call

Consume is a helper method to define mock.On call

  • ctx context.Context
  • models []interface{}
  • attributes []map[string]string

func (*RunnableUntypedBatchConsumerCallback_Expecter) GetModel added in v0.41.0 

func (_e *RunnableUntypedBatchConsumerCallback_Expecter) GetModel(attributes interface{}) *RunnableUntypedBatchConsumerCallback_GetModel_Call

GetModel is a helper method to define mock.On call

  • attributes map[string]string

func (*RunnableUntypedBatchConsumerCallback_Expecter) Run added in v0.41.0 

func (_e *RunnableUntypedBatchConsumerCallback_Expecter) Run(ctx interface{}) *RunnableUntypedBatchConsumerCallback_Run_Call

Run is a helper method to define mock.On call

  • ctx context.Context

type RunnableUntypedBatchConsumerCallback_GetModel_Call added in v0.41.0 

type RunnableUntypedBatchConsumerCallback_GetModel_Call struct {
	*mock.Call
}

RunnableUntypedBatchConsumerCallback_GetModel_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetModel'

func (*RunnableUntypedBatchConsumerCallback_GetModel_Call) Return added in v0.41.0 

func (_c *RunnableUntypedBatchConsumerCallback_GetModel_Call) Return(_a0 interface{}, _a1 error) *RunnableUntypedBatchConsumerCallback_GetModel_Call

func (*RunnableUntypedBatchConsumerCallback_GetModel_Call) Run added in v0.41.0 

func (_c *RunnableUntypedBatchConsumerCallback_GetModel_Call) Run(run func(attributes map[string]string)) *RunnableUntypedBatchConsumerCallback_GetModel_Call

func (*RunnableUntypedBatchConsumerCallback_GetModel_Call) RunAndReturn added in v0.41.0 

func (_c *RunnableUntypedBatchConsumerCallback_GetModel_Call) RunAndReturn(run func(map[string]string) (interface{}, error)) *RunnableUntypedBatchConsumerCallback_GetModel_Call

type RunnableUntypedBatchConsumerCallback_Run_Call added in v0.41.0 

type RunnableUntypedBatchConsumerCallback_Run_Call struct {
	*mock.Call
}

RunnableUntypedBatchConsumerCallback_Run_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Run'

func (*RunnableUntypedBatchConsumerCallback_Run_Call) Return added in v0.41.0 

func (_c *RunnableUntypedBatchConsumerCallback_Run_Call) Return(_a0 error) *RunnableUntypedBatchConsumerCallback_Run_Call

func (*RunnableUntypedBatchConsumerCallback_Run_Call) Run added in v0.41.0 

func (_c *RunnableUntypedBatchConsumerCallback_Run_Call) Run(run func(ctx context.Context)) *RunnableUntypedBatchConsumerCallback_Run_Call

func (*RunnableUntypedBatchConsumerCallback_Run_Call) RunAndReturn added in v0.41.0 

func (_c *RunnableUntypedBatchConsumerCallback_Run_Call) RunAndReturn(run func(context.Context) error) *RunnableUntypedBatchConsumerCallback_Run_Call

type RunnableUntypedConsumerCallback added in v0.41.0 

type RunnableUntypedConsumerCallback struct {
	mock.Mock
}

RunnableUntypedConsumerCallback is an autogenerated mock type for the RunnableUntypedConsumerCallback type

func NewRunnableUntypedConsumerCallback added in v0.41.0 

func NewRunnableUntypedConsumerCallback(t interface {
	mock.TestingT
	Cleanup(func())
}) *RunnableUntypedConsumerCallback

NewRunnableUntypedConsumerCallback creates a new instance of RunnableUntypedConsumerCallback. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*RunnableUntypedConsumerCallback) Consume added in v0.41.0 

func (_m *RunnableUntypedConsumerCallback) Consume(ctx context.Context, model interface{}, attributes map[string]string) (bool, error)

Consume provides a mock function with given fields: ctx, model, attributes

func (*RunnableUntypedConsumerCallback) EXPECT added in v0.41.0 

func (_m *RunnableUntypedConsumerCallback) EXPECT() *RunnableUntypedConsumerCallback_Expecter

func (*RunnableUntypedConsumerCallback) GetModel added in v0.41.0 

func (_m *RunnableUntypedConsumerCallback) GetModel(attributes map[string]string) (interface{}, error)

GetModel provides a mock function with given fields: attributes

func (*RunnableUntypedConsumerCallback) Run added in v0.41.0 

func (_m *RunnableUntypedConsumerCallback) Run(ctx context.Context) error

Run provides a mock function with given fields: ctx

type RunnableUntypedConsumerCallback_Consume_Call added in v0.41.0 

type RunnableUntypedConsumerCallback_Consume_Call struct {
	*mock.Call
}

RunnableUntypedConsumerCallback_Consume_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Consume'

func (*RunnableUntypedConsumerCallback_Consume_Call) Return added in v0.41.0 

func (_c *RunnableUntypedConsumerCallback_Consume_Call) Return(_a0 bool, _a1 error) *RunnableUntypedConsumerCallback_Consume_Call

func (*RunnableUntypedConsumerCallback_Consume_Call) Run added in v0.41.0 

func (_c *RunnableUntypedConsumerCallback_Consume_Call) Run(run func(ctx context.Context, model interface{}, attributes map[string]string)) *RunnableUntypedConsumerCallback_Consume_Call

func (*RunnableUntypedConsumerCallback_Consume_Call) RunAndReturn added in v0.41.0 

func (_c *RunnableUntypedConsumerCallback_Consume_Call) RunAndReturn(run func(context.Context, interface{}, map[string]string) (bool, error)) *RunnableUntypedConsumerCallback_Consume_Call

type RunnableUntypedConsumerCallback_Expecter added in v0.41.0 

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

func (*RunnableUntypedConsumerCallback_Expecter) Consume added in v0.41.0 

func (_e *RunnableUntypedConsumerCallback_Expecter) Consume(ctx interface{}, model interface{}, attributes interface{}) *RunnableUntypedConsumerCallback_Consume_Call

Consume is a helper method to define mock.On call

  • ctx context.Context
  • model interface{}
  • attributes map[string]string

func (*RunnableUntypedConsumerCallback_Expecter) GetModel added in v0.41.0 

func (_e *RunnableUntypedConsumerCallback_Expecter) GetModel(attributes interface{}) *RunnableUntypedConsumerCallback_GetModel_Call

GetModel is a helper method to define mock.On call

  • attributes map[string]string

func (*RunnableUntypedConsumerCallback_Expecter) Run added in v0.41.0 

func (_e *RunnableUntypedConsumerCallback_Expecter) Run(ctx interface{}) *RunnableUntypedConsumerCallback_Run_Call

Run is a helper method to define mock.On call

  • ctx context.Context

type RunnableUntypedConsumerCallback_GetModel_Call added in v0.41.0 

type RunnableUntypedConsumerCallback_GetModel_Call struct {
	*mock.Call
}

RunnableUntypedConsumerCallback_GetModel_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetModel'

func (*RunnableUntypedConsumerCallback_GetModel_Call) Return added in v0.41.0 

func (_c *RunnableUntypedConsumerCallback_GetModel_Call) Return(_a0 interface{}, _a1 error) *RunnableUntypedConsumerCallback_GetModel_Call

func (*RunnableUntypedConsumerCallback_GetModel_Call) Run added in v0.41.0 

func (_c *RunnableUntypedConsumerCallback_GetModel_Call) Run(run func(attributes map[string]string)) *RunnableUntypedConsumerCallback_GetModel_Call

func (*RunnableUntypedConsumerCallback_GetModel_Call) RunAndReturn added in v0.41.0 

func (_c *RunnableUntypedConsumerCallback_GetModel_Call) RunAndReturn(run func(map[string]string) (interface{}, error)) *RunnableUntypedConsumerCallback_GetModel_Call

type RunnableUntypedConsumerCallback_Run_Call added in v0.41.0 

type RunnableUntypedConsumerCallback_Run_Call struct {
	*mock.Call
}

RunnableUntypedConsumerCallback_Run_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Run'

func (*RunnableUntypedConsumerCallback_Run_Call) Return added in v0.41.0 

func (_c *RunnableUntypedConsumerCallback_Run_Call) Return(_a0 error) *RunnableUntypedConsumerCallback_Run_Call

func (*RunnableUntypedConsumerCallback_Run_Call) Run added in v0.41.0 

func (_c *RunnableUntypedConsumerCallback_Run_Call) Run(run func(ctx context.Context)) *RunnableUntypedConsumerCallback_Run_Call

func (*RunnableUntypedConsumerCallback_Run_Call) RunAndReturn added in v0.41.0 

func (_c *RunnableUntypedConsumerCallback_Run_Call) RunAndReturn(run func(context.Context) error) *RunnableUntypedConsumerCallback_Run_Call

type SchemaRegistryAwareInput added in v0.51.0 

type SchemaRegistryAwareInput struct {
	mock.Mock
}

SchemaRegistryAwareInput is an autogenerated mock type for the SchemaRegistryAwareInput type

func NewSchemaRegistryAwareInput added in v0.51.0 

func NewSchemaRegistryAwareInput(t interface {
	mock.TestingT
	Cleanup(func())
}) *SchemaRegistryAwareInput

NewSchemaRegistryAwareInput creates a new instance of SchemaRegistryAwareInput. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*SchemaRegistryAwareInput) Data added in v0.51.0 

func (_m *SchemaRegistryAwareInput) Data() <-chan *stream.Message

Data provides a mock function with no fields

func (*SchemaRegistryAwareInput) EXPECT added in v0.51.0 

func (_m *SchemaRegistryAwareInput) EXPECT() *SchemaRegistryAwareInput_Expecter

func (*SchemaRegistryAwareInput) InitSchemaRegistry added in v0.51.0 

func (_m *SchemaRegistryAwareInput) InitSchemaRegistry(ctx context.Context, settings stream.SchemaSettingsWithEncoding) (stream.MessageBodyEncoder, error)

InitSchemaRegistry provides a mock function with given fields: ctx, settings

func (*SchemaRegistryAwareInput) IsHealthy added in v0.51.0 

func (_m *SchemaRegistryAwareInput) IsHealthy() bool

IsHealthy provides a mock function with no fields

func (*SchemaRegistryAwareInput) Run added in v0.51.0 

func (_m *SchemaRegistryAwareInput) Run(ctx context.Context) error

Run provides a mock function with given fields: ctx

func (*SchemaRegistryAwareInput) Stop added in v0.51.0 

func (_m *SchemaRegistryAwareInput) Stop(ctx context.Context)

Stop provides a mock function with given fields: ctx

type SchemaRegistryAwareInput_Data_Call added in v0.51.0 

type SchemaRegistryAwareInput_Data_Call struct {
	*mock.Call
}

SchemaRegistryAwareInput_Data_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Data'

func (*SchemaRegistryAwareInput_Data_Call) Return added in v0.51.0 

func (_c *SchemaRegistryAwareInput_Data_Call) Return(_a0 <-chan *stream.Message) *SchemaRegistryAwareInput_Data_Call

func (*SchemaRegistryAwareInput_Data_Call) Run added in v0.51.0 

func (_c *SchemaRegistryAwareInput_Data_Call) Run(run func()) *SchemaRegistryAwareInput_Data_Call

func (*SchemaRegistryAwareInput_Data_Call) RunAndReturn added in v0.51.0 

func (_c *SchemaRegistryAwareInput_Data_Call) RunAndReturn(run func() <-chan *stream.Message) *SchemaRegistryAwareInput_Data_Call

type SchemaRegistryAwareInput_Expecter added in v0.51.0 

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

func (*SchemaRegistryAwareInput_Expecter) Data added in v0.51.0 

func (_e *SchemaRegistryAwareInput_Expecter) Data() *SchemaRegistryAwareInput_Data_Call

Data is a helper method to define mock.On call

func (*SchemaRegistryAwareInput_Expecter) InitSchemaRegistry added in v0.51.0 

func (_e *SchemaRegistryAwareInput_Expecter) InitSchemaRegistry(ctx interface{}, settings interface{}) *SchemaRegistryAwareInput_InitSchemaRegistry_Call

InitSchemaRegistry is a helper method to define mock.On call

  • ctx context.Context
  • settings stream.SchemaSettingsWithEncoding

func (*SchemaRegistryAwareInput_Expecter) IsHealthy added in v0.51.0 

func (_e *SchemaRegistryAwareInput_Expecter) IsHealthy() *SchemaRegistryAwareInput_IsHealthy_Call

IsHealthy is a helper method to define mock.On call

func (*SchemaRegistryAwareInput_Expecter) Run added in v0.51.0 

func (_e *SchemaRegistryAwareInput_Expecter) Run(ctx interface{}) *SchemaRegistryAwareInput_Run_Call

Run is a helper method to define mock.On call

  • ctx context.Context

func (*SchemaRegistryAwareInput_Expecter) Stop added in v0.51.0 

func (_e *SchemaRegistryAwareInput_Expecter) Stop(ctx interface{}) *SchemaRegistryAwareInput_Stop_Call

Stop is a helper method to define mock.On call

  • ctx context.Context

type SchemaRegistryAwareInput_InitSchemaRegistry_Call added in v0.51.0 

type SchemaRegistryAwareInput_InitSchemaRegistry_Call struct {
	*mock.Call
}

SchemaRegistryAwareInput_InitSchemaRegistry_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'InitSchemaRegistry'

func (*SchemaRegistryAwareInput_InitSchemaRegistry_Call) Return added in v0.51.0 

func (_c *SchemaRegistryAwareInput_InitSchemaRegistry_Call) Return(_a0 stream.MessageBodyEncoder, _a1 error) *SchemaRegistryAwareInput_InitSchemaRegistry_Call

func (*SchemaRegistryAwareInput_InitSchemaRegistry_Call) Run added in v0.51.0 

func (_c *SchemaRegistryAwareInput_InitSchemaRegistry_Call) Run(run func(ctx context.Context, settings stream.SchemaSettingsWithEncoding)) *SchemaRegistryAwareInput_InitSchemaRegistry_Call

func (*SchemaRegistryAwareInput_InitSchemaRegistry_Call) RunAndReturn added in v0.51.0 

func (_c *SchemaRegistryAwareInput_InitSchemaRegistry_Call) RunAndReturn(run func(context.Context, stream.SchemaSettingsWithEncoding) (stream.MessageBodyEncoder, error)) *SchemaRegistryAwareInput_InitSchemaRegistry_Call

type SchemaRegistryAwareInput_IsHealthy_Call added in v0.51.0 

type SchemaRegistryAwareInput_IsHealthy_Call struct {
	*mock.Call
}

SchemaRegistryAwareInput_IsHealthy_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'IsHealthy'

func (*SchemaRegistryAwareInput_IsHealthy_Call) Return added in v0.51.0 

func (_c *SchemaRegistryAwareInput_IsHealthy_Call) Return(_a0 bool) *SchemaRegistryAwareInput_IsHealthy_Call

func (*SchemaRegistryAwareInput_IsHealthy_Call) Run added in v0.51.0 

func (_c *SchemaRegistryAwareInput_IsHealthy_Call) Run(run func()) *SchemaRegistryAwareInput_IsHealthy_Call

func (*SchemaRegistryAwareInput_IsHealthy_Call) RunAndReturn added in v0.51.0 

func (_c *SchemaRegistryAwareInput_IsHealthy_Call) RunAndReturn(run func() bool) *SchemaRegistryAwareInput_IsHealthy_Call

type SchemaRegistryAwareInput_Run_Call added in v0.51.0 

type SchemaRegistryAwareInput_Run_Call struct {
	*mock.Call
}

SchemaRegistryAwareInput_Run_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Run'

func (*SchemaRegistryAwareInput_Run_Call) Return added in v0.51.0 

func (_c *SchemaRegistryAwareInput_Run_Call) Return(_a0 error) *SchemaRegistryAwareInput_Run_Call

func (*SchemaRegistryAwareInput_Run_Call) Run added in v0.51.0 

func (_c *SchemaRegistryAwareInput_Run_Call) Run(run func(ctx context.Context)) *SchemaRegistryAwareInput_Run_Call

func (*SchemaRegistryAwareInput_Run_Call) RunAndReturn added in v0.51.0 

func (_c *SchemaRegistryAwareInput_Run_Call) RunAndReturn(run func(context.Context) error) *SchemaRegistryAwareInput_Run_Call

type SchemaRegistryAwareInput_Stop_Call added in v0.51.0 

type SchemaRegistryAwareInput_Stop_Call struct {
	*mock.Call
}

SchemaRegistryAwareInput_Stop_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Stop'

func (*SchemaRegistryAwareInput_Stop_Call) Return added in v0.51.0 

func (_c *SchemaRegistryAwareInput_Stop_Call) Return() *SchemaRegistryAwareInput_Stop_Call

func (*SchemaRegistryAwareInput_Stop_Call) Run added in v0.51.0 

func (_c *SchemaRegistryAwareInput_Stop_Call) Run(run func(ctx context.Context)) *SchemaRegistryAwareInput_Stop_Call

func (*SchemaRegistryAwareInput_Stop_Call) RunAndReturn added in v0.51.0 

func (_c *SchemaRegistryAwareInput_Stop_Call) RunAndReturn(run func(context.Context)) *SchemaRegistryAwareInput_Stop_Call

type SchemaRegistryAwareOutput added in v0.51.0 

type SchemaRegistryAwareOutput struct {
	mock.Mock
}

SchemaRegistryAwareOutput is an autogenerated mock type for the SchemaRegistryAwareOutput type

func NewSchemaRegistryAwareOutput added in v0.51.0 

func NewSchemaRegistryAwareOutput(t interface {
	mock.TestingT
	Cleanup(func())
}) *SchemaRegistryAwareOutput

NewSchemaRegistryAwareOutput creates a new instance of SchemaRegistryAwareOutput. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*SchemaRegistryAwareOutput) EXPECT added in v0.51.0 

func (_m *SchemaRegistryAwareOutput) EXPECT() *SchemaRegistryAwareOutput_Expecter

func (*SchemaRegistryAwareOutput) InitSchemaRegistry added in v0.51.0 

func (_m *SchemaRegistryAwareOutput) InitSchemaRegistry(ctx context.Context, settings stream.SchemaSettingsWithEncoding) (stream.MessageBodyEncoder, error)

InitSchemaRegistry provides a mock function with given fields: ctx, settings

func (*SchemaRegistryAwareOutput) Write added in v0.51.0 

func (_m *SchemaRegistryAwareOutput) Write(ctx context.Context, batch []stream.WritableMessage) error

Write provides a mock function with given fields: ctx, batch

func (*SchemaRegistryAwareOutput) WriteOne added in v0.51.0 

func (_m *SchemaRegistryAwareOutput) WriteOne(ctx context.Context, msg stream.WritableMessage) error

WriteOne provides a mock function with given fields: ctx, msg

type SchemaRegistryAwareOutput_Expecter added in v0.51.0 

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

func (*SchemaRegistryAwareOutput_Expecter) InitSchemaRegistry added in v0.51.0 

func (_e *SchemaRegistryAwareOutput_Expecter) InitSchemaRegistry(ctx interface{}, settings interface{}) *SchemaRegistryAwareOutput_InitSchemaRegistry_Call

InitSchemaRegistry is a helper method to define mock.On call

  • ctx context.Context
  • settings stream.SchemaSettingsWithEncoding

func (*SchemaRegistryAwareOutput_Expecter) Write added in v0.51.0 

func (_e *SchemaRegistryAwareOutput_Expecter) Write(ctx interface{}, batch interface{}) *SchemaRegistryAwareOutput_Write_Call

Write is a helper method to define mock.On call

  • ctx context.Context
  • batch []stream.WritableMessage

func (*SchemaRegistryAwareOutput_Expecter) WriteOne added in v0.51.0 

func (_e *SchemaRegistryAwareOutput_Expecter) WriteOne(ctx interface{}, msg interface{}) *SchemaRegistryAwareOutput_WriteOne_Call

WriteOne is a helper method to define mock.On call

  • ctx context.Context
  • msg stream.WritableMessage

type SchemaRegistryAwareOutput_InitSchemaRegistry_Call added in v0.51.0 

type SchemaRegistryAwareOutput_InitSchemaRegistry_Call struct {
	*mock.Call
}

SchemaRegistryAwareOutput_InitSchemaRegistry_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'InitSchemaRegistry'

func (*SchemaRegistryAwareOutput_InitSchemaRegistry_Call) Return added in v0.51.0 

func (_c *SchemaRegistryAwareOutput_InitSchemaRegistry_Call) Return(_a0 stream.MessageBodyEncoder, _a1 error) *SchemaRegistryAwareOutput_InitSchemaRegistry_Call

func (*SchemaRegistryAwareOutput_InitSchemaRegistry_Call) Run added in v0.51.0 

func (_c *SchemaRegistryAwareOutput_InitSchemaRegistry_Call) Run(run func(ctx context.Context, settings stream.SchemaSettingsWithEncoding)) *SchemaRegistryAwareOutput_InitSchemaRegistry_Call

func (*SchemaRegistryAwareOutput_InitSchemaRegistry_Call) RunAndReturn added in v0.51.0 

func (_c *SchemaRegistryAwareOutput_InitSchemaRegistry_Call) RunAndReturn(run func(context.Context, stream.SchemaSettingsWithEncoding) (stream.MessageBodyEncoder, error)) *SchemaRegistryAwareOutput_InitSchemaRegistry_Call

type SchemaRegistryAwareOutput_WriteOne_Call added in v0.51.0 

type SchemaRegistryAwareOutput_WriteOne_Call struct {
	*mock.Call
}

SchemaRegistryAwareOutput_WriteOne_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'WriteOne'

func (*SchemaRegistryAwareOutput_WriteOne_Call) Return added in v0.51.0 

func (_c *SchemaRegistryAwareOutput_WriteOne_Call) Return(_a0 error) *SchemaRegistryAwareOutput_WriteOne_Call

func (*SchemaRegistryAwareOutput_WriteOne_Call) Run added in v0.51.0 

func (_c *SchemaRegistryAwareOutput_WriteOne_Call) Run(run func(ctx context.Context, msg stream.WritableMessage)) *SchemaRegistryAwareOutput_WriteOne_Call

func (*SchemaRegistryAwareOutput_WriteOne_Call) RunAndReturn added in v0.51.0 

func (_c *SchemaRegistryAwareOutput_WriteOne_Call) RunAndReturn(run func(context.Context, stream.WritableMessage) error) *SchemaRegistryAwareOutput_WriteOne_Call

type SchemaRegistryAwareOutput_Write_Call added in v0.51.0 

type SchemaRegistryAwareOutput_Write_Call struct {
	*mock.Call
}

SchemaRegistryAwareOutput_Write_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Write'

func (*SchemaRegistryAwareOutput_Write_Call) Return added in v0.51.0 

func (_c *SchemaRegistryAwareOutput_Write_Call) Return(_a0 error) *SchemaRegistryAwareOutput_Write_Call

func (*SchemaRegistryAwareOutput_Write_Call) Run added in v0.51.0 

func (_c *SchemaRegistryAwareOutput_Write_Call) Run(run func(ctx context.Context, batch []stream.WritableMessage)) *SchemaRegistryAwareOutput_Write_Call

func (*SchemaRegistryAwareOutput_Write_Call) RunAndReturn added in v0.51.0 

func (_c *SchemaRegistryAwareOutput_Write_Call) RunAndReturn(run func(context.Context, []stream.WritableMessage) error) *SchemaRegistryAwareOutput_Write_Call

type SchemaSettingsAwareCallback added in v0.51.0 

type SchemaSettingsAwareCallback struct {
	mock.Mock
}

SchemaSettingsAwareCallback is an autogenerated mock type for the SchemaSettingsAwareCallback type

func NewSchemaSettingsAwareCallback added in v0.51.0 

func NewSchemaSettingsAwareCallback(t interface {
	mock.TestingT
	Cleanup(func())
}) *SchemaSettingsAwareCallback

NewSchemaSettingsAwareCallback creates a new instance of SchemaSettingsAwareCallback. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*SchemaSettingsAwareCallback) EXPECT added in v0.51.0 

func (_m *SchemaSettingsAwareCallback) EXPECT() *SchemaSettingsAwareCallback_Expecter

func (*SchemaSettingsAwareCallback) GetSchemaSettings added in v0.51.0 

func (_m *SchemaSettingsAwareCallback) GetSchemaSettings() (*stream.SchemaSettings, error)

GetSchemaSettings provides a mock function with no fields

type SchemaSettingsAwareCallback_Expecter added in v0.51.0 

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

func (*SchemaSettingsAwareCallback_Expecter) GetSchemaSettings added in v0.51.0 

func (_e *SchemaSettingsAwareCallback_Expecter) GetSchemaSettings() *SchemaSettingsAwareCallback_GetSchemaSettings_Call

GetSchemaSettings is a helper method to define mock.On call

type SchemaSettingsAwareCallback_GetSchemaSettings_Call added in v0.51.0 

type SchemaSettingsAwareCallback_GetSchemaSettings_Call struct {
	*mock.Call
}

SchemaSettingsAwareCallback_GetSchemaSettings_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetSchemaSettings'

func (*SchemaSettingsAwareCallback_GetSchemaSettings_Call) Return added in v0.51.0 

func (_c *SchemaSettingsAwareCallback_GetSchemaSettings_Call) Return(_a0 *stream.SchemaSettings, _a1 error) *SchemaSettingsAwareCallback_GetSchemaSettings_Call

func (*SchemaSettingsAwareCallback_GetSchemaSettings_Call) Run added in v0.51.0 

func (_c *SchemaSettingsAwareCallback_GetSchemaSettings_Call) Run(run func()) *SchemaSettingsAwareCallback_GetSchemaSettings_Call

func (*SchemaSettingsAwareCallback_GetSchemaSettings_Call) RunAndReturn added in v0.51.0 

func (_c *SchemaSettingsAwareCallback_GetSchemaSettings_Call) RunAndReturn(run func() (*stream.SchemaSettings, error)) *SchemaSettingsAwareCallback_GetSchemaSettings_Call

type UntypedBatchConsumerCallback added in v0.41.0 

type UntypedBatchConsumerCallback struct {
	mock.Mock
}

UntypedBatchConsumerCallback is an autogenerated mock type for the UntypedBatchConsumerCallback type

func NewUntypedBatchConsumerCallback added in v0.41.0 

func NewUntypedBatchConsumerCallback(t interface {
	mock.TestingT
	Cleanup(func())
}) *UntypedBatchConsumerCallback

NewUntypedBatchConsumerCallback creates a new instance of UntypedBatchConsumerCallback. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*UntypedBatchConsumerCallback) Consume added in v0.41.0 

func (_m *UntypedBatchConsumerCallback) Consume(ctx context.Context, models []interface{}, attributes []map[string]string) ([]bool, error)

Consume provides a mock function with given fields: ctx, models, attributes

func (*UntypedBatchConsumerCallback) EXPECT added in v0.41.0 

func (_m *UntypedBatchConsumerCallback) EXPECT() *UntypedBatchConsumerCallback_Expecter

func (*UntypedBatchConsumerCallback) GetModel added in v0.41.0 

func (_m *UntypedBatchConsumerCallback) GetModel(attributes map[string]string) (interface{}, error)

GetModel provides a mock function with given fields: attributes

type UntypedBatchConsumerCallback_Consume_Call added in v0.41.0 

type UntypedBatchConsumerCallback_Consume_Call struct {
	*mock.Call
}

UntypedBatchConsumerCallback_Consume_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Consume'

func (*UntypedBatchConsumerCallback_Consume_Call) Return added in v0.41.0 

func (_c *UntypedBatchConsumerCallback_Consume_Call) Return(_a0 []bool, _a1 error) *UntypedBatchConsumerCallback_Consume_Call

func (*UntypedBatchConsumerCallback_Consume_Call) Run added in v0.41.0 

func (_c *UntypedBatchConsumerCallback_Consume_Call) Run(run func(ctx context.Context, models []interface{}, attributes []map[string]string)) *UntypedBatchConsumerCallback_Consume_Call

func (*UntypedBatchConsumerCallback_Consume_Call) RunAndReturn added in v0.41.0 

func (_c *UntypedBatchConsumerCallback_Consume_Call) RunAndReturn(run func(context.Context, []interface{}, []map[string]string) ([]bool, error)) *UntypedBatchConsumerCallback_Consume_Call

type UntypedBatchConsumerCallback_Expecter added in v0.41.0 

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

func (*UntypedBatchConsumerCallback_Expecter) Consume added in v0.41.0 

func (_e *UntypedBatchConsumerCallback_Expecter) Consume(ctx interface{}, models interface{}, attributes interface{}) *UntypedBatchConsumerCallback_Consume_Call

Consume is a helper method to define mock.On call

  • ctx context.Context
  • models []interface{}
  • attributes []map[string]string

func (*UntypedBatchConsumerCallback_Expecter) GetModel added in v0.41.0 

func (_e *UntypedBatchConsumerCallback_Expecter) GetModel(attributes interface{}) *UntypedBatchConsumerCallback_GetModel_Call

GetModel is a helper method to define mock.On call

  • attributes map[string]string

type UntypedBatchConsumerCallback_GetModel_Call added in v0.41.0 

type UntypedBatchConsumerCallback_GetModel_Call struct {
	*mock.Call
}

UntypedBatchConsumerCallback_GetModel_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetModel'

func (*UntypedBatchConsumerCallback_GetModel_Call) Return added in v0.41.0 

func (_c *UntypedBatchConsumerCallback_GetModel_Call) Return(_a0 interface{}, _a1 error) *UntypedBatchConsumerCallback_GetModel_Call

func (*UntypedBatchConsumerCallback_GetModel_Call) Run added in v0.41.0 

func (_c *UntypedBatchConsumerCallback_GetModel_Call) Run(run func(attributes map[string]string)) *UntypedBatchConsumerCallback_GetModel_Call

func (*UntypedBatchConsumerCallback_GetModel_Call) RunAndReturn added in v0.41.0 

func (_c *UntypedBatchConsumerCallback_GetModel_Call) RunAndReturn(run func(map[string]string) (interface{}, error)) *UntypedBatchConsumerCallback_GetModel_Call

type UntypedConsumerCallback added in v0.41.0 

type UntypedConsumerCallback struct {
	mock.Mock
}

UntypedConsumerCallback is an autogenerated mock type for the UntypedConsumerCallback type

func NewUntypedConsumerCallback added in v0.41.0 

func NewUntypedConsumerCallback(t interface {
	mock.TestingT
	Cleanup(func())
}) *UntypedConsumerCallback

NewUntypedConsumerCallback creates a new instance of UntypedConsumerCallback. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*UntypedConsumerCallback) Consume added in v0.41.0 

func (_m *UntypedConsumerCallback) Consume(ctx context.Context, model interface{}, attributes map[string]string) (bool, error)

Consume provides a mock function with given fields: ctx, model, attributes

func (*UntypedConsumerCallback) EXPECT added in v0.41.0 

func (_m *UntypedConsumerCallback) EXPECT() *UntypedConsumerCallback_Expecter

func (*UntypedConsumerCallback) GetModel added in v0.41.0 

func (_m *UntypedConsumerCallback) GetModel(attributes map[string]string) (interface{}, error)

GetModel provides a mock function with given fields: attributes

type UntypedConsumerCallback_Consume_Call added in v0.41.0 

type UntypedConsumerCallback_Consume_Call struct {
	*mock.Call
}

UntypedConsumerCallback_Consume_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Consume'

func (*UntypedConsumerCallback_Consume_Call) Return added in v0.41.0 

func (_c *UntypedConsumerCallback_Consume_Call) Return(_a0 bool, _a1 error) *UntypedConsumerCallback_Consume_Call

func (*UntypedConsumerCallback_Consume_Call) Run added in v0.41.0 

func (_c *UntypedConsumerCallback_Consume_Call) Run(run func(ctx context.Context, model interface{}, attributes map[string]string)) *UntypedConsumerCallback_Consume_Call

func (*UntypedConsumerCallback_Consume_Call) RunAndReturn added in v0.41.0 

func (_c *UntypedConsumerCallback_Consume_Call) RunAndReturn(run func(context.Context, interface{}, map[string]string) (bool, error)) *UntypedConsumerCallback_Consume_Call

type UntypedConsumerCallback_Expecter added in v0.41.0 

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

func (*UntypedConsumerCallback_Expecter) Consume added in v0.41.0 

func (_e *UntypedConsumerCallback_Expecter) Consume(ctx interface{}, model interface{}, attributes interface{}) *UntypedConsumerCallback_Consume_Call

Consume is a helper method to define mock.On call

  • ctx context.Context
  • model interface{}
  • attributes map[string]string

func (*UntypedConsumerCallback_Expecter) GetModel added in v0.41.0 

func (_e *UntypedConsumerCallback_Expecter) GetModel(attributes interface{}) *UntypedConsumerCallback_GetModel_Call

GetModel is a helper method to define mock.On call

  • attributes map[string]string

type UntypedConsumerCallback_GetModel_Call added in v0.41.0 

type UntypedConsumerCallback_GetModel_Call struct {
	*mock.Call
}

UntypedConsumerCallback_GetModel_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetModel'

func (*UntypedConsumerCallback_GetModel_Call) Return added in v0.41.0 

func (_c *UntypedConsumerCallback_GetModel_Call) Return(_a0 interface{}, _a1 error) *UntypedConsumerCallback_GetModel_Call

func (*UntypedConsumerCallback_GetModel_Call) Run added in v0.41.0 

func (_c *UntypedConsumerCallback_GetModel_Call) Run(run func(attributes map[string]string)) *UntypedConsumerCallback_GetModel_Call

func (*UntypedConsumerCallback_GetModel_Call) RunAndReturn added in v0.41.0 

func (_c *UntypedConsumerCallback_GetModel_Call) RunAndReturn(run func(map[string]string) (interface{}, error)) *UntypedConsumerCallback_GetModel_Call

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.