sql

Documentation

Index

• Constants
• Variables
• func NewQueueV2(db sqlplugin.DB, logger log.Logger) persistence.QueueV2
• func NewSQLAdminDB(dbKind sqlplugin.DbKind, cfg *config.SQL, r resolver.ServiceResolver) (sqlplugin.AdminDB, error)
• func NewSQLDB(dbKind sqlplugin.DbKind, cfg *config.SQL, r resolver.ServiceResolver) (sqlplugin.DB, error)
• func NewSQLExecutionStore(db sqlplugin.DB, logger log.Logger) (p.ExecutionStore, error)
• func NewSqlNexusIncomingServiceStore(db sqlplugin.DB, logger log.Logger) (p.NexusIncomingServiceStore, error)
• func RegisterPlugin(pluginName string, plugin sqlplugin.Plugin)
• func VerifyCompatibleVersion(cfg config.Persistence, r resolver.ServiceResolver) error
• type DbConn
  • func NewRefCountedDBConn(dbKind sqlplugin.DbKind, cfg *config.SQL, r resolver.ServiceResolver) DbConn
  • func (c *DbConn) Close() error
  • func (c *DbConn) ForceClose()
  • func (c *DbConn) Get() (sqlplugin.DB, error)
• type Factory
  • func NewFactory(cfg config.SQL, r resolver.ServiceResolver, clusterName string, ...) *Factory
  • func (f *Factory) Close()
  • func (f *Factory) GetDB() (sqlplugin.DB, error)
  • func (f *Factory) NewClusterMetadataStore() (p.ClusterMetadataStore, error)
  • func (f *Factory) NewExecutionStore() (p.ExecutionStore, error)
  • func (f *Factory) NewMetadataStore() (p.MetadataStore, error)
  • func (f *Factory) NewNexusIncomingServiceStore() (p.NexusIncomingServiceStore, error)
  • func (f *Factory) NewQueue(queueType p.QueueType) (p.Queue, error)
  • func (f *Factory) NewQueueV2() (p.QueueV2, error)
  • func (f *Factory) NewShardStore() (p.ShardStore, error)
  • func (f *Factory) NewTaskStore() (p.TaskStore, error)
• type QueueV2Metadata
• type SqlStore
  • func NewSqlStore(db sqlplugin.DB, logger log.Logger) SqlStore
  • func (m *SqlStore) Close()
  • func (m *SqlStore) GetDbName() string
  • func (m *SqlStore) GetName() string
• type TestCluster
  • func NewTestCluster(pluginName string, dbName string, username string, password string, ...) *TestCluster
  • func (s *TestCluster) Config() config.Persistence
  • func (s *TestCluster) CreateDatabase()
  • func (s *TestCluster) DatabaseName() string
  • func (s *TestCluster) DropDatabase()
  • func (s *TestCluster) LoadSchema(schemaFile string)
  • func (s *TestCluster) SetupTestDatabase()
  • func (s *TestCluster) TearDownTestDatabase()

Constants

const (
	// NOTE: transaction ID is *= -1 in DB
	MinTxnID int64 = math.MaxInt64
	MaxTxnID int64 = math.MinInt64 + 1 // int overflow
)

Variables

var ErrPluginNotSupported = errors.New("plugin not supported")

Functions

func NewQueueV2

func NewQueueV2(db sqlplugin.DB,
	logger log.Logger,
) persistence.QueueV2

NewQueueV2 returns an implementation of persistence.QueueV2.

func NewSQLAdminDB

func NewSQLAdminDB(
	dbKind sqlplugin.DbKind,
	cfg *config.SQL,
	r resolver.ServiceResolver,
) (sqlplugin.AdminDB, error)

NewSQLAdminDB returns a AdminDB

func NewSQLDB

func NewSQLDB(
	dbKind sqlplugin.DbKind,
	cfg *config.SQL,
	r resolver.ServiceResolver,
) (sqlplugin.DB, error)

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

NewSQLExecutionStore creates an instance of ExecutionStore

