mocks

package
v0.0.0-...-3a8d8de Latest Latest
Warning

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

 Go to latest Published: Jan 9, 2025 License: BSD-3-Clause Imports: 4 Imported by: 0

Documentation

Overview

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MockNatsClient 

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

MockNatsClient is a mock of NatsClient interface.

func NewMockNatsClient 

func NewMockNatsClient(ctrl *gomock.Controller) *MockNatsClient

NewMockNatsClient creates a new mock instance.

func (*MockNatsClient) CreateKeyValueStore 

func (m *MockNatsClient) CreateKeyValueStore(keyValueStore string) error

CreateKeyValueStore mocks base method.

func (*MockNatsClient) CreateObjectStore 

func (m *MockNatsClient) CreateObjectStore(objectStore string) error

CreateObjectStore mocks base method.

func (*MockNatsClient) CreateStream 

func (m *MockNatsClient) CreateStream(streamConfig *entity.StreamConfig) error

CreateStream mocks base method.

func (*MockNatsClient) DeleteKeyValueStore 

func (m *MockNatsClient) DeleteKeyValueStore(keyValueStore string) error

DeleteKeyValueStore mocks base method.

func (*MockNatsClient) DeleteObjectStore 

func (m *MockNatsClient) DeleteObjectStore(stream string) error

DeleteObjectStore mocks base method.

func (*MockNatsClient) DeleteStream 

func (m *MockNatsClient) DeleteStream(stream string) error

DeleteStream mocks base method.

func (*MockNatsClient) EXPECT 

func (m *MockNatsClient) EXPECT() *MockNatsClientMockRecorder

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

func (*MockNatsClient) GetObjectStoreNames 

func (m *MockNatsClient) GetObjectStoreNames(optFilter ...*regexp.Regexp) ([]string, error)

GetObjectStoreNames mocks base method.

func (*MockNatsClient) GetStreamNames 

func (m *MockNatsClient) GetStreamNames(optFilter ...*regexp.Regexp) ([]string, error)

GetStreamNames mocks base method.

func (*MockNatsClient) UpdateConfiguration 

func (m *MockNatsClient) UpdateConfiguration(keyValueStore string, keyValueConfig map[string]string) error

UpdateConfiguration mocks base method.

type MockNatsClientMockRecorder 

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

MockNatsClientMockRecorder is the mock recorder for MockNatsClient.

func (*MockNatsClientMockRecorder) CreateKeyValueStore 

func (mr *MockNatsClientMockRecorder) CreateKeyValueStore(keyValueStore interface{}) *gomock.Call

CreateKeyValueStore indicates an expected call of CreateKeyValueStore.

func (*MockNatsClientMockRecorder) CreateObjectStore 

func (mr *MockNatsClientMockRecorder) CreateObjectStore(objectStore interface{}) *gomock.Call

CreateObjectStore indicates an expected call of CreateObjectStore.

func (*MockNatsClientMockRecorder) CreateStream 

func (mr *MockNatsClientMockRecorder) CreateStream(streamConfig interface{}) *gomock.Call

CreateStream indicates an expected call of CreateStream.

func (*MockNatsClientMockRecorder) DeleteKeyValueStore 

func (mr *MockNatsClientMockRecorder) DeleteKeyValueStore(keyValueStore interface{}) *gomock.Call

DeleteKeyValueStore indicates an expected call of DeleteKeyValueStore.

func (*MockNatsClientMockRecorder) DeleteObjectStore 

func (mr *MockNatsClientMockRecorder) DeleteObjectStore(stream interface{}) *gomock.Call

DeleteObjectStore indicates an expected call of DeleteObjectStore.

func (*MockNatsClientMockRecorder) DeleteStream 

func (mr *MockNatsClientMockRecorder) DeleteStream(stream interface{}) *gomock.Call

DeleteStream indicates an expected call of DeleteStream.

func (*MockNatsClientMockRecorder) GetObjectStoreNames 

func (mr *MockNatsClientMockRecorder) GetObjectStoreNames(optFilter ...interface{}) *gomock.Call

GetObjectStoreNames indicates an expected call of GetObjectStoreNames.

func (*MockNatsClientMockRecorder) GetStreamNames 

func (mr *MockNatsClientMockRecorder) GetStreamNames(optFilter ...interface{}) *gomock.Call

GetStreamNames indicates an expected call of GetStreamNames.

func (*MockNatsClientMockRecorder) UpdateConfiguration 

func (mr *MockNatsClientMockRecorder) UpdateConfiguration(keyValueStore, keyValueConfig interface{}) *gomock.Call

UpdateConfiguration indicates an expected call of UpdateConfiguration.

type MockNatsManager 

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

MockNatsManager is a mock of NatsManager interface.

func NewMockNatsManager 

func NewMockNatsManager(ctrl *gomock.Controller) *MockNatsManager

NewMockNatsManager creates a new mock instance.

func (*MockNatsManager) CreateGlobalKeyValueStore 

