mysql

func (*DB) BeginTx ¶ added in v1.2.17

func (mdb *DB) BeginTx(ctx context.Context, dbShardID int) (sqlplugin.Tx, error)

BeginTx starts a new transaction and returns a reference to the Tx object

func (*DB) Close ¶ added in v1.2.17

func (mdb *DB) Close() error

Close closes the connection to the mysql db

func (*DB) Commit ¶ added in v1.2.17

func (mdb *DB) Commit() error

Commit commits a previously started transaction

func (*DB) CreateDatabase ¶ added in v1.2.17

func (mdb *DB) CreateDatabase(name string) error

CreateDatabase creates a database if it doesn't exist

func (*DB) CreateSchemaVersionTables ¶ added in v1.2.17

func (mdb *DB) CreateSchemaVersionTables() error

CreateSchemaVersionTables sets up the schema version tables

func (*DB) DatabaseExists ¶

func (mdb *DB) DatabaseExists(name string) (bool, error)

func (*DB) DeleteFromActiveClusterSelectionPolicy ¶ added in v1.4.1

func (mdb *DB) DeleteFromActiveClusterSelectionPolicy(ctx context.Context, filter *sqlplugin.ActiveClusterSelectionPolicyFilter) (sql.Result, error)

func (*DB) DeleteFromActivityInfoMaps ¶ added in v1.2.17

func (mdb *DB) DeleteFromActivityInfoMaps(ctx context.Context, filter *sqlplugin.ActivityInfoMapsFilter) (sql.Result, error)

DeleteFromActivityInfoMaps deletes one or more rows from activity_info_maps table

func (*DB) DeleteFromBufferedEvents ¶ added in v1.2.17

func (mdb *DB) DeleteFromBufferedEvents(ctx context.Context, filter *sqlplugin.BufferedEventsFilter) (sql.Result, error)

DeleteFromBufferedEvents deletes one or more rows from buffered_events table

func (*DB) DeleteFromChildExecutionInfoMaps ¶ added in v1.2.17

func (mdb *DB) DeleteFromChildExecutionInfoMaps(ctx context.Context, filter *sqlplugin.ChildExecutionInfoMapsFilter) (sql.Result, error)

DeleteFromChildExecutionInfoMaps deletes one or more rows from child_execution_info_maps table

func (*DB) DeleteFromCrossClusterTasks ¶ added in v1.2.17

func (mdb *DB) DeleteFromCrossClusterTasks(ctx context.Context, filter *sqlplugin.CrossClusterTasksFilter) (sql.Result, error)

DeleteFromCrossClusterTasks deletes one row from cross_cluster_tasks table

func (*DB) DeleteFromCurrentExecutions ¶ added in v1.2.17

func (mdb *DB) DeleteFromCurrentExecutions(ctx context.Context, filter *sqlplugin.CurrentExecutionsFilter) (sql.Result, error)

DeleteFromCurrentExecutions deletes a single row in current_executions table

func (*DB) DeleteFromDomain ¶ added in v1.2.17

func (mdb *DB) DeleteFromDomain(ctx context.Context, filter *sqlplugin.DomainFilter) (sql.Result, error)

DeleteFromDomain deletes a single row in domains table

func (*DB) DeleteFromExecutions ¶ added in v1.2.17

func (mdb *DB) DeleteFromExecutions(ctx context.Context, filter *sqlplugin.ExecutionsFilter) (sql.Result, error)

DeleteFromExecutions deletes a single row from executions table

func (*DB) DeleteFromHistoryNode ¶ added in v1.2.17

func (mdb *DB) DeleteFromHistoryNode(ctx context.Context, filter *sqlplugin.HistoryNodeFilter) (sql.Result, error)

DeleteFromHistoryNode deletes one or more rows from history_node table

func (*DB) DeleteFromHistoryTree ¶ added in v1.2.17

func (mdb *DB) DeleteFromHistoryTree(ctx context.Context, filter *sqlplugin.HistoryTreeFilter) (sql.Result, error)

DeleteFromHistoryTree deletes one or more rows from history_tree table

func (*DB) DeleteFromReplicationTasks ¶ added in v1.2.17

func (mdb *DB) DeleteFromReplicationTasks(ctx context.Context, filter *sqlplugin.ReplicationTasksFilter) (sql.Result, error)

DeleteFromReplicationTasks deletes one row from replication_tasks table

func (*DB) DeleteFromRequestCancelInfoMaps ¶ added in v1.2.17

func (mdb *DB) DeleteFromRequestCancelInfoMaps(ctx context.Context, filter *sqlplugin.RequestCancelInfoMapsFilter) (sql.Result, error)

DeleteFromRequestCancelInfoMaps deletes one or more rows from request_cancel_info_maps table

