nosql

package
v1.4.2 Latest Latest
Warning

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

 Go to latest Published: Sep 10, 2026 License: Apache-2.0 Imports: 23 Imported by: 0

Documentation

Overview

Package nosql is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GetRegisteredPluginNames 

func GetRegisteredPluginNames() []string

GetRegisteredPluginNames returns the list of registered plugin names

func NewNoSQLConfigStore 

func NewNoSQLConfigStore(
	cfg config.ShardedNoSQL,
	logger log.Logger,
	metricsClient metrics.Client,
	dc *persistence.DynamicConfiguration,
) (persistence.ConfigStore, error)

func NewNoSQLDB 

func NewNoSQLDB(cfg *config.NoSQL, logger log.Logger, dc *persistence.DynamicConfiguration) (nosqlplugin.DB, error)

NewNoSQLDB creates a returns a reference to a logical connection to the underlying NoSQL database. The returned object is to tied to a single NoSQL database and the object can be used to perform CRUD operations on the tables in the database

func PluginRegistered 

func PluginRegistered(pluginName string) bool

PluginRegistered returns true if plugin with given name has been registered, false otherwise

func RegisterPlugin 

func RegisterPlugin(pluginName string, plugin nosqlplugin.Plugin)

RegisterPlugin will register a NoSQL plugin

func RegisterPluginForTest added in v1.2.10 

func RegisterPluginForTest(t *testing.T, pluginName string, plugin nosqlplugin.Plugin)

RegisterPluginForTest should be used only in tests to register the DB plugin and de-register at the end

func RegisterPluginIfNotExists 

func RegisterPluginIfNotExists(pluginName string, plugin nosqlplugin.Plugin)

RegisterPluginIfNotExists will register a NoSQL plugin only if a plugin with same name has not already been registered

Types

type Factory 

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

Factory vends datastore implementations backed by cassandra

func NewFactory 

func NewFactory(cfg config.ShardedNoSQL, clusterName string, logger log.Logger, metricsClient metrics.Client, taskSerializer serialization.TaskSerializer, parser serialization.Parser, dc *persistence.DynamicConfiguration) *Factory

NewFactory returns an instance of a factory object which can be used to create datastores that are backed by cassandra

func (*Factory) Close 

func (f *Factory) Close()

Close closes the factory. Store Close methods own connection lifecycle (matching HistoryStore), so this is intentionally a no-op.

func (*Factory) NewAdminDBs 

func (f *Factory) NewAdminDBs(dbType persistence.DBType) ([]persistence.AdminDB, error)

func (*Factory) NewConfigStore 

func (f *Factory) NewConfigStore() (persistence.ConfigStore, error)

NewConfigStore returns a new config store

func (*Factory) NewDomainAuditStore added in v1.4.0 

func (f *Factory) NewDomainAuditStore() (persistence.DomainAuditStore, error)

NewDomainAuditStore returns a domain audit store

func (*Factory) NewDomainStore 

func (f *Factory) NewDomainStore() (persistence.DomainStore, error)

NewDomainStore returns a metadata store that understands only v2

func (*Factory) NewExecutionStore 

func (f *Factory) NewExecutionStore() (persistence.ExecutionStore, error)

NewExecutionStore returns an ExecutionStore

func (*Factory) NewHistoryDLQTaskStore added in v1.4.1 

func (f *Factory) NewHistoryDLQTaskStore() (persistence.HistoryDLQTaskStore, error)

NewHistoryDLQTaskStore returns a history DLQ task store

func (*Factory) NewHistoryStore 

func (f *Factory) NewHistoryStore() (persistence.HistoryStore, error)

NewHistoryStore returns a new history store

func (*Factory) NewQueue 

func (f *Factory) NewQueue(queueType persistence.QueueType) (persistence.QueueStore, error)

NewQueue returns a new queue backed by cassandra

func (*Factory) NewSemaphoreMetadataStore 

func (f *Factory) NewSemaphoreMetadataStore() (persistence.SemaphoreMetadataStore, error)

NewSemaphoreMetadataStore returns a semaphore metadata store

func (*Factory) NewSemaphoreTaskStore 

func (f *Factory) NewSemaphoreTaskStore() (persistence.SemaphoreTaskStore, error)

NewSemaphoreTaskStore returns a semaphore task (task queue) store

func (*Factory) NewSemaphoreTokenStore 

func (f *Factory) NewSemaphoreTokenStore() (persistence.SemaphoreTokenStore, error)

NewSemaphoreTokenStore returns a semaphore token store

func (*Factory) NewShardStore 

func (f *Factory) NewShardStore() (persistence.ShardStore, error)

NewShardStore returns a new shard store

func (*Factory) NewTaskStore 

func (f *Factory) NewTaskStore() (persistence.TaskStore, error)

NewTaskStore returns a new task store

func (*Factory) NewVisibilityStore 

func (f *Factory) NewVisibilityStore(sortByCloseTime bool) (persistence.VisibilityStore, error)

NewVisibilityStore returns a visibility store

