offset

Documentation

Overview

Package offset is a generated GoMock package.

Index

• type Manager
  • func NewOffsetManager(storage storage.OffsetStorage, commitInterval time.Duration) Manager
• type MockManager
  • func NewMockManager(ctrl *gomock.Controller) *MockManager
  • func (m *MockManager) EXPECT() *MockManagerMockRecorder
  • func (m *MockManager) GetOffset(ctx context.Context, subscriptionID vanus.ID) (info.ListOffsetInfo, error)
  • func (m *MockManager) Offset(ctx context.Context, subscriptionID vanus.ID, offsets info.ListOffsetInfo, ...) error
  • func (m *MockManager) RemoveRegisterSubscription(ctx context.Context, id vanus.ID) error
  • func (m *MockManager) Start()
  • func (m *MockManager) Stop()
• type MockManagerMockRecorder
  • func (mr *MockManagerMockRecorder) GetOffset(ctx, subscriptionID interface{}) *gomock.Call
  • func (mr *MockManagerMockRecorder) Offset(ctx, subscriptionID, offsets, commit interface{}) *gomock.Call
  • func (mr *MockManagerMockRecorder) RemoveRegisterSubscription(ctx, id interface{}) *gomock.Call
  • func (mr *MockManagerMockRecorder) Start() *gomock.Call
  • func (mr *MockManagerMockRecorder) Stop() *gomock.Call

Types

type Manager

type Manager interface {
	GetOffset(ctx context.Context, subscriptionID vanus.ID) (info.ListOffsetInfo, error)
	Offset(ctx context.Context, subscriptionID vanus.ID, offsets info.ListOffsetInfo, commit bool) error
	RemoveRegisterSubscription(ctx context.Context, id vanus.ID) error
	Start()
	Stop()
}

func NewOffsetManager

func NewOffsetManager(storage storage.OffsetStorage, commitInterval time.Duration) Manager

type MockManager

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

MockManager is a mock of Manager interface.

func NewMockManager

func NewMockManager(ctrl *gomock.Controller) *MockManager

NewMockManager creates a new mock instance.

func (*MockManager) EXPECT

func (m *MockManager) EXPECT() *MockManagerMockRecorder

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

func (*MockManager) GetOffset

func (m *MockManager) GetOffset(ctx context.Context, subscriptionID vanus.ID) (info.ListOffsetInfo, error)

GetOffset mocks base method.

func (*MockManager) Offset

func (m *MockManager) Offset(ctx context.Context, subscriptionID vanus.ID, offsets info.ListOffsetInfo, commit bool) error

Offset mocks base method.

func (*MockManager) RemoveRegisterSubscription

func (m *MockManager) RemoveRegisterSubscription(ctx context.Context, id vanus.ID) error

RemoveRegisterSubscription mocks base method.

func (*MockManager) Start

func (m *MockManager) Start()

Start mocks base method.

func (*MockManager) Stop

func (m *MockManager) Stop()

Stop mocks base method.

type MockManagerMockRecorder

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

MockManagerMockRecorder is the mock recorder for MockManager.

func (*MockManagerMockRecorder) GetOffset

func (mr *MockManagerMockRecorder) GetOffset(ctx, subscriptionID interface{}) *gomock.Call

GetOffset indicates an expected call of GetOffset.

func (*MockManagerMockRecorder) Offset

func (mr *MockManagerMockRecorder) Offset(ctx, subscriptionID, offsets, commit interface{}) *gomock.Call

Offset indicates an expected call of Offset.

func (*MockManagerMockRecorder) RemoveRegisterSubscription

func (mr *MockManagerMockRecorder) RemoveRegisterSubscription(ctx, id interface{}) *gomock.Call

RemoveRegisterSubscription indicates an expected call of RemoveRegisterSubscription.

func (*MockManagerMockRecorder) Start

func (mr *MockManagerMockRecorder) Start() *gomock.Call

Start indicates an expected call of Start.

func (*MockManagerMockRecorder) Stop

func (mr *MockManagerMockRecorder) Stop() *gomock.Call

Stop indicates an expected call of Stop.