func (*DB) DeleteFromSignalInfoMaps ¶ added in v1.2.17

func (mdb *DB) DeleteFromSignalInfoMaps(ctx context.Context, filter *sqlplugin.SignalInfoMapsFilter) (sql.Result, error)

DeleteFromSignalInfoMaps deletes one or more rows from signal_info_maps table

func (*DB) DeleteFromSignalsRequestedSets ¶ added in v1.2.17

func (mdb *DB) DeleteFromSignalsRequestedSets(ctx context.Context, filter *sqlplugin.SignalsRequestedSetsFilter) (sql.Result, error)

DeleteFromSignalsRequestedSets deletes one or more rows from signals_requested_sets table

func (*DB) DeleteFromTaskLists ¶ added in v1.2.17

func (mdb *DB) DeleteFromTaskLists(ctx context.Context, filter *sqlplugin.TaskListsFilter) (sql.Result, error)

DeleteFromTaskLists deletes a row from task_lists table

func (*DB) DeleteFromTasks ¶ added in v1.2.17

func (mdb *DB) DeleteFromTasks(ctx context.Context, filter *sqlplugin.TasksFilter) (sql.Result, error)

DeleteFromTasks deletes one or more rows from tasks table

func (*DB) DeleteFromTimerInfoMaps ¶ added in v1.2.17

func (mdb *DB) DeleteFromTimerInfoMaps(ctx context.Context, filter *sqlplugin.TimerInfoMapsFilter) (sql.Result, error)

DeleteFromTimerInfoMaps deletes one or more rows from timer_info_maps table

func (*DB) DeleteFromTimerTasks ¶ added in v1.2.17

func (mdb *DB) DeleteFromTimerTasks(ctx context.Context, filter *sqlplugin.TimerTasksFilter) (sql.Result, error)

DeleteFromTimerTasks deletes one row from timer_tasks table

func (*DB) DeleteFromTransferTasks ¶ added in v1.2.17

func (mdb *DB) DeleteFromTransferTasks(ctx context.Context, filter *sqlplugin.TransferTasksFilter) (sql.Result, error)

DeleteFromTransferTasks deletes one row from transfer_tasks table

func (*DB) DeleteFromVisibility ¶ added in v1.2.17

func (mdb *DB) DeleteFromVisibility(ctx context.Context, filter *sqlplugin.VisibilityFilter) (sql.Result, error)

DeleteFromVisibility deletes a row from visibility table if it exist

func (*DB) DeleteMessage ¶ added in v1.2.17

func (mdb *DB) DeleteMessage(
	ctx context.Context,
	queueType persistence.QueueType,
	messageID int64,
) (sql.Result, error)

DeleteMessage deletes message with a messageID from the queue

func (*DB) DeleteMessageFromReplicationTasksDLQ ¶ added in v1.2.17

func (mdb *DB) DeleteMessageFromReplicationTasksDLQ(
	ctx context.Context,
	filter *sqlplugin.ReplicationTasksDLQFilter,
) (sql.Result, error)

DeleteMessageFromReplicationTasksDLQ deletes one row from replication_tasks_dlq table

func (*DB) DeleteMessagesBefore ¶ added in v1.2.17

func (mdb *DB) DeleteMessagesBefore(
	ctx context.Context,
	queueType persistence.QueueType,
	messageID int64,
) (sql.Result, error)

DeleteMessagesBefore deletes messages before messageID from the queue

func (*DB) DropAllTables ¶ added in v1.2.17

func (mdb *DB) DropAllTables(database string) error

DropAllTables drops all tables from this database

func (*DB) DropDatabase ¶ added in v1.2.17

func (mdb *DB) DropDatabase(name string) error

DropDatabase drops a database

func (*DB) DropTable ¶ added in v1.2.17

func (mdb *DB) DropTable(name string) error

DropTable drops a given table from the database

func (*DB) ExecSchemaOperationQuery ¶ added in v1.2.17

func (mdb *DB) ExecSchemaOperationQuery(ctx context.Context, stmt string, args ...interface{}) error

ExecSchemaOperationQuery executes a sql statement for schema ONLY. DO NOT use it in other cases, otherwise it will not work for multiple SQL database.

func (*DB) GetAckLevels ¶ added in v1.2.17

func (mdb *DB) GetAckLevels(
	ctx context.Context,
	queueType persistence.QueueType,
	forUpdate bool,
) (map[string]int64, error)

GetAckLevels returns ack levels for pulling clusters

func (*DB) GetAllHistoryTreeBranches ¶ added in v1.2.17

func (mdb *DB) GetAllHistoryTreeBranches(ctx context.Context, filter *sqlplugin.HistoryTreeFilter) ([]sqlplugin.HistoryTreeRow, error)