func (m *MockNatsManager) CreateGlobalKeyValueStore(productID string) (string, error)

CreateGlobalKeyValueStore mocks base method.

func (*MockNatsManager) CreateObjectStores 

func (m *MockNatsManager) CreateObjectStores(productID, versionTag string, workflows []entity.Workflow) (entity.WorkflowsObjectStoresConfig, error)

CreateObjectStores mocks base method.

func (*MockNatsManager) CreateStreams 

func (m *MockNatsManager) CreateStreams(productID, versionTag string, workflows []entity.Workflow) (entity.WorkflowsStreamsConfig, error)

CreateStreams mocks base method.

func (*MockNatsManager) CreateVersionKeyValueStores 

func (m *MockNatsManager) CreateVersionKeyValueStores(productID, versionTag string, workflows []entity.Workflow) (*entity.VersionKeyValueStores, error)

CreateVersionKeyValueStores mocks base method.

func (*MockNatsManager) DeleteGlobalKeyValueStore 

func (m *MockNatsManager) DeleteGlobalKeyValueStore(productID string) error

DeleteGlobalKeyValueStore mocks base method.

func (*MockNatsManager) DeleteObjectStores 

func (m *MockNatsManager) DeleteObjectStores(productID, versionTag string) error

DeleteObjectStores mocks base method.

func (*MockNatsManager) DeleteStreams 

func (m *MockNatsManager) DeleteStreams(productID, versionTag string) error

DeleteStreams mocks base method.

func (*MockNatsManager) DeleteVersionKeyValueStores 

func (m *MockNatsManager) DeleteVersionKeyValueStores(productID, versionTag string, workflows []entity.Workflow) error

DeleteVersionKeyValueStores mocks base method.

func (*MockNatsManager) EXPECT 

func (m *MockNatsManager) EXPECT() *MockNatsManagerMockRecorder

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

func (*MockNatsManager) UpdateKeyValueStoresConfiguration 

func (m *MockNatsManager) UpdateKeyValueStoresConfiguration(configurations []entity.KeyValueConfiguration) error

UpdateKeyValueStoresConfiguration mocks base method.

type MockNatsManagerMockRecorder 

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

MockNatsManagerMockRecorder is the mock recorder for MockNatsManager.

func (*MockNatsManagerMockRecorder) CreateGlobalKeyValueStore 

func (mr *MockNatsManagerMockRecorder) CreateGlobalKeyValueStore(productID interface{}) *gomock.Call

CreateGlobalKeyValueStore indicates an expected call of CreateGlobalKeyValueStore.

func (*MockNatsManagerMockRecorder) CreateObjectStores 

func (mr *MockNatsManagerMockRecorder) CreateObjectStores(productID, versionTag, workflows interface{}) *gomock.Call

CreateObjectStores indicates an expected call of CreateObjectStores.

func (*MockNatsManagerMockRecorder) CreateStreams 

func (mr *MockNatsManagerMockRecorder) CreateStreams(productID, versionTag, workflows interface{}) *gomock.Call

CreateStreams indicates an expected call of CreateStreams.

func (*MockNatsManagerMockRecorder) CreateVersionKeyValueStores 

func (mr *MockNatsManagerMockRecorder) CreateVersionKeyValueStores(productID, versionTag, workflows interface{}) *gomock.Call

CreateVersionKeyValueStores indicates an expected call of CreateVersionKeyValueStores.

func (*MockNatsManagerMockRecorder) DeleteGlobalKeyValueStore 

func (mr *MockNatsManagerMockRecorder) DeleteGlobalKeyValueStore(productID interface{}) *gomock.Call

DeleteGlobalKeyValueStore indicates an expected call of DeleteGlobalKeyValueStore.

func (*MockNatsManagerMockRecorder) DeleteObjectStores 

func (mr *MockNatsManagerMockRecorder) DeleteObjectStores(productID, versionTag interface{}) *gomock.Call

DeleteObjectStores indicates an expected call of DeleteObjectStores.

func (*MockNatsManagerMockRecorder) DeleteStreams 

func (mr *MockNatsManagerMockRecorder) DeleteStreams(productID, versionTag interface{}) *gomock.Call

DeleteStreams indicates an expected call of DeleteStreams.

func (*MockNatsManagerMockRecorder) DeleteVersionKeyValueStores 

func (mr *MockNatsManagerMockRecorder) DeleteVersionKeyValueStores(productID, versionTag, workflows interface{}) *gomock.Call

DeleteVersionKeyValueStores indicates an expected call of DeleteVersionKeyValueStores.

func (*MockNatsManagerMockRecorder) UpdateKeyValueStoresConfiguration 

func (mr *MockNatsManagerMockRecorder) UpdateKeyValueStoresConfiguration(configurations interface{}) *gomock.Call

UpdateKeyValueStoresConfiguration indicates an expected call of UpdateKeyValueStoresConfiguration.

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.