nosql

Documentation

Index

• func GetRegisteredPluginNames() []string
• func NewExecutionStore(shardID int, db nosqlplugin.DB, logger log.Logger) (p.ExecutionStore, error)
• func NewNoSQLAdminDB(cfg *config.NoSQL, logger log.Logger, dc *p.DynamicConfiguration) (nosqlplugin.AdminDB, error)
• func NewNoSQLConfigStore(cfg config.ShardedNoSQL, logger log.Logger, ...) (persistence.ConfigStore, error)
• func NewNoSQLDB(cfg *config.NoSQL, logger log.Logger, dc *p.DynamicConfiguration) (nosqlplugin.DB, error)
• func NewTestCluster(pluginName, keyspace, username, password, host string, port, protoVersion int, ...) testcluster.PersistenceTestCluster
• func PluginRegistered(pluginName string) bool
• func RegisterPlugin(pluginName string, plugin nosqlplugin.Plugin)
• func RegisterPluginIfNotExists(pluginName string, plugin nosqlplugin.Plugin)
• type Factory
  • func NewFactory(cfg config.ShardedNoSQL, clusterName string, logger log.Logger, ...) *Factory
  • func (f *Factory) Close()
  • func (f *Factory) NewConfigStore() (p.ConfigStore, error)
  • func (f *Factory) NewDomainStore() (p.DomainStore, error)
  • func (f *Factory) NewExecutionStore(shardID int) (p.ExecutionStore, error)
  • func (f *Factory) NewHistoryStore() (p.HistoryStore, error)
  • func (f *Factory) NewQueue(queueType p.QueueType) (p.Queue, error)
  • func (f *Factory) NewShardStore() (p.ShardStore, error)
  • func (f *Factory) NewTaskStore() (p.TaskStore, error)
  • func (f *Factory) NewVisibilityStore(sortByCloseTime bool) (p.VisibilityStore, error)
• type ShardingError
  • func (e *ShardingError) Error() string

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,
) (p.ExecutionStore, error)

NewExecutionStore is used to create an instance of ExecutionStore implementation

func NewNoSQLAdminDB

func NewNoSQLAdminDB(cfg *config.NoSQL, logger log.Logger, dc *p.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 *p.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(
	pluginName, keyspace, username, password, host string,
	port, protoVersion int,
	schemaBaseDir string,
) 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 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 *p.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() (p.ConfigStore, error)

NewConfigStore returns a new config store

func (*Factory) NewDomainStore

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

NewDomainStore returns a metadata store that understands only v2

func (*Factory) NewExecutionStore

func (f *Factory) NewExecutionStore(shardID int) (p.ExecutionStore, error)

NewExecutionStore returns an ExecutionStore for a given shardID

func (*Factory) NewHistoryStore

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

NewHistoryStore returns a new history store

func (*Factory) NewQueue

func (f *Factory) NewQueue(queueType p.QueueType) (p.Queue, error)

NewQueue returns a new queue backed by cassandra

func (*Factory) NewShardStore

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

NewShardStore returns a new shard store

func (*Factory) NewTaskStore

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

NewTaskStore returns a new task store

func (*Factory) NewVisibilityStore

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

NewVisibilityStore returns a visibility store

type ShardingError

type ShardingError struct {
	Message string
}

ShardingError represents invalid shard

func (*ShardingError) Error

func (e *ShardingError) Error() string