func (*DB) GetLastEnqueuedMessageIDForUpdate ¶ added in v1.2.17

func (mdb *DB) GetLastEnqueuedMessageIDForUpdate(
	ctx context.Context,
	queueType persistence.QueueType,
) (int64, error)

GetLastEnqueuedMessageIDForUpdate returns the last enqueued message ID

func (*DB) GetMessagesBetween ¶ added in v1.2.17

func (mdb *DB) GetMessagesBetween(
	ctx context.Context,
	queueType persistence.QueueType,
	firstMessageID int64,
	lastMessageID int64,
	maxRows int,
) ([]sqlplugin.QueueRow, error)

GetMessagesBetween retrieves messages from the queue

func (*DB) GetMessagesFromQueue ¶ added in v1.2.17

func (mdb *DB) GetMessagesFromQueue(
	ctx context.Context,
	queueType persistence.QueueType,
	lastMessageID int64,
	maxRows int,
) ([]sqlplugin.QueueRow, error)

GetMessagesFromQueue retrieves messages from the queue

func (*DB) GetOrphanTasks ¶ added in v1.2.17

func (mdb *DB) GetOrphanTasks(ctx context.Context, filter *sqlplugin.OrphanTasksFilter) ([]sqlplugin.TaskKeyRow, error)

func (*DB) GetQueueSize ¶ added in v1.2.17

func (mdb *DB) GetQueueSize(
	ctx context.Context,
	queueType persistence.QueueType,
) (int64, error)

GetQueueSize returns the queue size

func (*DB) GetTasksCount ¶ added in v1.2.17

func (mdb *DB) GetTasksCount(ctx context.Context, filter *sqlplugin.TasksFilter) (int64, error)

func (*DB) GetTotalNumDBShards ¶ added in v1.2.17

func (mdb *DB) GetTotalNumDBShards() int

func (*DB) HasSchemaVersionTables ¶

func (mdb *DB) HasSchemaVersionTables() (bool, error)

HasSchemaVersionTables checks if schema metadata tables exist.

func (*DB) InsertAckLevel ¶ added in v1.2.17

func (mdb *DB) InsertAckLevel(
	ctx context.Context,
	queueType persistence.QueueType,
	messageID int64,
	clusterName string,
) error

InsertAckLevel inserts ack level

func (*DB) InsertConfig ¶ added in v1.2.17

func (mdb *DB) InsertConfig(ctx context.Context, row *persistence.InternalConfigStoreEntry) error

func (*DB) InsertIntoActiveClusterSelectionPolicy ¶ added in v1.4.1

func (mdb *DB) InsertIntoActiveClusterSelectionPolicy(ctx context.Context, row *sqlplugin.ActiveClusterSelectionPolicyRow) (sql.Result, error)

func (*DB) InsertIntoBufferedEvents ¶ added in v1.2.17

func (mdb *DB) InsertIntoBufferedEvents(ctx context.Context, rows []sqlplugin.BufferedEventsRow) (sql.Result, error)

InsertIntoBufferedEvents inserts one or more rows into buffered_events table

func (*DB) InsertIntoCrossClusterTasks ¶ added in v1.2.17

func (mdb *DB) InsertIntoCrossClusterTasks(ctx context.Context, rows []sqlplugin.CrossClusterTasksRow) (sql.Result, error)

InsertIntoCrossClusterTasks inserts one or more rows into cross_cluster_tasks table

func (*DB) InsertIntoCurrentExecutions ¶ added in v1.2.17

func (mdb *DB) InsertIntoCurrentExecutions(ctx context.Context, row *sqlplugin.CurrentExecutionsRow) (sql.Result, error)

InsertIntoCurrentExecutions inserts a single row into current_executions table

func (*DB) InsertIntoDomain ¶ added in v1.2.17

func (mdb *DB) InsertIntoDomain(ctx context.Context, row *sqlplugin.DomainRow) (sql.Result, error)

InsertIntoDomain inserts a single row into domains table

func (*DB) InsertIntoDomainAuditLog ¶ added in v1.4.0

func (mdb *DB) InsertIntoDomainAuditLog(ctx context.Context, row *sqlplugin.DomainAuditLogRow) (sql.Result, error)

InsertIntoDomainAuditLog inserts a single row into domain_audit_log table

func (*DB) InsertIntoExecutions ¶ added in v1.2.17

func (mdb *DB) InsertIntoExecutions(ctx context.Context, row *sqlplugin.ExecutionsRow) (sql.Result, error)

InsertIntoExecutions inserts a row into executions table

func (*DB) InsertIntoHistoryNode ¶ added in v1.2.17