func NewSqlNexusIncomingServiceStore

func NewSqlNexusIncomingServiceStore(
	db sqlplugin.DB,
	logger log.Logger,
) (p.NexusIncomingServiceStore, error)

func RegisterPlugin

func RegisterPlugin(pluginName string, plugin sqlplugin.Plugin)

RegisterPlugin will register a SQL plugin

func VerifyCompatibleVersion

func VerifyCompatibleVersion(
	cfg config.Persistence,
	r resolver.ServiceResolver,
) error

VerifyCompatibleVersion ensures that the installed version of temporal and visibility is greater than or equal to the expected version.

Types

type DbConn

type DbConn struct {
	sqlplugin.DB

	sync.Mutex
	// contains filtered or unexported fields
}

DbConn represents a logical mysql connection - its a wrapper around the standard sql connection pool with additional reference counting

func NewRefCountedDBConn

func NewRefCountedDBConn(
	dbKind sqlplugin.DbKind,
	cfg *config.SQL,
	r resolver.ServiceResolver,
) DbConn

NewRefCountedDBConn returns a logical mysql connection that uses reference counting to decide when to close the underlying connection object. The reference count gets incremented everytime get() is called and decremented everytime Close() is called

func (*DbConn) Close

func (c *DbConn) Close() error

Close closes the underlying connection if the reference count becomes zero

func (*DbConn) ForceClose

func (c *DbConn) ForceClose()

ForceClose ignores reference counts and shutsdown the underlying connection pool

func (*DbConn) Get

func (c *DbConn) Get() (sqlplugin.DB, error)

Get returns a mysql db connection and increments a reference count this method will create a new connection, if an existing connection does not exist

type Factory

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

Factory vends store objects backed by MySQL

func NewFactory

func NewFactory(
	cfg config.SQL,
	r resolver.ServiceResolver,
	clusterName string,
	logger log.Logger,
) *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) Close

func (f *Factory) Close()

Close closes the factory

func (*Factory) GetDB

func (f *Factory) GetDB() (sqlplugin.DB, error)

GetDB return a new SQL DB connection

func (*Factory) NewClusterMetadataStore

func (f *Factory) NewClusterMetadataStore() (p.ClusterMetadataStore, error)

NewClusterMetadataStore returns a new ClusterMetadata store

func (*Factory) NewExecutionStore

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

NewExecutionStore returns a new ExecutionStore

func (*Factory) NewMetadataStore

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

NewMetadataStore returns a new metadata store

func (*Factory) NewNexusIncomingServiceStore

func (f *Factory) NewNexusIncomingServiceStore() (p.NexusIncomingServiceStore, error)

NewNexusIncomingServiceStore returns a new NexusIncomingServiceStore

func (*Factory) NewQueue

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

NewQueue returns a new queue backed by sql

func (*Factory) NewQueueV2

func (f *Factory) NewQueueV2() (p.QueueV2, error)

NewQueueV2 returns a new data-access object for queues and messages.

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

type QueueV2Metadata

type QueueV2Metadata struct {
	Metadata *persistencespb.Queue
	Version  int64
}

type SqlStore

type SqlStore struct {
	Db sqlplugin.DB
	// contains filtered or unexported fields
}

TODO: Rename all SQL Managers to Stores

func NewSqlStore

func NewSqlStore(db sqlplugin.DB, logger log.Logger) SqlStore

func (*SqlStore) Close

func (m *SqlStore) Close()

func (*SqlStore) GetDbName

func (m *SqlStore) GetDbName() string

func (*SqlStore) GetName

func (m *SqlStore) GetName() string

type TestCluster

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

TestCluster allows executing cassandra operations in testing.

func NewTestCluster

func NewTestCluster(
	pluginName string,
	dbName string,
	username string,
	password string,
	host string,
	port int,
	connectAttributes map[string]string,
	schemaDir string,
	faultInjection *config.FaultInjection,
	logger log.Logger,
) *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) 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(schemaFile string)

LoadSchema 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