nosql

package
v1.2.13-prerelease07 Latest Latest
Warning

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

 Go to latest Published: Aug 27, 2024 License: MIT Imports: 22 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 NewExecutionStore 

func NewExecutionStore(
	shardID int,
	db nosqlplugin.DB,
	logger log.Logger,
) (persistence.ExecutionStore, error)

NewExecutionStore is used to create an instance of ExecutionStore implementation

func NewNoSQLAdminDB 

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

NewNoSQLAdminDB returns a AdminDB

func NewNoSQLConfigStore 

func NewNoSQLConfigStore(
	cfg config.ShardedNoSQL,
	logger log.Logger,
	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 NewTestCluster 

func NewTestCluster(t *testing.T, params TestClusterParams) testcluster.PersistenceTestCluster

NewTestCluster returns a new cassandra test cluster if schemaBaseDir is empty, it will be auto-resolved based on os.Getwd() otherwise the specified value will be used (used by internal tests)

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 {
	sync.RWMutex
	// contains filtered or unexported fields
}

Factory vends datastore implementations backed by cassandra

func NewFactory 

func NewFactory(cfg config.ShardedNoSQL, clusterName string, logger log.Logger, 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

func (*Factory) NewConfigStore 

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

NewConfigStore returns a new config 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(shardID int) (persistence.ExecutionStore, error)

NewExecutionStore returns an ExecutionStore for a given shardID

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.Queue, error)

NewQueue returns a new queue backed by cassandra

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) 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) 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 interface{}) *gomock.Call

GetStoreShardByHistoryShard indicates an expected call of GetStoreShardByHistoryShard.

func (*MockshardedNosqlStoreMockRecorder) GetStoreShardByTaskList added in v1.2.9 

func (mr *MockshardedNosqlStoreMockRecorder) GetStoreShardByTaskList(domainID, taskListName, taskType interface{}) *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

type TestClusterParams added in v1.2.7 

type TestClusterParams struct {
	PluginName    string
	KeySpace      string
	Username      string
	Password      string
	Host          string
	Port          int
	ProtoVersion  int
	SchemaBaseDir string
	// Replicas defaults to 1 if not set
	Replicas int
	// MaxConns defaults to 2 if not set
	MaxConns int
}

TestClusterParams are params for test cluster initialization.

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
cassandra/tests
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.