func (mdb *DB) InsertIntoHistoryNode(ctx context.Context, row *sqlplugin.HistoryNodeRow) (sql.Result, error)

InsertIntoHistoryNode inserts a row into history_node table

func (*DB) InsertIntoHistoryTree ¶ added in v1.2.17

func (mdb *DB) InsertIntoHistoryTree(ctx context.Context, row *sqlplugin.HistoryTreeRow) (sql.Result, error)

InsertIntoHistoryTree inserts a row into history_tree table

func (*DB) InsertIntoQueue ¶ added in v1.2.17

func (mdb *DB) InsertIntoQueue(
	ctx context.Context,
	row *sqlplugin.QueueRow,
) (sql.Result, error)

InsertIntoQueue inserts a new row into queue table

func (*DB) InsertIntoReplicationTasks ¶ added in v1.2.17

func (mdb *DB) InsertIntoReplicationTasks(ctx context.Context, rows []sqlplugin.ReplicationTasksRow) (sql.Result, error)

InsertIntoReplicationTasks inserts one or more rows into replication_tasks table

func (*DB) InsertIntoReplicationTasksDLQ ¶ added in v1.2.17

func (mdb *DB) InsertIntoReplicationTasksDLQ(ctx context.Context, row *sqlplugin.ReplicationTaskDLQRow) (sql.Result, error)

InsertIntoReplicationTasksDLQ inserts one or more rows into replication_tasks_dlq table

func (*DB) InsertIntoShards ¶ added in v1.2.17

func (mdb *DB) InsertIntoShards(ctx context.Context, row *sqlplugin.ShardsRow) (sql.Result, error)

InsertIntoShards inserts one or more rows into shards table

func (*DB) InsertIntoSignalsRequestedSets ¶ added in v1.2.17

func (mdb *DB) InsertIntoSignalsRequestedSets(ctx context.Context, rows []sqlplugin.SignalsRequestedSetsRow) (sql.Result, error)

InsertIntoSignalsRequestedSets inserts one or more rows into signals_requested_sets table

func (*DB) InsertIntoTaskLists ¶ added in v1.2.17

func (mdb *DB) InsertIntoTaskLists(ctx context.Context, row *sqlplugin.TaskListsRow) (sql.Result, error)

InsertIntoTaskLists inserts one or more rows into task_lists table

func (*DB) InsertIntoTaskListsWithTTL ¶ added in v1.2.17

func (mdb *DB) InsertIntoTaskListsWithTTL(_ context.Context, _ *sqlplugin.TaskListsRowWithTTL) (sql.Result, error)

InsertIntoTaskListsWithTTL is not supported in MySQL

func (*DB) InsertIntoTasks ¶ added in v1.2.17

func (mdb *DB) InsertIntoTasks(ctx context.Context, rows []sqlplugin.TasksRow) (sql.Result, error)

InsertIntoTasks inserts one or more rows into tasks table

func (*DB) InsertIntoTasksWithTTL ¶ added in v1.2.17

func (mdb *DB) InsertIntoTasksWithTTL(_ context.Context, _ []sqlplugin.TasksRowWithTTL) (sql.Result, error)

InsertIntoTasksWithTTL is not supported in MySQL

func (*DB) InsertIntoTimerTasks ¶ added in v1.2.17

func (mdb *DB) InsertIntoTimerTasks(ctx context.Context, rows []sqlplugin.TimerTasksRow) (sql.Result, error)

InsertIntoTimerTasks inserts one or more rows into timer_tasks table

func (*DB) InsertIntoTransferTasks ¶ added in v1.2.17

func (mdb *DB) InsertIntoTransferTasks(ctx context.Context, rows []sqlplugin.TransferTasksRow) (sql.Result, error)

InsertIntoTransferTasks inserts one or more rows into transfer_tasks table

func (*DB) InsertIntoVisibility ¶ added in v1.2.17

func (mdb *DB) InsertIntoVisibility(ctx context.Context, row *sqlplugin.VisibilityRow) (sql.Result, error)

InsertIntoVisibility inserts a row into visibility table. If an row already exist, its left as such and no update will be made

func (*DB) IsDupEntryError ¶ added in v1.2.17

func (mdb *DB) IsDupEntryError(err error) bool

func (*DB) IsNotFoundError ¶ added in v1.2.17

func (mdb *DB) IsNotFoundError(err error) bool

func (*DB) IsThrottlingError ¶ added in v1.2.17

func (mdb *DB) IsThrottlingError(err error) bool

func (*DB) IsTimeoutError ¶ added in v1.2.17

func (mdb *DB) IsTimeoutError(err error) bool

func (*DB) ListTables ¶ added in v1.2.17

func (mdb *DB) ListTables(database string) ([]string, error)

ListTables returns a list of tables in this database

