Versions in this module Expand all Collapse all v0 v0.9.0 Sep 7, 2023 v0.8.0 Apr 17, 2023 Changes in this version + type Manager interface + GetOffset func(ctx context.Context, subscriptionID vanus.ID) (info.ListOffsetInfo, error) + Offset func(ctx context.Context, subscriptionID vanus.ID, offsets info.ListOffsetInfo, ...) error + RemoveRegisterSubscription func(ctx context.Context, id vanus.ID) error + Start func() + Stop func() + func NewOffsetManager(storage storage.OffsetStorage, commitInterval time.Duration) Manager + type MockManager struct + 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 struct + 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
Go to main page