Documentation
¶
Index ¶
- func GetRegisteredPluginNames() []string
- func NewHistoryV2Persistence(db sqlplugin.DB, logger log.Logger, parser serialization.Parser, ...) (persistence.HistoryStore, error)
- func NewSQLAdminDB(cfg *config.SQL) (sqlplugin.AdminDB, error)
- func NewSQLConfigStore(db sqlplugin.DB, logger log.Logger, parser serialization.Parser) (persistence.ConfigStore, error)
- func NewSQLDB(cfg *config.SQL) (sqlplugin.DB, error)
- func NewSQLExecutionStore(db sqlplugin.DB, logger log.Logger, shardID int, parser serialization.Parser, ...) (p.ExecutionStore, error)
- func NewSQLVisibilityStore(cfg config.SQL, logger log.Logger) (p.VisibilityStore, error)
- func NewShardPersistence(db sqlplugin.DB, currentClusterName string, log log.Logger, ...) (persistence.ShardStore, error)
- func NewTestCluster(pluginName, dbName, username, password, host string, port int, ...) (testcluster.PersistenceTestCluster, error)
- func PluginRegistered(pluginName string) bool
- func RegisterPlugin(pluginName string, plugin sqlplugin.Plugin)
- func RegisterPluginIfNotExists(pluginName string, plugin sqlplugin.Plugin)
- type Factory
- func (f *Factory) Close()
- func (f *Factory) NewConfigStore() (p.ConfigStore, error)
- func (f *Factory) NewDomainAuditStore() (p.DomainAuditStore, 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.QueueStore, error)
- func (f *Factory) NewShardStore() (p.ShardStore, error)
- func (f *Factory) NewTaskStore() (p.TaskStore, error)
- func (f *Factory) NewVisibilityStore(sortByCloseTime bool) (p.VisibilityStore, error)
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 NewHistoryV2Persistence ¶
func NewHistoryV2Persistence( db sqlplugin.DB, logger log.Logger, parser serialization.Parser, dc *persistence.DynamicConfiguration, ) (persistence.HistoryStore, error)
NewHistoryV2Persistence creates an instance of HistoryManager
func NewSQLAdminDB ¶
NewSQLAdminDB returns a AdminDB
func NewSQLConfigStore ¶
func NewSQLConfigStore( db sqlplugin.DB, logger log.Logger, parser serialization.Parser, ) (persistence.ConfigStore, error)
NewSQLConfigStore creates a config store for SQL
func NewSQLDB ¶
NewSQLDB creates a returns a reference to a logical connection to the underlying SQL database. The returned object is to tied to a single SQL database and the object can be used to perform CRUD operations on the tables in the database
func NewSQLExecutionStore ¶
func NewSQLExecutionStore( db sqlplugin.DB, logger log.Logger, shardID int, parser serialization.Parser, taskSerializer serialization.TaskSerializer, dc *p.DynamicConfiguration, ) (p.ExecutionStore, error)
NewSQLExecutionStore creates an instance of ExecutionStore
func NewSQLVisibilityStore ¶
NewSQLVisibilityStore creates an instance of ExecutionStore
func NewShardPersistence ¶
func NewShardPersistence( db sqlplugin.DB, currentClusterName string, log log.Logger, parser serialization.Parser, ) (persistence.ShardStore, error)
NewShardPersistence creates an instance of ShardStore
func NewTestCluster ¶
func NewTestCluster(pluginName, dbName, username, password, host string, port int, schemaDir string) (testcluster.PersistenceTestCluster, error)
NewTestCluster returns a new SQL test cluster
func PluginRegistered ¶
PluginRegistered returns true if plugin with given name has been registered, false otherwise
func RegisterPlugin ¶
RegisterPlugin will register a SQL plugin
func RegisterPluginIfNotExists ¶
RegisterPluginIfNotExists will register a SQL 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 store objects backed by MySQL
func NewFactory ¶
func NewFactory( cfg config.SQL, clusterName string, logger log.Logger, parser serialization.Parser, dc *p.DynamicConfiguration, ) *Factory
NewFactory returns an instance of a factory object which can be used to create datastores backed by any kind of SQL store
func (*Factory) NewConfigStore ¶
func (f *Factory) NewConfigStore() (p.ConfigStore, error)
NewConfigStore returns a new config store backed by sql. Not Yet Implemented.
func (*Factory) NewDomainAuditStore ¶
func (f *Factory) NewDomainAuditStore() (p.DomainAuditStore, error)
NewDomainAuditStore returns a domain audit store
func (*Factory) NewDomainStore ¶
func (f *Factory) NewDomainStore() (p.DomainStore, error)
NewDomainStore returns a new metadata store
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) NewShardStore ¶
func (f *Factory) NewShardStore() (p.ShardStore, error)
NewShardStore returns a new shard store
func (*Factory) NewTaskStore ¶
NewTaskStore returns a new task store
func (*Factory) NewVisibilityStore ¶
func (f *Factory) NewVisibilityStore(sortByCloseTime bool) (p.VisibilityStore, error)
NewVisibilityStore returns a visibility store TODO sortByCloseTime will be removed and implemented for https://github.com/cadence-workflow/shard-manager/issues/3621
Source Files
¶
- common.go
- factory.go
- plugin.go
- sql_config_store.go
- sql_domain_audit_store.go
- sql_domain_store.go
- sql_execution_store.go
- sql_execution_store_util.go
- sql_history_store.go
- sql_queue_store.go
- sql_shard_store.go
- sql_task_store.go
- sql_test_utils.go
- sql_visibility_store.go
- workflow_state_maps.go
- workflow_state_non_maps.go
Directories