func (*DB) LockCurrentExecutions ¶ added in v1.2.17

func (mdb *DB) LockCurrentExecutions(ctx context.Context, filter *sqlplugin.CurrentExecutionsFilter) (*sqlplugin.CurrentExecutionsRow, error)

LockCurrentExecutions acquires a write lock on a single row in current_executions table

func (*DB) LockCurrentExecutionsJoinExecutions ¶ added in v1.2.17

func (mdb *DB) LockCurrentExecutionsJoinExecutions(ctx context.Context, filter *sqlplugin.CurrentExecutionsFilter) ([]sqlplugin.CurrentExecutionsRow, error)

LockCurrentExecutionsJoinExecutions joins a row in current_executions with executions table and acquires a write lock on the result

func (*DB) LockDomainMetadata ¶ added in v1.2.17

func (mdb *DB) LockDomainMetadata(ctx context.Context) error

LockDomainMetadata acquires a write lock on a single row in domain_metadata table

func (*DB) LockTaskLists ¶ added in v1.2.17

func (mdb *DB) LockTaskLists(ctx context.Context, filter *sqlplugin.TaskListsFilter) (int64, error)

LockTaskLists locks a row in task_lists table

func (*DB) MaxAllowedTTL ¶ added in v1.2.17

func (mdb *DB) MaxAllowedTTL() (*time.Duration, error)

MaxAllowedTTL returns the max allowed ttl MySQL supports

func (*DB) PluginName ¶ added in v1.2.17

func (mdb *DB) PluginName() string

PluginName returns the name of the mysql plugin

func (*DB) RangeDeleteFromCrossClusterTasks ¶ added in v1.2.17

func (mdb *DB) RangeDeleteFromCrossClusterTasks(ctx context.Context, filter *sqlplugin.CrossClusterTasksFilter) (sql.Result, error)

RangeDeleteFromCrossClusterTasks deletes multi rows from cross_cluster_tasks table

func (*DB) RangeDeleteFromReplicationTasks ¶ added in v1.2.17

func (mdb *DB) RangeDeleteFromReplicationTasks(ctx context.Context, filter *sqlplugin.ReplicationTasksFilter) (sql.Result, error)

RangeDeleteFromReplicationTasks deletes multi rows from replication_tasks table

func (*DB) RangeDeleteFromTimerTasks ¶ added in v1.2.17

func (mdb *DB) RangeDeleteFromTimerTasks(ctx context.Context, filter *sqlplugin.TimerTasksFilter) (sql.Result, error)

RangeDeleteFromTimerTasks deletes multi rows from timer_tasks table

func (*DB) RangeDeleteFromTransferTasks ¶ added in v1.2.17

func (mdb *DB) RangeDeleteFromTransferTasks(ctx context.Context, filter *sqlplugin.TransferTasksFilter) (sql.Result, error)

RangeDeleteFromTransferTasks deletes multi rows from transfer_tasks table

func (*DB) RangeDeleteMessageFromReplicationTasksDLQ ¶ added in v1.2.17

func (mdb *DB) RangeDeleteMessageFromReplicationTasksDLQ(
	ctx context.Context,
	filter *sqlplugin.ReplicationTasksDLQFilter,
) (sql.Result, error)

DeleteMessageFromReplicationTasksDLQ deletes one or more rows from replication_tasks_dlq table

func (*DB) RangeDeleteMessages ¶ added in v1.2.17

func (mdb *DB) RangeDeleteMessages(
	ctx context.Context,
	queueType persistence.QueueType,
	exclusiveBeginMessageID int64,
	inclusiveEndMessageID int64,
) (sql.Result, error)

RangeDeleteMessages deletes messages before messageID from the queue

func (*DB) ReadLockExecutions ¶ added in v1.2.17

func (mdb *DB) ReadLockExecutions(ctx context.Context, filter *sqlplugin.ExecutionsFilter) (int, error)

ReadLockExecutions acquires a write lock on a single row in executions table

func (*DB) ReadLockShards ¶ added in v1.2.17

func (mdb *DB) ReadLockShards(ctx context.Context, filter *sqlplugin.ShardsFilter) (int, error)

ReadLockShards acquires a read lock on a single row in shards table

func (*DB) ReadSchemaVersion ¶ added in v1.2.17

func (mdb *DB) ReadSchemaVersion(database string) (string, error)

ReadSchemaVersion returns the current schema version for the keyspace

func (*DB) ReplaceIntoActivityInfoMaps ¶ added in v1.2.17

func (mdb *DB) ReplaceIntoActivityInfoMaps(ctx context.Context, rows []sqlplugin.ActivityInfoMapsRow) (sql.Result, error)

ReplaceIntoActivityInfoMaps replaces one or more rows in activity_info_maps table

