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 + func NewSecretStorage(config primitive.KvStorageConfig, encryption string) (secret.Storage, error) + type MockOffsetStorage struct + func NewMockOffsetStorage(ctrl *gomock.Controller) *MockOffsetStorage + func (m *MockOffsetStorage) CreateOffset(ctx context.Context, subscriptionID vanus.ID, info info.OffsetInfo) error + func (m *MockOffsetStorage) DeleteOffset(ctx context.Context, subscriptionID vanus.ID) error + func (m *MockOffsetStorage) EXPECT() *MockOffsetStorageMockRecorder + func (m *MockOffsetStorage) GetOffsets(ctx context.Context, subscriptionID vanus.ID) (info.ListOffsetInfo, error) + func (m *MockOffsetStorage) UpdateOffset(ctx context.Context, subscriptionID vanus.ID, info info.OffsetInfo) error + type MockOffsetStorageMockRecorder struct + func (mr *MockOffsetStorageMockRecorder) CreateOffset(ctx, subscriptionID, info interface{}) *gomock.Call + func (mr *MockOffsetStorageMockRecorder) DeleteOffset(ctx, subscriptionID interface{}) *gomock.Call + func (mr *MockOffsetStorageMockRecorder) GetOffsets(ctx, subscriptionID interface{}) *gomock.Call + func (mr *MockOffsetStorageMockRecorder) UpdateOffset(ctx, subscriptionID, info interface{}) *gomock.Call + type MockStorage struct + func NewMockStorage(ctrl *gomock.Controller) *MockStorage + func (m *MockStorage) Close() + type MockSubscriptionStorage struct + func NewMockSubscriptionStorage(ctrl *gomock.Controller) *MockSubscriptionStorage + func (m *MockSubscriptionStorage) CreateSubscription(ctx context.Context, sub *metadata.Subscription) error + func (m *MockSubscriptionStorage) DeleteSubscription(ctx context.Context, id vanus.ID) error + func (m *MockSubscriptionStorage) EXPECT() *MockSubscriptionStorageMockRecorder + func (m *MockSubscriptionStorage) GetSubscription(ctx context.Context, id vanus.ID) (*metadata.Subscription, error) + func (m *MockSubscriptionStorage) ListSubscription(ctx context.Context) ([]*metadata.Subscription, error) + func (m *MockSubscriptionStorage) UpdateSubscription(ctx context.Context, sub *metadata.Subscription) error + type MockSubscriptionStorageMockRecorder struct + func (mr *MockSubscriptionStorageMockRecorder) CreateSubscription(ctx, sub interface{}) *gomock.Call + func (mr *MockSubscriptionStorageMockRecorder) DeleteSubscription(ctx, id interface{}) *gomock.Call + func (mr *MockSubscriptionStorageMockRecorder) GetSubscription(ctx, id interface{}) *gomock.Call + func (mr *MockSubscriptionStorageMockRecorder) ListSubscription(ctx interface{}) *gomock.Call + func (mr *MockSubscriptionStorageMockRecorder) UpdateSubscription(ctx, sub interface{}) *gomock.Call + type MockTriggerWorkerStorage struct + func NewMockTriggerWorkerStorage(ctrl *gomock.Controller) *MockTriggerWorkerStorage + func (m *MockTriggerWorkerStorage) DeleteTriggerWorker(ctx context.Context, id string) error + func (m *MockTriggerWorkerStorage) EXPECT() *MockTriggerWorkerStorageMockRecorder + func (m *MockTriggerWorkerStorage) GetTriggerWorker(ctx context.Context, id string) (*metadata.TriggerWorkerInfo, error) + func (m *MockTriggerWorkerStorage) ListTriggerWorker(ctx context.Context) ([]*metadata.TriggerWorkerInfo, error) + func (m *MockTriggerWorkerStorage) SaveTriggerWorker(arg0 context.Context, arg1 metadata.TriggerWorkerInfo) error + type MockTriggerWorkerStorageMockRecorder struct + func (mr *MockTriggerWorkerStorageMockRecorder) DeleteTriggerWorker(ctx, id interface{}) *gomock.Call + func (mr *MockTriggerWorkerStorageMockRecorder) GetTriggerWorker(ctx, id interface{}) *gomock.Call + func (mr *MockTriggerWorkerStorageMockRecorder) ListTriggerWorker(ctx interface{}) *gomock.Call + func (mr *MockTriggerWorkerStorageMockRecorder) SaveTriggerWorker(arg0, arg1 interface{}) *gomock.Call + type OffsetStorage interface + CreateOffset func(ctx context.Context, subscriptionID vanus.ID, info info.OffsetInfo) error + DeleteOffset func(ctx context.Context, subscriptionID vanus.ID) error + GetOffsets func(ctx context.Context, subscriptionID vanus.ID) (info.ListOffsetInfo, error) + UpdateOffset func(ctx context.Context, subscriptionID vanus.ID, info info.OffsetInfo) error + func NewOffsetStorage(client kv.Client) OffsetStorage + type SecretStorage struct + func (p *SecretStorage) Delete(ctx context.Context, subID vanus.ID) error + func (p *SecretStorage) Read(ctx context.Context, subID vanus.ID, credentialType primitive.CredentialType) (primitive.SinkCredential, error) + func (p *SecretStorage) Write(ctx context.Context, subID vanus.ID, credential primitive.SinkCredential) error + type Storage interface + Close func() + func NewFakeStorage() Storage + func NewStorage(config primitive.KvStorageConfig) (Storage, error) + type SubscriptionStorage interface + CreateSubscription func(ctx context.Context, sub *metadata.Subscription) error + DeleteSubscription func(ctx context.Context, id vanus.ID) error + GetSubscription func(ctx context.Context, id vanus.ID) (*metadata.Subscription, error) + ListSubscription func(ctx context.Context) ([]*metadata.Subscription, error) + UpdateSubscription func(ctx context.Context, sub *metadata.Subscription) error + func NewSubscriptionStorage(client kv.Client) SubscriptionStorage + type TriggerWorkerStorage interface + DeleteTriggerWorker func(ctx context.Context, id string) error + GetTriggerWorker func(ctx context.Context, id string) (*metadata.TriggerWorkerInfo, error) + ListTriggerWorker func(ctx context.Context) ([]*metadata.TriggerWorkerInfo, error) + SaveTriggerWorker func(context.Context, metadata.TriggerWorkerInfo) error + func NewTriggerWorkerStorage(client kv.Client) TriggerWorkerStorage
Go to main page