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 + AddSubscription func(ctx context.Context, subscription *metadata.Subscription) error + DeleteSubscription func(ctx context.Context, id vanus.ID) error + GetDeadLetterOffset func(ctx context.Context, id vanus.ID) (uint64, error) + GetOffset func(ctx context.Context, id vanus.ID) (info.ListOffsetInfo, error) + GetOrSaveOffset func(ctx context.Context, id vanus.ID) (info.ListOffsetInfo, error) + GetSubscription func(ctx context.Context, id vanus.ID) *metadata.Subscription + GetSubscriptionByName func(ctx context.Context, namespaceID vanus.ID, name string) *metadata.Subscription + Heartbeat func(ctx context.Context, id vanus.ID, addr string, time time.Time) error + Init func(ctx context.Context) error + ListSubscription func(ctx context.Context) []*metadata.Subscription + ResetOffsetByTimestamp func(ctx context.Context, id vanus.ID, timestamp uint64) (info.ListOffsetInfo, error) + SaveDeadLetterOffset func(ctx context.Context, id vanus.ID, offset uint64) error + SaveOffset func(ctx context.Context, id vanus.ID, offsets info.ListOffsetInfo, commit bool) error + Start func() + Stop func() + UpdateSubscription func(ctx context.Context, subscription *metadata.Subscription) error + func NewSubscriptionManager(storage storage.Storage, secretStorage secret.Storage, ebCli eb.Client, ...) Manager + type MockManager struct + func NewMockManager(ctrl *gomock.Controller) *MockManager + func (m *MockManager) AddSubscription(ctx context.Context, subscription *metadata.Subscription) error + func (m *MockManager) DeleteSubscription(ctx context.Context, id vanus.ID) error + func (m *MockManager) EXPECT() *MockManagerMockRecorder + func (m *MockManager) GetDeadLetterOffset(ctx context.Context, id vanus.ID) (uint64, error) + func (m *MockManager) GetOffset(ctx context.Context, id vanus.ID) (info.ListOffsetInfo, error) + func (m *MockManager) GetOrSaveOffset(ctx context.Context, id vanus.ID) (info.ListOffsetInfo, error) + func (m *MockManager) GetSubscription(ctx context.Context, id vanus.ID) *metadata.Subscription + func (m *MockManager) GetSubscriptionByName(ctx context.Context, eventbusID vanus.ID, name string) *metadata.Subscription + func (m *MockManager) Heartbeat(ctx context.Context, id vanus.ID, addr string, time time.Time) error + func (m *MockManager) Init(ctx context.Context) error + func (m *MockManager) ListSubscription(ctx context.Context) []*metadata.Subscription + func (m *MockManager) ResetOffsetByTimestamp(ctx context.Context, id vanus.ID, timestamp uint64) (info.ListOffsetInfo, error) + func (m *MockManager) SaveDeadLetterOffset(ctx context.Context, id vanus.ID, offset uint64) error + func (m *MockManager) SaveOffset(ctx context.Context, id vanus.ID, offsets info.ListOffsetInfo, commit bool) error + func (m *MockManager) Start() + func (m *MockManager) Stop() + func (m *MockManager) UpdateSubscription(ctx context.Context, subscription *metadata.Subscription) error + type MockManagerMockRecorder struct + func (mr *MockManagerMockRecorder) AddSubscription(ctx, subscription interface{}) *gomock.Call + func (mr *MockManagerMockRecorder) DeleteSubscription(ctx, id interface{}) *gomock.Call + func (mr *MockManagerMockRecorder) GetDeadLetterOffset(ctx, id interface{}) *gomock.Call + func (mr *MockManagerMockRecorder) GetOffset(ctx, id interface{}) *gomock.Call + func (mr *MockManagerMockRecorder) GetOrSaveOffset(ctx, id interface{}) *gomock.Call + func (mr *MockManagerMockRecorder) GetSubscription(ctx, id interface{}) *gomock.Call + func (mr *MockManagerMockRecorder) GetSubscriptionByName(ctx, eventbusID, name interface{}) *gomock.Call + func (mr *MockManagerMockRecorder) Heartbeat(ctx, id, addr, time interface{}) *gomock.Call + func (mr *MockManagerMockRecorder) Init(ctx interface{}) *gomock.Call + func (mr *MockManagerMockRecorder) ListSubscription(ctx interface{}) *gomock.Call + func (mr *MockManagerMockRecorder) ResetOffsetByTimestamp(ctx, id, timestamp interface{}) *gomock.Call + func (mr *MockManagerMockRecorder) SaveDeadLetterOffset(ctx, id, offset interface{}) *gomock.Call + func (mr *MockManagerMockRecorder) SaveOffset(ctx, id, offsets, commit interface{}) *gomock.Call + func (mr *MockManagerMockRecorder) Start() *gomock.Call + func (mr *MockManagerMockRecorder) Stop() *gomock.Call + func (mr *MockManagerMockRecorder) UpdateSubscription(ctx, subscription interface{}) *gomock.Call
Go to main page