type MockshardedNosqlStore added in v1.2.9 

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

MockshardedNosqlStore is a mock of shardedNosqlStore interface.

func NewMockshardedNosqlStore added in v1.2.9 

func NewMockshardedNosqlStore(ctrl *gomock.Controller) *MockshardedNosqlStore

NewMockshardedNosqlStore creates a new mock instance.

func (*MockshardedNosqlStore) Close added in v1.2.9 

func (m *MockshardedNosqlStore) Close()

Close mocks base method.

func (*MockshardedNosqlStore) EXPECT added in v1.2.9 

func (m *MockshardedNosqlStore) EXPECT() *MockshardedNosqlStoreMockRecorder

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

func (*MockshardedNosqlStore) GetDefaultShard added in v1.2.9 

func (m *MockshardedNosqlStore) GetDefaultShard() nosqlStore

GetDefaultShard mocks base method.

func (*MockshardedNosqlStore) GetLogger added in v1.2.9 

func (m *MockshardedNosqlStore) GetLogger() log.Logger

GetLogger mocks base method.

func (*MockshardedNosqlStore) GetMetricsClient added in v1.3.1 

func (m *MockshardedNosqlStore) GetMetricsClient() metrics.Client

GetMetricsClient mocks base method.

func (*MockshardedNosqlStore) GetName added in v1.2.9 

func (m *MockshardedNosqlStore) GetName() string

GetName mocks base method.

func (*MockshardedNosqlStore) GetShardingPolicy added in v1.2.9 

func (m *MockshardedNosqlStore) GetShardingPolicy() shardingPolicy

GetShardingPolicy mocks base method.

func (*MockshardedNosqlStore) GetStoreShardByHistoryShard added in v1.2.9 

func (m *MockshardedNosqlStore) GetStoreShardByHistoryShard(shardID int) (*nosqlStore, error)

GetStoreShardByHistoryShard mocks base method.

func (*MockshardedNosqlStore) GetStoreShardByTaskList added in v1.2.9 

func (m *MockshardedNosqlStore) GetStoreShardByTaskList(domainID, taskListName string, taskType int) (*nosqlStore, error)

GetStoreShardByTaskList mocks base method.

type MockshardedNosqlStoreMockRecorder added in v1.2.9 

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

MockshardedNosqlStoreMockRecorder is the mock recorder for MockshardedNosqlStore.

func (*MockshardedNosqlStoreMockRecorder) Close added in v1.2.9 

func (mr *MockshardedNosqlStoreMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockshardedNosqlStoreMockRecorder) GetDefaultShard added in v1.2.9 

func (mr *MockshardedNosqlStoreMockRecorder) GetDefaultShard() *gomock.Call

GetDefaultShard indicates an expected call of GetDefaultShard.

func (*MockshardedNosqlStoreMockRecorder) GetLogger added in v1.2.9 

func (mr *MockshardedNosqlStoreMockRecorder) GetLogger() *gomock.Call

GetLogger indicates an expected call of GetLogger.

func (*MockshardedNosqlStoreMockRecorder) GetMetricsClient added in v1.3.1 

func (mr *MockshardedNosqlStoreMockRecorder) GetMetricsClient() *gomock.Call

GetMetricsClient indicates an expected call of GetMetricsClient.

func (*MockshardedNosqlStoreMockRecorder) GetName added in v1.2.9 

func (mr *MockshardedNosqlStoreMockRecorder) GetName() *gomock.Call

GetName indicates an expected call of GetName.

func (*MockshardedNosqlStoreMockRecorder) GetShardingPolicy added in v1.2.9 

func (mr *MockshardedNosqlStoreMockRecorder) GetShardingPolicy() *gomock.Call

GetShardingPolicy indicates an expected call of GetShardingPolicy.

func (*MockshardedNosqlStoreMockRecorder) GetStoreShardByHistoryShard added in v1.2.9 

func (mr *MockshardedNosqlStoreMockRecorder) GetStoreShardByHistoryShard(shardID any) *gomock.Call

GetStoreShardByHistoryShard indicates an expected call of GetStoreShardByHistoryShard.

func (*MockshardedNosqlStoreMockRecorder) GetStoreShardByTaskList added in v1.2.9 

func (mr *MockshardedNosqlStoreMockRecorder) GetStoreShardByTaskList(domainID, taskListName, taskType any) *gomock.Call

GetStoreShardByTaskList indicates an expected call of GetStoreShardByTaskList.

type ShardingError added in v1.2.1 

type ShardingError struct {
	Message string
}

ShardingError represents invalid shard

func (*ShardingError) Error added in v1.2.1 

func (e *ShardingError) Error() string

Source Files

View all Source files

Directories

Path Synopsis
Package nosqlplugin is a generated GoMock package.
 Package nosqlplugin is a generated GoMock package.
cassandra
cassandra/gocql
Package gocql is a generated GoMock package.
 Package gocql is a generated GoMock package.
cassandra/gocql/public
dynamodb
mongodb

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.