func (*DB) ReplaceIntoChildExecutionInfoMaps ¶ added in v1.2.17

func (mdb *DB) ReplaceIntoChildExecutionInfoMaps(ctx context.Context, rows []sqlplugin.ChildExecutionInfoMapsRow) (sql.Result, error)

ReplaceIntoChildExecutionInfoMaps replaces one or more rows in child_execution_info_maps table

func (*DB) ReplaceIntoRequestCancelInfoMaps ¶ added in v1.2.17

func (mdb *DB) ReplaceIntoRequestCancelInfoMaps(ctx context.Context, rows []sqlplugin.RequestCancelInfoMapsRow) (sql.Result, error)

ReplaceIntoRequestCancelInfoMaps replaces one or more rows in request_cancel_info_maps table

func (*DB) ReplaceIntoSignalInfoMaps ¶ added in v1.2.17

func (mdb *DB) ReplaceIntoSignalInfoMaps(ctx context.Context, rows []sqlplugin.SignalInfoMapsRow) (sql.Result, error)

ReplaceIntoSignalInfoMaps replaces one or more rows in signal_info_maps table

func (*DB) ReplaceIntoTimerInfoMaps ¶ added in v1.2.17

func (mdb *DB) ReplaceIntoTimerInfoMaps(ctx context.Context, rows []sqlplugin.TimerInfoMapsRow) (sql.Result, error)

ReplaceIntoTimerInfoMaps replaces one or more rows in timer_info_maps table

func (*DB) ReplaceIntoVisibility ¶ added in v1.2.17

func (mdb *DB) ReplaceIntoVisibility(ctx context.Context, row *sqlplugin.VisibilityRow) (sql.Result, error)

ReplaceIntoVisibility replaces an existing row if it exist or creates a new row in visibility table

func (*DB) Rollback ¶ added in v1.2.17

func (mdb *DB) Rollback() error

Rollback triggers rollback of a previously started transaction

func (*DB) SelectFromActiveClusterSelectionPolicy ¶ added in v1.4.1

func (mdb *DB) SelectFromActiveClusterSelectionPolicy(ctx context.Context, filter *sqlplugin.ActiveClusterSelectionPolicyFilter) (*sqlplugin.ActiveClusterSelectionPolicyRow, error)

func (*DB) SelectFromActivityInfoMaps ¶ added in v1.2.17

func (mdb *DB) SelectFromActivityInfoMaps(ctx context.Context, filter *sqlplugin.ActivityInfoMapsFilter) ([]sqlplugin.ActivityInfoMapsRow, error)

SelectFromActivityInfoMaps reads one or more rows from activity_info_maps table

func (*DB) SelectFromBufferedEvents ¶ added in v1.2.17

func (mdb *DB) SelectFromBufferedEvents(ctx context.Context, filter *sqlplugin.BufferedEventsFilter) ([]sqlplugin.BufferedEventsRow, error)

SelectFromBufferedEvents reads one or more rows from buffered_events table

func (*DB) SelectFromChildExecutionInfoMaps ¶ added in v1.2.17

func (mdb *DB) SelectFromChildExecutionInfoMaps(ctx context.Context, filter *sqlplugin.ChildExecutionInfoMapsFilter) ([]sqlplugin.ChildExecutionInfoMapsRow, error)

SelectFromChildExecutionInfoMaps reads one or more rows from child_execution_info_maps table

func (*DB) SelectFromCrossClusterTasks ¶ added in v1.2.17

func (mdb *DB) SelectFromCrossClusterTasks(ctx context.Context, filter *sqlplugin.CrossClusterTasksFilter) ([]sqlplugin.CrossClusterTasksRow, error)

SelectFromCrossClusterTasks reads one or more rows from cross_cluster_tasks table

func (*DB) SelectFromCurrentExecutions ¶ added in v1.2.17

func (mdb *DB) SelectFromCurrentExecutions(ctx context.Context, filter *sqlplugin.CurrentExecutionsFilter) (*sqlplugin.CurrentExecutionsRow, error)

SelectFromCurrentExecutions reads one or more rows from current_executions table

func (*DB) SelectFromDomain ¶ added in v1.2.17

func (mdb *DB) SelectFromDomain(ctx context.Context, filter *sqlplugin.DomainFilter) ([]sqlplugin.DomainRow, error)

SelectFromDomain reads one or more rows from domains table

func (*DB) SelectFromDomainAuditLogs ¶ added in v1.4.0

func (mdb *DB) SelectFromDomainAuditLogs(
	ctx context.Context,
	filter *sqlplugin.DomainAuditLogFilter,
) ([]*sqlplugin.DomainAuditLogRow, error)

