Documentation
¶
Index ¶
- Constants
- func NewSQLExecutionStore(db sqldb.Interface, logger log.Logger, shardID int) (p.ExecutionStore, error)
- func NewSQLVisibilityStore(cfg config.SQL, logger log.Logger) (p.VisibilityStore, error)
- type Factory
- func (f *Factory) Close()
- func (f *Factory) NewExecutionStore(shardID int) (p.ExecutionStore, error)
- func (f *Factory) NewHistoryStore() (p.HistoryStore, error)
- func (f *Factory) NewHistoryV2Store() (p.HistoryV2Store, error)
- func (f *Factory) NewMetadataStore() (p.MetadataStore, error)
- func (f *Factory) NewMetadataStoreV1() (p.MetadataStore, error)
- func (f *Factory) NewMetadataStoreV2() (p.MetadataStore, error)
- func (f *Factory) NewShardStore() (p.ShardStore, error)
- func (f *Factory) NewTaskStore() (p.TaskStore, error)
- func (f *Factory) NewVisibilityStore() (p.VisibilityStore, error)
- type TestCluster
- func (s *TestCluster) Config() config.Persistence
- func (s *TestCluster) CreateDatabase()
- func (s *TestCluster) CreateSession()
- func (s *TestCluster) DatabaseName() string
- func (s *TestCluster) DropDatabase()
- func (s *TestCluster) LoadSchema(fileNames []string, schemaDir string)
- func (s *TestCluster) LoadVisibilitySchema(fileNames []string, schemaDir string)
- func (s *TestCluster) SetupTestDatabase()
- func (s *TestCluster) TearDownTestDatabase()
Constants ¶
const ErrDupEntry = 1062
ErrDupEntry MySQL Error 1062 indicates a duplicate primary key i.e. the row already exists, so we don't do the insert and return a ConditionalUpdate error.
Variables ¶
This section is empty.
Functions ¶
func NewSQLExecutionStore ¶ added in v0.5.0
func NewSQLExecutionStore(db sqldb.Interface, logger log.Logger, shardID int) (p.ExecutionStore, error)
NewSQLExecutionStore creates an instance of ExecutionStore
func NewSQLVisibilityStore ¶ added in v0.5.0
NewSQLVisibilityStore creates an instance of ExecutionStore
Types ¶
type Factory ¶
type Factory struct {
// contains filtered or unexported fields
}
Factory vends store objects backed by MySQL
func NewFactory ¶
NewFactory returns an instance of a factory object which can be used to create datastores backed by any kind of SQL 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) NewHistoryV2Store ¶ added in v0.5.0
func (f *Factory) NewHistoryV2Store() (p.HistoryV2Store, error)
NewHistoryV2Store returns a new history store
func (*Factory) NewMetadataStore ¶
func (f *Factory) NewMetadataStore() (p.MetadataStore, error)
NewMetadataStore returns a new metadata store
func (*Factory) NewMetadataStoreV1 ¶
func (f *Factory) NewMetadataStoreV1() (p.MetadataStore, error)
NewMetadataStoreV1 returns the default metadatastore
func (*Factory) NewMetadataStoreV2 ¶
func (f *Factory) NewMetadataStoreV2() (p.MetadataStore, error)
NewMetadataStoreV2 returns the default metadatastore
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() (p.VisibilityStore, error)
NewVisibilityStore returns a visibility store
type TestCluster ¶
type TestCluster struct {
// contains filtered or unexported fields
}
TestCluster allows executing cassandra operations in testing.
func NewTestCluster ¶
func NewTestCluster(dbName string, port int, schemaDir string) *TestCluster
NewTestCluster returns a new SQL test cluster
func (*TestCluster) Config ¶
func (s *TestCluster) Config() config.Persistence
Config returns the persistence config for connecting to this test cluster
func (*TestCluster) CreateDatabase ¶
func (s *TestCluster) CreateDatabase()
CreateDatabase from PersistenceTestCluster interface
func (*TestCluster) CreateSession ¶
func (s *TestCluster) CreateSession()
CreateSession from PersistenceTestCluster interface
func (*TestCluster) DatabaseName ¶
func (s *TestCluster) DatabaseName() string
DatabaseName from PersistenceTestCluster interface
func (*TestCluster) DropDatabase ¶
func (s *TestCluster) DropDatabase()
DropDatabase from PersistenceTestCluster interface
func (*TestCluster) LoadSchema ¶
func (s *TestCluster) LoadSchema(fileNames []string, schemaDir string)
LoadSchema from PersistenceTestCluster interface
func (*TestCluster) LoadVisibilitySchema ¶
func (s *TestCluster) LoadVisibilitySchema(fileNames []string, schemaDir string)
LoadVisibilitySchema from PersistenceTestCluster interface
func (*TestCluster) SetupTestDatabase ¶
func (s *TestCluster) SetupTestDatabase()
SetupTestDatabase from PersistenceTestCluster interface
func (*TestCluster) TearDownTestDatabase ¶
func (s *TestCluster) TearDownTestDatabase()
TearDownTestDatabase from PersistenceTestCluster interface
Source Files
Directories