cassandra

Documentation

Index

• func CreateCassandraKeyspace(s gocql.Session, keyspace string, replicas int, overwrite bool) (err error)
• func DropCassandraKeyspace(s gocql.Session, keyspace string) (err error)
• func NewHistoryV2PersistenceFromSession(client gocql.Client, session gocql.Session, logger log.Logger) p.HistoryStore
• func NewShardPersistenceFromSession(client gocql.Client, session gocql.Session, clusterName string, ...) p.ShardStore
• func NewWorkflowExecutionPersistence(shardID int, client gocql.Client, session gocql.Session, logger log.Logger) (p.ExecutionStore, error)
• type Factory
  • func NewFactory(cfg config.Cassandra, clusterName string, logger log.Logger) *Factory
  • func (f *Factory) Close()
  • func (f *Factory) NewExecutionStore(shardID int) (p.ExecutionStore, error)
  • func (f *Factory) NewHistoryV2Store() (p.HistoryStore, error)
  • func (f *Factory) NewMetadataStore() (p.MetadataStore, 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 TestCluster
  • func NewTestCluster(keyspace, username, password, host string, port int, schemaDir string) *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()

Functions

func CreateCassandraKeyspace

func CreateCassandraKeyspace(s gocql.Session, keyspace string, replicas int, overwrite bool) (err error)

CreateCassandraKeyspace creates the keyspace using this session for given replica count

func DropCassandraKeyspace

func DropCassandraKeyspace(s gocql.Session, keyspace string) (err error)

DropCassandraKeyspace drops the given keyspace, if it exists

func NewHistoryV2PersistenceFromSession

func NewHistoryV2PersistenceFromSession(
	client gocql.Client,
	session gocql.Session,
	logger log.Logger,
) p.HistoryStore

NewHistoryV2PersistenceFromSession returns new HistoryStore

func NewShardPersistenceFromSession

func NewShardPersistenceFromSession(
	client gocql.Client,
	session gocql.Session,
	clusterName string,
	logger log.Logger,
) p.ShardStore

NewShardPersistenceFromSession is used to create an instance of ShardManager implementation It is being used by some admin toolings

func NewWorkflowExecutionPersistence

func NewWorkflowExecutionPersistence(
	shardID int,
	client gocql.Client,
	session gocql.Session,
	logger log.Logger,
) (p.ExecutionStore, error)

NewWorkflowExecutionPersistence is used to create an instance of workflowExecutionManager implementation

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.Cassandra, clusterName string, logger log.Logger) *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) NewExecutionStore

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

NewExecutionStore returns an ExecutionStore for a given shardID

func (*Factory) NewHistoryV2Store

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

NewHistoryV2Store returns a new history store

func (*Factory) NewMetadataStore

func (f *Factory) NewMetadataStore() (p.MetadataStore, error)

NewMetadataStore returns a metadata store that understands only v2

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 TestCluster

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

TestCluster allows executing cassandra operations in testing.

func NewTestCluster

func NewTestCluster(keyspace, username, password, host string, port int, schemaDir string) *TestCluster

NewTestCluster returns a new cassandra 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