SelectFromDomainAuditLogs returns audit log entries for a domain, operation type, and time range

func (*DB) SelectFromDomainMetadata ¶ added in v1.2.17

func (mdb *DB) SelectFromDomainMetadata(ctx context.Context) (*sqlplugin.DomainMetadataRow, error)

SelectFromDomainMetadata reads a single row in domain_metadata table

func (*DB) SelectFromExecutions ¶ added in v1.2.17

func (mdb *DB) SelectFromExecutions(ctx context.Context, filter *sqlplugin.ExecutionsFilter) ([]sqlplugin.ExecutionsRow, error)

SelectFromExecutions reads a single row from executions table The list execution query result is order by workflow ID only. It may returns duplicate record with pagination.

func (*DB) SelectFromHistoryNode ¶ added in v1.2.17

func (mdb *DB) SelectFromHistoryNode(ctx context.Context, filter *sqlplugin.HistoryNodeFilter) ([]sqlplugin.HistoryNodeRow, error)

SelectFromHistoryNode reads one or more rows from history_node table

func (*DB) SelectFromHistoryTree ¶ added in v1.2.17

func (mdb *DB) SelectFromHistoryTree(ctx context.Context, filter *sqlplugin.HistoryTreeFilter) ([]sqlplugin.HistoryTreeRow, error)

SelectFromHistoryTree reads one or more rows from history_tree table

func (*DB) SelectFromReplicationDLQ ¶ added in v1.2.17

func (mdb *DB) SelectFromReplicationDLQ(ctx context.Context, filter *sqlplugin.ReplicationTaskDLQFilter) (int64, error)

SelectFromReplicationDLQ reads one row from replication_tasks_dlq table

func (*DB) SelectFromReplicationTasks ¶ added in v1.2.17

func (mdb *DB) SelectFromReplicationTasks(ctx context.Context, filter *sqlplugin.ReplicationTasksFilter) ([]sqlplugin.ReplicationTasksRow, error)

SelectFromReplicationTasks reads one or more rows from replication_tasks table

func (*DB) SelectFromReplicationTasksDLQ ¶ added in v1.2.17

func (mdb *DB) SelectFromReplicationTasksDLQ(ctx context.Context, filter *sqlplugin.ReplicationTasksDLQFilter) ([]sqlplugin.ReplicationTasksRow, error)

SelectFromReplicationTasksDLQ reads one or more rows from replication_tasks_dlq table

func (*DB) SelectFromRequestCancelInfoMaps ¶ added in v1.2.17

func (mdb *DB) SelectFromRequestCancelInfoMaps(ctx context.Context, filter *sqlplugin.RequestCancelInfoMapsFilter) ([]sqlplugin.RequestCancelInfoMapsRow, error)

SelectFromRequestCancelInfoMaps reads one or more rows from request_cancel_info_maps table

func (*DB) SelectFromShards ¶ added in v1.2.17

func (mdb *DB) SelectFromShards(ctx context.Context, filter *sqlplugin.ShardsFilter) (*sqlplugin.ShardsRow, error)

SelectFromShards reads one or more rows from shards table

func (*DB) SelectFromSignalInfoMaps ¶ added in v1.2.17

func (mdb *DB) SelectFromSignalInfoMaps(ctx context.Context, filter *sqlplugin.SignalInfoMapsFilter) ([]sqlplugin.SignalInfoMapsRow, error)

SelectFromSignalInfoMaps reads one or more rows from signal_info_maps table

func (*DB) SelectFromSignalsRequestedSets ¶ added in v1.2.17

func (mdb *DB) SelectFromSignalsRequestedSets(ctx context.Context, filter *sqlplugin.SignalsRequestedSetsFilter) ([]sqlplugin.SignalsRequestedSetsRow, error)

SelectFromSignalsRequestedSets reads one or more rows from signals_requested_sets table

func (*DB) SelectFromTaskLists ¶ added in v1.2.17

func (mdb *DB) SelectFromTaskLists(ctx context.Context, filter *sqlplugin.TaskListsFilter) ([]sqlplugin.TaskListsRow, error)

SelectFromTaskLists reads one or more rows from task_lists table

func (*DB) SelectFromTasks ¶ added in v1.2.17

func (mdb *DB) SelectFromTasks(ctx context.Context, filter *sqlplugin.TasksFilter) ([]sqlplugin.TasksRow, error)

SelectFromTasks reads one or more rows from tasks table

func (*DB) SelectFromTimerInfoMaps ¶ added in v1.2.17

func (mdb *DB) SelectFromTimerInfoMaps(ctx context.Context, filter *sqlplugin.TimerInfoMapsFilter) ([]sqlplugin.TimerInfoMapsRow, error)

SelectFromTimerInfoMaps reads one or more rows from timer_info_maps table

