mock_handler

package
v0.10.3-0...-929dc65 Latest Latest
Warning

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

 Go to latest Published: Nov 13, 2025 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MockHandlerClient 

type MockHandlerClient struct {
	mock.Mock
}

MockHandlerClient is an autogenerated mock type for the HandlerClient type

func NewMockHandlerClient 

func NewMockHandlerClient(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockHandlerClient

NewMockHandlerClient creates a new instance of MockHandlerClient. 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 (*MockHandlerClient) Close 

func (_m *MockHandlerClient) Close()

Close provides a mock function with no fields

func (*MockHandlerClient) CreateConsumer 

func (_m *MockHandlerClient) CreateConsumer(ctx context.Context, opts *handler.ConsumerOptions) (handler.Consumer, error)

CreateConsumer provides a mock function with given fields: ctx, opts

func (*MockHandlerClient) CreateProducer 

func (_m *MockHandlerClient) CreateProducer(ctx context.Context, opts *handler.ProducerOptions) (handler.Producer, error)

CreateProducer provides a mock function with given fields: ctx, opts

func (*MockHandlerClient) EXPECT 

func (_m *MockHandlerClient) EXPECT() *MockHandlerClient_Expecter

func (*MockHandlerClient) GetLatestMVCCTimestampIfLocal 

func (_m *MockHandlerClient) GetLatestMVCCTimestampIfLocal(ctx context.Context, vchannel string) (uint64, error)

GetLatestMVCCTimestampIfLocal provides a mock function with given fields: ctx, vchannel

func (*MockHandlerClient) GetReplicateCheckpoint 

func (_m *MockHandlerClient) GetReplicateCheckpoint(ctx context.Context, channelName string) (*wal.ReplicateCheckpoint, error)

GetReplicateCheckpoint provides a mock function with given fields: ctx, channelName

func (*MockHandlerClient) GetWALMetricsIfLocal 

func (_m *MockHandlerClient) GetWALMetricsIfLocal(ctx context.Context) (*types.StreamingNodeMetrics, error)

GetWALMetricsIfLocal provides a mock function with given fields: ctx

type MockHandlerClient_Close_Call 

type MockHandlerClient_Close_Call struct {
	*mock.Call
}

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

func (*MockHandlerClient_Close_Call) Return 

func (_c *MockHandlerClient_Close_Call) Return() *MockHandlerClient_Close_Call

func (*MockHandlerClient_Close_Call) Run 

func (_c *MockHandlerClient_Close_Call) Run(run func()) *MockHandlerClient_Close_Call

func (*MockHandlerClient_Close_Call) RunAndReturn 

func (_c *MockHandlerClient_Close_Call) RunAndReturn(run func()) *MockHandlerClient_Close_Call

type MockHandlerClient_CreateConsumer_Call 

type MockHandlerClient_CreateConsumer_Call struct {
	*mock.Call
}

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

func (*MockHandlerClient_CreateConsumer_Call) Return 

func (_c *MockHandlerClient_CreateConsumer_Call) Return(_a0 handler.Consumer, _a1 error) *MockHandlerClient_CreateConsumer_Call

func (*MockHandlerClient_CreateConsumer_Call) Run 

func (_c *MockHandlerClient_CreateConsumer_Call) Run(run func(ctx context.Context, opts *handler.ConsumerOptions)) *MockHandlerClient_CreateConsumer_Call

func (*MockHandlerClient_CreateConsumer_Call) RunAndReturn 

func (_c *MockHandlerClient_CreateConsumer_Call) RunAndReturn(run func(context.Context, *handler.ConsumerOptions) (handler.Consumer, error)) *MockHandlerClient_CreateConsumer_Call

type MockHandlerClient_CreateProducer_Call 

type MockHandlerClient_CreateProducer_Call struct {
	*mock.Call
}

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

func (*MockHandlerClient_CreateProducer_Call) Return 

func (_c *MockHandlerClient_CreateProducer_Call) Return(_a0 handler.Producer, _a1 error) *MockHandlerClient_CreateProducer_Call

func (*MockHandlerClient_CreateProducer_Call) Run 

func (_c *MockHandlerClient_CreateProducer_Call) Run(run func(ctx context.Context, opts *handler.ProducerOptions)) *MockHandlerClient_CreateProducer_Call

func (*MockHandlerClient_CreateProducer_Call) RunAndReturn 

func (_c *MockHandlerClient_CreateProducer_Call) RunAndReturn(run func(context.Context, *handler.ProducerOptions) (handler.Producer, error)) *MockHandlerClient_CreateProducer_Call

type MockHandlerClient_Expecter 

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

func (*MockHandlerClient_Expecter) Close 

func (_e *MockHandlerClient_Expecter) Close() *MockHandlerClient_Close_Call

Close is a helper method to define mock.On call

func (*MockHandlerClient_Expecter) CreateConsumer 

func (_e *MockHandlerClient_Expecter) CreateConsumer(ctx interface{}, opts interface{}) *MockHandlerClient_CreateConsumer_Call

CreateConsumer is a helper method to define mock.On call

  • ctx context.Context
  • opts *handler.ConsumerOptions

func (*MockHandlerClient_Expecter) CreateProducer 

func (_e *MockHandlerClient_Expecter) CreateProducer(ctx interface{}, opts interface{}) *MockHandlerClient_CreateProducer_Call

CreateProducer is a helper method to define mock.On call

  • ctx context.Context
  • opts *handler.ProducerOptions

func (*MockHandlerClient_Expecter) GetLatestMVCCTimestampIfLocal 

func (_e *MockHandlerClient_Expecter) GetLatestMVCCTimestampIfLocal(ctx interface{}, vchannel interface{}) *MockHandlerClient_GetLatestMVCCTimestampIfLocal_Call

GetLatestMVCCTimestampIfLocal is a helper method to define mock.On call

  • ctx context.Context
  • vchannel string

func (*MockHandlerClient_Expecter) GetReplicateCheckpoint 

func (_e *MockHandlerClient_Expecter) GetReplicateCheckpoint(ctx interface{}, channelName interface{}) *MockHandlerClient_GetReplicateCheckpoint_Call

GetReplicateCheckpoint is a helper method to define mock.On call

  • ctx context.Context
  • channelName string

func (*MockHandlerClient_Expecter) GetWALMetricsIfLocal 

func (_e *MockHandlerClient_Expecter) GetWALMetricsIfLocal(ctx interface{}) *MockHandlerClient_GetWALMetricsIfLocal_Call

GetWALMetricsIfLocal is a helper method to define mock.On call

  • ctx context.Context

type MockHandlerClient_GetLatestMVCCTimestampIfLocal_Call 

type MockHandlerClient_GetLatestMVCCTimestampIfLocal_Call struct {
	*mock.Call
}

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

func (*MockHandlerClient_GetLatestMVCCTimestampIfLocal_Call) Return 

func (_c *MockHandlerClient_GetLatestMVCCTimestampIfLocal_Call) Return(_a0 uint64, _a1 error) *MockHandlerClient_GetLatestMVCCTimestampIfLocal_Call

func (*MockHandlerClient_GetLatestMVCCTimestampIfLocal_Call) Run 

func (_c *MockHandlerClient_GetLatestMVCCTimestampIfLocal_Call) Run(run func(ctx context.Context, vchannel string)) *MockHandlerClient_GetLatestMVCCTimestampIfLocal_Call

func (*MockHandlerClient_GetLatestMVCCTimestampIfLocal_Call) RunAndReturn 

func (_c *MockHandlerClient_GetLatestMVCCTimestampIfLocal_Call) RunAndReturn(run func(context.Context, string) (uint64, error)) *MockHandlerClient_GetLatestMVCCTimestampIfLocal_Call

type MockHandlerClient_GetReplicateCheckpoint_Call 

type MockHandlerClient_GetReplicateCheckpoint_Call struct {
	*mock.Call
}

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

func (*MockHandlerClient_GetReplicateCheckpoint_Call) Return 

func (_c *MockHandlerClient_GetReplicateCheckpoint_Call) Return(_a0 *wal.ReplicateCheckpoint, _a1 error) *MockHandlerClient_GetReplicateCheckpoint_Call

func (*MockHandlerClient_GetReplicateCheckpoint_Call) Run 

func (_c *MockHandlerClient_GetReplicateCheckpoint_Call) Run(run func(ctx context.Context, channelName string)) *MockHandlerClient_GetReplicateCheckpoint_Call

func (*MockHandlerClient_GetReplicateCheckpoint_Call) RunAndReturn 

func (_c *MockHandlerClient_GetReplicateCheckpoint_Call) RunAndReturn(run func(context.Context, string) (*wal.ReplicateCheckpoint, error)) *MockHandlerClient_GetReplicateCheckpoint_Call

type MockHandlerClient_GetWALMetricsIfLocal_Call 

type MockHandlerClient_GetWALMetricsIfLocal_Call struct {
	*mock.Call
}

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

func (*MockHandlerClient_GetWALMetricsIfLocal_Call) Return 

func (_c *MockHandlerClient_GetWALMetricsIfLocal_Call) Return(_a0 *types.StreamingNodeMetrics, _a1 error) *MockHandlerClient_GetWALMetricsIfLocal_Call

func (*MockHandlerClient_GetWALMetricsIfLocal_Call) Run 

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

func (*MockHandlerClient_GetWALMetricsIfLocal_Call) RunAndReturn 

func (_c *MockHandlerClient_GetWALMetricsIfLocal_Call) RunAndReturn(run func(context.Context) (*types.StreamingNodeMetrics, error)) *MockHandlerClient_GetWALMetricsIfLocal_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.