func (*DB) SelectFromTimerTasks ¶ added in v1.2.17

func (mdb *DB) SelectFromTimerTasks(ctx context.Context, filter *sqlplugin.TimerTasksFilter) ([]sqlplugin.TimerTasksRow, error)

SelectFromTimerTasks reads one or more rows from timer_tasks table

func (*DB) SelectFromTransferTasks ¶ added in v1.2.17

func (mdb *DB) SelectFromTransferTasks(ctx context.Context, filter *sqlplugin.TransferTasksFilter) ([]sqlplugin.TransferTasksRow, error)

SelectFromTransferTasks reads one or more rows from transfer_tasks table

func (*DB) SelectFromVisibility ¶ added in v1.2.17

func (mdb *DB) SelectFromVisibility(ctx context.Context, filter *sqlplugin.VisibilityFilter) ([]sqlplugin.VisibilityRow, error)

SelectFromVisibility reads one or more rows from visibility table

func (*DB) SelectLatestConfig ¶ added in v1.2.17

func (mdb *DB) SelectLatestConfig(ctx context.Context, rowType int) (*persistence.InternalConfigStoreEntry, error)

func (*DB) SupportsAsyncTransaction ¶ added in v1.2.17

func (mdb *DB) SupportsAsyncTransaction() bool

SupportsTTL returns weather MySQL supports Asynchronous transaction

func (*DB) SupportsTTL ¶ added in v1.2.17

func (mdb *DB) SupportsTTL() bool

SupportsTTL returns weather MySQL supports TTL

func (*DB) UpdateAckLevels ¶ added in v1.2.17

func (mdb *DB) UpdateAckLevels(
	ctx context.Context,
	queueType persistence.QueueType,
	clusterAckLevels map[string]int64,
) error

UpdateAckLevels updates cluster ack levels

func (*DB) UpdateCurrentExecutions ¶ added in v1.2.17

func (mdb *DB) UpdateCurrentExecutions(ctx context.Context, row *sqlplugin.CurrentExecutionsRow) (sql.Result, error)

UpdateCurrentExecutions updates a single row in current_executions table

func (*DB) UpdateDomain ¶ added in v1.2.17

func (mdb *DB) UpdateDomain(ctx context.Context, row *sqlplugin.DomainRow) (sql.Result, error)

UpdateDomain updates a single row in domains table

func (*DB) UpdateDomainMetadata ¶ added in v1.2.17

func (mdb *DB) UpdateDomainMetadata(ctx context.Context, row *sqlplugin.DomainMetadataRow) (sql.Result, error)

UpdateDomainMetadata updates a single row in domain_metadata table

func (*DB) UpdateExecutions ¶ added in v1.2.17

func (mdb *DB) UpdateExecutions(ctx context.Context, row *sqlplugin.ExecutionsRow) (sql.Result, error)

UpdateExecutions updates a single row in executions table

func (*DB) UpdateSchemaVersion ¶ added in v1.2.17

func (mdb *DB) UpdateSchemaVersion(database string, newVersion string, minCompatibleVersion string) error

UpdateSchemaVersion updates the schema version for the keyspace

func (*DB) UpdateShards ¶ added in v1.2.17

func (mdb *DB) UpdateShards(ctx context.Context, row *sqlplugin.ShardsRow) (sql.Result, error)

UpdateShards updates one or more rows into shards table

func (*DB) UpdateTaskLists ¶ added in v1.2.17

func (mdb *DB) UpdateTaskLists(ctx context.Context, row *sqlplugin.TaskListsRow) (sql.Result, error)

UpdateTaskLists updates a row in task_lists table

func (*DB) UpdateTaskListsWithTTL ¶ added in v1.2.17

func (mdb *DB) UpdateTaskListsWithTTL(_ context.Context, _ *sqlplugin.TaskListsRowWithTTL) (sql.Result, error)

UpdateTaskListsWithTTL is not supported in MySQL

func (*DB) WriteLockExecutions ¶ added in v1.2.17

func (mdb *DB) WriteLockExecutions(ctx context.Context, filter *sqlplugin.ExecutionsFilter) (int, error)

WriteLockExecutions acquires a write lock on a single row in executions table

func (*DB) WriteLockShards ¶ added in v1.2.17

func (mdb *DB) WriteLockShards(ctx context.Context, filter *sqlplugin.ShardsFilter) (int, error)

WriteLockShards acquires a write lock on a single row in shards table

func (*DB) WriteSchemaUpdateLog ¶ added in v1.2.17

func (mdb *DB) WriteSchemaUpdateLog(oldVersion string, newVersion string, manifestMD5 string, desc string) error

WriteSchemaUpdateLog adds an entry to the schema update history table