sqlplugin

package
v1.2.14-prerelease02 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 25, 2024 License: MIT Imports: 10 Imported by: 0

Documentation

Overview

Package sqlplugin is a generated GoMock package.

Index

Constants

View Source 
const (
	// this means the query need to execute in one shard but the shard should be fixed/static, e.g. for domain, queue storage are single shard
	DbDefaultShard = 0
	// this is should never being used in sharded SQL driver. It is used in admin/schema operation in singleton driver, which ignores all the shardID parameter
	DbShardUndefined = -1
	// this means the query needs to execute in all dbShards in sharded SQL driver (currently not supported)
	DbAllShards = -2
)

This section defines the special dbShardID, they must all below 0

Variables

View Source 
var (
	// ErrTTLNotSupported indicates the sql plugin does not support ttl
	ErrTTLNotSupported = errors.New("plugin implementation does not support ttl")
)

Functions

func GetDBShardIDFromDomainID added in v0.24.0 

func GetDBShardIDFromDomainID(domainID string, numDBShards int) int

GetDBShardIDFromDomainID maps domainID to a DBShardID

func GetDBShardIDFromDomainIDAndTasklist added in v0.24.0 

func GetDBShardIDFromDomainIDAndTasklist(domainID, tasklistName string, numDBShards int) int

GetDBShardIDFromDomainIDAndTasklist maps <domainID, tasklistName> to a DBShardID

func GetDBShardIDFromHistoryShardID added in v0.24.0 

func GetDBShardIDFromHistoryShardID(historyShardID int, numDBShards int) int

GetDBShardIDFromHistoryShardID maps historyShardID to a DBShardID

func GetDBShardIDFromTreeID added in v0.24.0 

func GetDBShardIDFromTreeID(treeID serialization.UUID, numDBShards int) int

GetDBShardIDFromTreeID maps treeID to a DBShardID

Types

type ActivityInfoMapsFilter 

type ActivityInfoMapsFilter struct {
	ShardID     int64
	DomainID    serialization.UUID
	WorkflowID  string
	RunID       serialization.UUID
	ScheduleIDs []int64
}

ActivityInfoMapsFilter contains the column names within activity_info_maps table that can be used to filter results through a WHERE clause

type ActivityInfoMapsRow 

type ActivityInfoMapsRow struct {
	ShardID                  int64
	DomainID                 serialization.UUID
	WorkflowID               string
	RunID                    serialization.UUID
	ScheduleID               int64
	Data                     []byte
	DataEncoding             string
	LastHeartbeatDetails     []byte
	LastHeartbeatUpdatedTime time.Time
}

ActivityInfoMapsRow represents a row in activity_info_maps table

type AdminDB 

type AdminDB interface {
	PluginName() string
	Close() error
	// contains filtered or unexported methods
}

AdminDB defines the API for admin SQL operations for CLI and testing suites

type BufferedEventsFilter 

type BufferedEventsFilter struct {
	ShardID    int
	DomainID   serialization.UUID
	WorkflowID string
	RunID      serialization.UUID
}

BufferedEventsFilter contains the column names within buffered_events table that can be used to filter results through a WHERE clause

type BufferedEventsRow 

type BufferedEventsRow struct {
	ShardID      int
	DomainID     serialization.UUID
	WorkflowID   string
	RunID        serialization.UUID
	Data         []byte
	DataEncoding string
}

BufferedEventsRow represents a row in buffered_events table

type ChildExecutionInfoMapsFilter 

type ChildExecutionInfoMapsFilter struct {
	ShardID      int64
	DomainID     serialization.UUID
	WorkflowID   string
	RunID        serialization.UUID
	InitiatedIDs []int64
}

ChildExecutionInfoMapsFilter contains the column names within child_execution_info_maps table that can be used to filter results through a WHERE clause

type ChildExecutionInfoMapsRow 

type ChildExecutionInfoMapsRow struct {
	ShardID      int64
	DomainID     serialization.UUID
	WorkflowID   string
	RunID        serialization.UUID
	InitiatedID  int64
	Data         []byte
	DataEncoding string
}

ChildExecutionInfoMapsRow represents a row in child_execution_info_maps table

type ClusterConfigRow added in v1.2.4 

type ClusterConfigRow struct {
	RowType      int
	Version      int64
	Timestamp    time.Time
	Data         []byte
	DataEncoding string
}

ClusterConfigRow represents a row in cluster_config table

type CrossClusterTasksFilter added in v0.22.0 

type CrossClusterTasksFilter struct {
	TargetCluster string
	ShardID       int
	TaskID        int64
	MinTaskID     int64
	MaxTaskID     int64
	PageSize      int
}

CrossClusterTasksFilter contains the column names within cross_cluster_tasks table that can be used to filter results through a WHERE clause

type CrossClusterTasksRow added in v0.22.0 

type CrossClusterTasksRow struct {
	TargetCluster string
	ShardID       int
	TaskID        int64
	Data          []byte
	DataEncoding  string
}

CrossClusterTasksRow represents a row in cross_cluster_tasks table

type CurrentExecutionsFilter 

type CurrentExecutionsFilter struct {
	ShardID    int64
	DomainID   serialization.UUID
	WorkflowID string
	RunID      serialization.UUID
}

CurrentExecutionsFilter contains the column names within current_executions table that can be used to filter results through a WHERE clause

type CurrentExecutionsRow 

type CurrentExecutionsRow struct {
	ShardID          int64
	DomainID         serialization.UUID
	WorkflowID       string
	RunID            serialization.UUID
	CreateRequestID  string
	State            int
	CloseStatus      int
	LastWriteVersion int64
	StartVersion     int64
}

CurrentExecutionsRow represents a row in current_executions table

type DB 

type DB interface {
	ErrorChecker

	GetTotalNumDBShards() int
	BeginTx(ctx context.Context, dbShardID int) (Tx, error)
	PluginName() string
	Close() error
	// contains filtered or unexported methods
}

DB defines the API for regular SQL operations of a Cadence server

type DomainFilter 

type DomainFilter struct {
	ID            *serialization.UUID
	Name          *string
	GreaterThanID *serialization.UUID
	PageSize      *int
}

DomainFilter contains the column names within domain table that can be used to filter results through a WHERE clause. When ID is not nil, it will be used for WHERE condition. If ID is nil and Name is non-nil, Name will be used for WHERE condition. When both ID and Name are nil, no WHERE clause will be used

type DomainMetadataRow 

type DomainMetadataRow struct {
	NotificationVersion int64
}

DomainMetadataRow represents a row in domain_metadata table

type DomainRow 

type DomainRow struct {
	ID           serialization.UUID
	Name         string
	Data         []byte
	DataEncoding string
	IsGlobal     bool
}

DomainRow represents a row in domain table

type ErrorChecker added in v0.21.2 

type ErrorChecker interface {
	IsDupEntryError(err error) bool
	IsNotFoundError(err error) bool
	IsTimeoutError(err error) bool
	IsThrottlingError(err error) bool
}

type EventsFilter 

type EventsFilter struct {
	DomainID     serialization.UUID
	WorkflowID   string
	RunID        serialization.UUID
	FirstEventID *int64
	NextEventID  *int64
	PageSize     *int
}

EventsFilter contains the column names within events table that can be used to filter results through a WHERE clause

type EventsRow 

type EventsRow struct {
	DomainID     serialization.UUID
	WorkflowID   string
	RunID        serialization.UUID
	FirstEventID int64
	BatchVersion int64
	RangeID      int64
	TxID         int64
	Data         []byte
	DataEncoding string
}

EventsRow represents a row in events table

type ExecutionsFilter 

type ExecutionsFilter struct {
	ShardID    int
	DomainID   serialization.UUID
	WorkflowID string
	RunID      serialization.UUID
	Size       int
}

ExecutionsFilter contains the column names within executions table that can be used to filter results through a WHERE clause To get single row, it requires ShardID, DomainID, WorkflowID, RunID To get a list of rows, it requires ShardID, Size. The WorkflowID and RunID are optional for listing rows. They work as the start boundary for pagination.

type ExecutionsRow 

type ExecutionsRow struct {
	ShardID                  int
	DomainID                 serialization.UUID
	WorkflowID               string
	RunID                    serialization.UUID
	NextEventID              int64
	LastWriteVersion         int64
	Data                     []byte
	DataEncoding             string
	VersionHistories         []byte
	VersionHistoriesEncoding string
}

ExecutionsRow represents a row in executions table

type HistoryNodeFilter 

type HistoryNodeFilter struct {
	ShardID  int
	TreeID   serialization.UUID
	BranchID serialization.UUID
	// Inclusive
	MinNodeID *int64
	// Exclusive
	MaxNodeID *int64
	PageSize  int
}

HistoryNodeFilter contains the column names within history_node table that can be used to filter results through a WHERE clause

type HistoryNodeRow 

type HistoryNodeRow struct {
	ShardID  int
	TreeID   serialization.UUID
	BranchID serialization.UUID
	NodeID   int64
	// use pointer so that it's easier to multiple by -1
	TxnID        *int64
	Data         []byte
	DataEncoding string
}

HistoryNodeRow represents a row in history_node table

type HistoryTreeFilter 

type HistoryTreeFilter struct {
	ShardID  int
	TreeID   serialization.UUID
	BranchID *serialization.UUID
	PageSize *int
}

HistoryTreeFilter contains the column names within history_tree table that can be used to filter results through a WHERE clause

type HistoryTreeRow 

type HistoryTreeRow struct {
	ShardID      int
	TreeID       serialization.UUID
	BranchID     serialization.UUID
	Data         []byte
	DataEncoding string
}

HistoryTreeRow represents a row in history_tree table

type MockAdminDB added in v1.2.7 

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

MockAdminDB is a mock of AdminDB interface.

func NewMockAdminDB added in v1.2.7 

func NewMockAdminDB(ctrl *gomock.Controller) *MockAdminDB

NewMockAdminDB creates a new mock instance.

func (*MockAdminDB) Close added in v1.2.7 

func (m *MockAdminDB) Close() error

Close mocks base method.

func (*MockAdminDB) CreateDatabase added in v1.2.7 

func (m *MockAdminDB) CreateDatabase(database string) error

CreateDatabase mocks base method.

func (*MockAdminDB) CreateSchemaVersionTables added in v1.2.7 

func (m *MockAdminDB) CreateSchemaVersionTables() error

CreateSchemaVersionTables mocks base method.

func (*MockAdminDB) DropAllTables added in v1.2.7 

func (m *MockAdminDB) DropAllTables(database string) error

DropAllTables mocks base method.

func (*MockAdminDB) DropDatabase added in v1.2.7 

func (m *MockAdminDB) DropDatabase(database string) error

DropDatabase mocks base method.

func (*MockAdminDB) DropTable added in v1.2.7 

func (m *MockAdminDB) DropTable(table string) error

DropTable mocks base method.

func (*MockAdminDB) EXPECT added in v1.2.7 

func (m *MockAdminDB) EXPECT() *MockAdminDBMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockAdminDB) ExecSchemaOperationQuery added in v1.2.7 

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

ExecSchemaOperationQuery mocks base method.

func (*MockAdminDB) ListTables added in v1.2.7 

func (m *MockAdminDB) ListTables(database string) ([]string, error)

ListTables mocks base method.

func (*MockAdminDB) PluginName added in v1.2.7 

func (m *MockAdminDB) PluginName() string

PluginName mocks base method.

func (*MockAdminDB) ReadSchemaVersion added in v1.2.7 

func (m *MockAdminDB) ReadSchemaVersion(database string) (string, error)

ReadSchemaVersion mocks base method.

func (*MockAdminDB) UpdateSchemaVersion added in v1.2.7 

func (m *MockAdminDB) UpdateSchemaVersion(database, newVersion, minCompatibleVersion string) error

UpdateSchemaVersion mocks base method.

func (*MockAdminDB) WriteSchemaUpdateLog added in v1.2.7 

func (m *MockAdminDB) WriteSchemaUpdateLog(oldVersion, newVersion, manifestMD5, desc string) error

WriteSchemaUpdateLog mocks base method.

type MockAdminDBMockRecorder added in v1.2.7 

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

MockAdminDBMockRecorder is the mock recorder for MockAdminDB.

func (*MockAdminDBMockRecorder) Close added in v1.2.7 

func (mr *MockAdminDBMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockAdminDBMockRecorder) CreateDatabase added in v1.2.7 

func (mr *MockAdminDBMockRecorder) CreateDatabase(database interface{}) *gomock.Call

CreateDatabase indicates an expected call of CreateDatabase.

func (*MockAdminDBMockRecorder) CreateSchemaVersionTables added in v1.2.7 

func (mr *MockAdminDBMockRecorder) CreateSchemaVersionTables() *gomock.Call

CreateSchemaVersionTables indicates an expected call of CreateSchemaVersionTables.

func (*MockAdminDBMockRecorder) DropAllTables added in v1.2.7 

func (mr *MockAdminDBMockRecorder) DropAllTables(database interface{}) *gomock.Call

DropAllTables indicates an expected call of DropAllTables.

func (*MockAdminDBMockRecorder) DropDatabase added in v1.2.7 

func (mr *MockAdminDBMockRecorder) DropDatabase(database interface{}) *gomock.Call

DropDatabase indicates an expected call of DropDatabase.

func (*MockAdminDBMockRecorder) DropTable added in v1.2.7 

func (mr *MockAdminDBMockRecorder) DropTable(table interface{}) *gomock.Call

DropTable indicates an expected call of DropTable.

func (*MockAdminDBMockRecorder) ExecSchemaOperationQuery added in v1.2.7 

func (mr *MockAdminDBMockRecorder) ExecSchemaOperationQuery(ctx, stmt interface{}, args ...interface{}) *gomock.Call

ExecSchemaOperationQuery indicates an expected call of ExecSchemaOperationQuery.

func (*MockAdminDBMockRecorder) ListTables added in v1.2.7 

func (mr *MockAdminDBMockRecorder) ListTables(database interface{}) *gomock.Call

ListTables indicates an expected call of ListTables.

func (*MockAdminDBMockRecorder) PluginName added in v1.2.7 

func (mr *MockAdminDBMockRecorder) PluginName() *gomock.Call

PluginName indicates an expected call of PluginName.

func (*MockAdminDBMockRecorder) ReadSchemaVersion added in v1.2.7 

func (mr *MockAdminDBMockRecorder) ReadSchemaVersion(database interface{}) *gomock.Call

ReadSchemaVersion indicates an expected call of ReadSchemaVersion.

func (*MockAdminDBMockRecorder) UpdateSchemaVersion added in v1.2.7 

func (mr *MockAdminDBMockRecorder) UpdateSchemaVersion(database, newVersion, minCompatibleVersion interface{}) *gomock.Call

UpdateSchemaVersion indicates an expected call of UpdateSchemaVersion.

func (*MockAdminDBMockRecorder) WriteSchemaUpdateLog added in v1.2.7 

func (mr *MockAdminDBMockRecorder) WriteSchemaUpdateLog(oldVersion, newVersion, manifestMD5, desc interface{}) *gomock.Call

WriteSchemaUpdateLog indicates an expected call of WriteSchemaUpdateLog.

type MockDB added in v1.2.7 

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

MockDB is a mock of DB interface.

func NewMockDB added in v1.2.7 

func NewMockDB(ctrl *gomock.Controller) *MockDB

NewMockDB creates a new mock instance.

func (*MockDB) BeginTx added in v1.2.7 

func (m *MockDB) BeginTx(ctx context.Context, dbShardID int) (Tx, error)

BeginTx mocks base method.

func (*MockDB) Close added in v1.2.7 

func (m *MockDB) Close() error

Close mocks base method.

func (*MockDB) DeleteFromActivityInfoMaps added in v1.2.7 

func (m *MockDB) DeleteFromActivityInfoMaps(ctx context.Context, filter *ActivityInfoMapsFilter) (sql.Result, error)

DeleteFromActivityInfoMaps mocks base method.

func (*MockDB) DeleteFromBufferedEvents added in v1.2.7 

func (m *MockDB) DeleteFromBufferedEvents(ctx context.Context, filter *BufferedEventsFilter) (sql.Result, error)

DeleteFromBufferedEvents mocks base method.

func (*MockDB) DeleteFromChildExecutionInfoMaps added in v1.2.7 

func (m *MockDB) DeleteFromChildExecutionInfoMaps(ctx context.Context, filter *ChildExecutionInfoMapsFilter) (sql.Result, error)

DeleteFromChildExecutionInfoMaps mocks base method.

func (*MockDB) DeleteFromCrossClusterTasks added in v1.2.7 

func (m *MockDB) DeleteFromCrossClusterTasks(ctx context.Context, filter *CrossClusterTasksFilter) (sql.Result, error)

DeleteFromCrossClusterTasks mocks base method.

func (*MockDB) DeleteFromCurrentExecutions added in v1.2.7 

func (m *MockDB) DeleteFromCurrentExecutions(ctx context.Context, filter *CurrentExecutionsFilter) (sql.Result, error)

DeleteFromCurrentExecutions mocks base method.

func (*MockDB) DeleteFromDomain added in v1.2.7 

func (m *MockDB) DeleteFromDomain(ctx context.Context, filter *DomainFilter) (sql.Result, error)

DeleteFromDomain mocks base method.

func (*MockDB) DeleteFromExecutions added in v1.2.7 

func (m *MockDB) DeleteFromExecutions(ctx context.Context, filter *ExecutionsFilter) (sql.Result, error)

DeleteFromExecutions mocks base method.

func (*MockDB) DeleteFromHistoryNode added in v1.2.7 

func (m *MockDB) DeleteFromHistoryNode(ctx context.Context, filter *HistoryNodeFilter) (sql.Result, error)

DeleteFromHistoryNode mocks base method.

func (*MockDB) DeleteFromHistoryTree added in v1.2.7 

func (m *MockDB) DeleteFromHistoryTree(ctx context.Context, filter *HistoryTreeFilter) (sql.Result, error)

DeleteFromHistoryTree mocks base method.

func (*MockDB) DeleteFromReplicationTasks added in v1.2.7 

func (m *MockDB) DeleteFromReplicationTasks(ctx context.Context, filter *ReplicationTasksFilter) (sql.Result, error)

DeleteFromReplicationTasks mocks base method.

func (*MockDB) DeleteFromRequestCancelInfoMaps added in v1.2.7 

func (m *MockDB) DeleteFromRequestCancelInfoMaps(ctx context.Context, filter *RequestCancelInfoMapsFilter) (sql.Result, error)

DeleteFromRequestCancelInfoMaps mocks base method.

func (*MockDB) DeleteFromSignalInfoMaps added in v1.2.7 

func (m *MockDB) DeleteFromSignalInfoMaps(ctx context.Context, filter *SignalInfoMapsFilter) (sql.Result, error)

DeleteFromSignalInfoMaps mocks base method.

func (*MockDB) DeleteFromSignalsRequestedSets added in v1.2.7 

func (m *MockDB) DeleteFromSignalsRequestedSets(ctx context.Context, filter *SignalsRequestedSetsFilter) (sql.Result, error)

DeleteFromSignalsRequestedSets mocks base method.

func (*MockDB) DeleteFromTaskLists added in v1.2.7 

func (m *MockDB) DeleteFromTaskLists(ctx context.Context, filter *TaskListsFilter) (sql.Result, error)

DeleteFromTaskLists mocks base method.

func (*MockDB) DeleteFromTasks added in v1.2.7 

func (m *MockDB) DeleteFromTasks(ctx context.Context, filter *TasksFilter) (sql.Result, error)

DeleteFromTasks mocks base method.

func (*MockDB) DeleteFromTimerInfoMaps added in v1.2.7 

func (m *MockDB) DeleteFromTimerInfoMaps(ctx context.Context, filter *TimerInfoMapsFilter) (sql.Result, error)

DeleteFromTimerInfoMaps mocks base method.

func (*MockDB) DeleteFromTimerTasks added in v1.2.7 

func (m *MockDB) DeleteFromTimerTasks(ctx context.Context, filter *TimerTasksFilter) (sql.Result, error)

DeleteFromTimerTasks mocks base method.

func (*MockDB) DeleteFromTransferTasks added in v1.2.7 

func (m *MockDB) DeleteFromTransferTasks(ctx context.Context, filter *TransferTasksFilter) (sql.Result, error)

DeleteFromTransferTasks mocks base method.

func (*MockDB) DeleteFromVisibility added in v1.2.7 

func (m *MockDB) DeleteFromVisibility(ctx context.Context, filter *VisibilityFilter) (sql.Result, error)

DeleteFromVisibility mocks base method.

func (*MockDB) DeleteMessage added in v1.2.7 

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

DeleteMessage mocks base method.

func (*MockDB) DeleteMessageFromReplicationTasksDLQ added in v1.2.7 

func (m *MockDB) DeleteMessageFromReplicationTasksDLQ(ctx context.Context, filter *ReplicationTasksDLQFilter) (sql.Result, error)

DeleteMessageFromReplicationTasksDLQ mocks base method.

func (*MockDB) DeleteMessagesBefore added in v1.2.7 

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

DeleteMessagesBefore mocks base method.

func (*MockDB) EXPECT added in v1.2.7 

func (m *MockDB) EXPECT() *MockDBMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockDB) GetAckLevels added in v1.2.7 

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

GetAckLevels mocks base method.

func (*MockDB) GetAllHistoryTreeBranches added in v1.2.7 

func (m *MockDB) GetAllHistoryTreeBranches(ctx context.Context, filter *HistoryTreeFilter) ([]HistoryTreeRow, error)

GetAllHistoryTreeBranches mocks base method.

func (*MockDB) GetLastEnqueuedMessageIDForUpdate added in v1.2.7 

func (m *MockDB) GetLastEnqueuedMessageIDForUpdate(ctx context.Context, queueType persistence.QueueType) (int64, error)

GetLastEnqueuedMessageIDForUpdate mocks base method.

func (*MockDB) GetMessagesBetween added in v1.2.7 

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

GetMessagesBetween mocks base method.

func (*MockDB) GetMessagesFromQueue added in v1.2.7 

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

GetMessagesFromQueue mocks base method.

func (*MockDB) GetOrphanTasks added in v1.2.7 

func (m *MockDB) GetOrphanTasks(ctx context.Context, filter *OrphanTasksFilter) ([]TaskKeyRow, error)

GetOrphanTasks mocks base method.

func (*MockDB) GetQueueSize added in v1.2.7 

func (m *MockDB) GetQueueSize(ctx context.Context, queueType persistence.QueueType) (int64, error)

GetQueueSize mocks base method.

func (*MockDB) GetTasksCount added in v1.2.7 

func (m *MockDB) GetTasksCount(ctx context.Context, filter *TasksFilter) (int64, error)

GetTasksCount mocks base method.

func (*MockDB) GetTotalNumDBShards added in v1.2.7 

func (m *MockDB) GetTotalNumDBShards() int

GetTotalNumDBShards mocks base method.

func (*MockDB) InsertAckLevel added in v1.2.7 

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

InsertAckLevel mocks base method.

func (*MockDB) InsertConfig added in v1.2.7 

func (m *MockDB) InsertConfig(ctx context.Context, row *persistence.InternalConfigStoreEntry) error

InsertConfig mocks base method.

func (*MockDB) InsertIntoBufferedEvents added in v1.2.7 

func (m *MockDB) InsertIntoBufferedEvents(ctx context.Context, rows []BufferedEventsRow) (sql.Result, error)

InsertIntoBufferedEvents mocks base method.

func (*MockDB) InsertIntoCrossClusterTasks added in v1.2.7 

func (m *MockDB) InsertIntoCrossClusterTasks(ctx context.Context, rows []CrossClusterTasksRow) (sql.Result, error)

InsertIntoCrossClusterTasks mocks base method.

func (*MockDB) InsertIntoCurrentExecutions added in v1.2.7 

func (m *MockDB) InsertIntoCurrentExecutions(ctx context.Context, row *CurrentExecutionsRow) (sql.Result, error)

InsertIntoCurrentExecutions mocks base method.

func (*MockDB) InsertIntoDomain added in v1.2.7 

func (m *MockDB) InsertIntoDomain(ctx context.Context, rows *DomainRow) (sql.Result, error)

InsertIntoDomain mocks base method.

func (*MockDB) InsertIntoExecutions added in v1.2.7 

func (m *MockDB) InsertIntoExecutions(ctx context.Context, row *ExecutionsRow) (sql.Result, error)

InsertIntoExecutions mocks base method.

func (*MockDB) InsertIntoHistoryNode added in v1.2.7 

func (m *MockDB) InsertIntoHistoryNode(ctx context.Context, row *HistoryNodeRow) (sql.Result, error)

InsertIntoHistoryNode mocks base method.

func (*MockDB) InsertIntoHistoryTree added in v1.2.7 

func (m *MockDB) InsertIntoHistoryTree(ctx context.Context, row *HistoryTreeRow) (sql.Result, error)

InsertIntoHistoryTree mocks base method.

func (*MockDB) InsertIntoQueue added in v1.2.7 

func (m *MockDB) InsertIntoQueue(ctx context.Context, row *QueueRow) (sql.Result, error)

InsertIntoQueue mocks base method.

func (*MockDB) InsertIntoReplicationTasks added in v1.2.7 

func (m *MockDB) InsertIntoReplicationTasks(ctx context.Context, rows []ReplicationTasksRow) (sql.Result, error)

InsertIntoReplicationTasks mocks base method.

func (*MockDB) InsertIntoReplicationTasksDLQ added in v1.2.7 

func (m *MockDB) InsertIntoReplicationTasksDLQ(ctx context.Context, row *ReplicationTaskDLQRow) (sql.Result, error)

InsertIntoReplicationTasksDLQ mocks base method.

func (*MockDB) InsertIntoShards added in v1.2.7 

func (m *MockDB) InsertIntoShards(ctx context.Context, rows *ShardsRow) (sql.Result, error)

InsertIntoShards mocks base method.

func (*MockDB) InsertIntoSignalsRequestedSets added in v1.2.7 

func (m *MockDB) InsertIntoSignalsRequestedSets(ctx context.Context, rows []SignalsRequestedSetsRow) (sql.Result, error)

InsertIntoSignalsRequestedSets mocks base method.

func (*MockDB) InsertIntoTaskLists added in v1.2.7 

func (m *MockDB) InsertIntoTaskLists(ctx context.Context, row *TaskListsRow) (sql.Result, error)

InsertIntoTaskLists mocks base method.

func (*MockDB) InsertIntoTaskListsWithTTL added in v1.2.7 

func (m *MockDB) InsertIntoTaskListsWithTTL(ctx context.Context, row *TaskListsRowWithTTL) (sql.Result, error)

InsertIntoTaskListsWithTTL mocks base method.

func (*MockDB) InsertIntoTasks added in v1.2.7 

func (m *MockDB) InsertIntoTasks(ctx context.Context, rows []TasksRow) (sql.Result, error)

InsertIntoTasks mocks base method.

func (*MockDB) InsertIntoTasksWithTTL added in v1.2.7 

func (m *MockDB) InsertIntoTasksWithTTL(ctx context.Context, rows []TasksRowWithTTL) (sql.Result, error)

InsertIntoTasksWithTTL mocks base method.

func (*MockDB) InsertIntoTimerTasks added in v1.2.7 

func (m *MockDB) InsertIntoTimerTasks(ctx context.Context, rows []TimerTasksRow) (sql.Result, error)

InsertIntoTimerTasks mocks base method.

func (*MockDB) InsertIntoTransferTasks added in v1.2.7 

func (m *MockDB) InsertIntoTransferTasks(ctx context.Context, rows []TransferTasksRow) (sql.Result, error)

InsertIntoTransferTasks mocks base method.

func (*MockDB) InsertIntoVisibility added in v1.2.7 

func (m *MockDB) InsertIntoVisibility(ctx context.Context, row *VisibilityRow) (sql.Result, error)

InsertIntoVisibility mocks base method.

func (*MockDB) IsDupEntryError added in v1.2.7 

func (m *MockDB) IsDupEntryError(err error) bool

IsDupEntryError mocks base method.

func (*MockDB) IsNotFoundError added in v1.2.7 

func (m *MockDB) IsNotFoundError(err error) bool

IsNotFoundError mocks base method.

func (*MockDB) IsThrottlingError added in v1.2.7 

func (m *MockDB) IsThrottlingError(err error) bool

IsThrottlingError mocks base method.

func (*MockDB) IsTimeoutError added in v1.2.7 

func (m *MockDB) IsTimeoutError(err error) bool

IsTimeoutError mocks base method.

func (*MockDB) LockCurrentExecutions added in v1.2.7 

func (m *MockDB) LockCurrentExecutions(ctx context.Context, filter *CurrentExecutionsFilter) (*CurrentExecutionsRow, error)

LockCurrentExecutions mocks base method.

func (*MockDB) LockCurrentExecutionsJoinExecutions added in v1.2.7 

func (m *MockDB) LockCurrentExecutionsJoinExecutions(ctx context.Context, filter *CurrentExecutionsFilter) ([]CurrentExecutionsRow, error)

LockCurrentExecutionsJoinExecutions mocks base method.

func (*MockDB) LockDomainMetadata added in v1.2.7 

func (m *MockDB) LockDomainMetadata(ctx context.Context) error

LockDomainMetadata mocks base method.

func (*MockDB) LockTaskLists added in v1.2.7 

func (m *MockDB) LockTaskLists(ctx context.Context, filter *TaskListsFilter) (int64, error)

LockTaskLists mocks base method.

func (*MockDB) MaxAllowedTTL added in v1.2.7 

func (m *MockDB) MaxAllowedTTL() (*time.Duration, error)

MaxAllowedTTL mocks base method.

func (*MockDB) PluginName added in v1.2.7 

func (m *MockDB) PluginName() string

PluginName mocks base method.

func (*MockDB) RangeDeleteFromCrossClusterTasks added in v1.2.7 

func (m *MockDB) RangeDeleteFromCrossClusterTasks(ctx context.Context, filter *CrossClusterTasksFilter) (sql.Result, error)

RangeDeleteFromCrossClusterTasks mocks base method.

func (*MockDB) RangeDeleteFromReplicationTasks added in v1.2.7 

func (m *MockDB) RangeDeleteFromReplicationTasks(ctx context.Context, filter *ReplicationTasksFilter) (sql.Result, error)

RangeDeleteFromReplicationTasks mocks base method.

func (*MockDB) RangeDeleteFromTimerTasks added in v1.2.7 

func (m *MockDB) RangeDeleteFromTimerTasks(ctx context.Context, filter *TimerTasksFilter) (sql.Result, error)

RangeDeleteFromTimerTasks mocks base method.

func (*MockDB) RangeDeleteFromTransferTasks added in v1.2.7 

func (m *MockDB) RangeDeleteFromTransferTasks(ctx context.Context, filter *TransferTasksFilter) (sql.Result, error)

RangeDeleteFromTransferTasks mocks base method.

func (*MockDB) RangeDeleteMessageFromReplicationTasksDLQ added in v1.2.7 

func (m *MockDB) RangeDeleteMessageFromReplicationTasksDLQ(ctx context.Context, filter *ReplicationTasksDLQFilter) (sql.Result, error)

RangeDeleteMessageFromReplicationTasksDLQ mocks base method.

func (*MockDB) RangeDeleteMessages added in v1.2.7 

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

RangeDeleteMessages mocks base method.

func (*MockDB) ReadLockExecutions added in v1.2.7 

func (m *MockDB) ReadLockExecutions(ctx context.Context, filter *ExecutionsFilter) (int, error)

ReadLockExecutions mocks base method.

func (*MockDB) ReadLockShards added in v1.2.7 

func (m *MockDB) ReadLockShards(ctx context.Context, filter *ShardsFilter) (int, error)

ReadLockShards mocks base method.

func (*MockDB) ReplaceIntoActivityInfoMaps added in v1.2.7 

func (m *MockDB) ReplaceIntoActivityInfoMaps(ctx context.Context, rows []ActivityInfoMapsRow) (sql.Result, error)

ReplaceIntoActivityInfoMaps mocks base method.

func (*MockDB) ReplaceIntoChildExecutionInfoMaps added in v1.2.7 

func (m *MockDB) ReplaceIntoChildExecutionInfoMaps(ctx context.Context, rows []ChildExecutionInfoMapsRow) (sql.Result, error)

ReplaceIntoChildExecutionInfoMaps mocks base method.

func (*MockDB) ReplaceIntoRequestCancelInfoMaps added in v1.2.7 

func (m *MockDB) ReplaceIntoRequestCancelInfoMaps(ctx context.Context, rows []RequestCancelInfoMapsRow) (sql.Result, error)

ReplaceIntoRequestCancelInfoMaps mocks base method.

func (*MockDB) ReplaceIntoSignalInfoMaps added in v1.2.7 

func (m *MockDB) ReplaceIntoSignalInfoMaps(ctx context.Context, rows []SignalInfoMapsRow) (sql.Result, error)

ReplaceIntoSignalInfoMaps mocks base method.

func (*MockDB) ReplaceIntoTimerInfoMaps added in v1.2.7 

func (m *MockDB) ReplaceIntoTimerInfoMaps(ctx context.Context, rows []TimerInfoMapsRow) (sql.Result, error)

ReplaceIntoTimerInfoMaps mocks base method.

func (*MockDB) ReplaceIntoVisibility added in v1.2.7 

func (m *MockDB) ReplaceIntoVisibility(ctx context.Context, row *VisibilityRow) (sql.Result, error)

ReplaceIntoVisibility mocks base method.

func (*MockDB) SelectFromActivityInfoMaps added in v1.2.7 

func (m *MockDB) SelectFromActivityInfoMaps(ctx context.Context, filter *ActivityInfoMapsFilter) ([]ActivityInfoMapsRow, error)

SelectFromActivityInfoMaps mocks base method.

func (*MockDB) SelectFromBufferedEvents added in v1.2.7 

func (m *MockDB) SelectFromBufferedEvents(ctx context.Context, filter *BufferedEventsFilter) ([]BufferedEventsRow, error)

SelectFromBufferedEvents mocks base method.

func (*MockDB) SelectFromChildExecutionInfoMaps added in v1.2.7 

func (m *MockDB) SelectFromChildExecutionInfoMaps(ctx context.Context, filter *ChildExecutionInfoMapsFilter) ([]ChildExecutionInfoMapsRow, error)

SelectFromChildExecutionInfoMaps mocks base method.

func (*MockDB) SelectFromCrossClusterTasks added in v1.2.7 

func (m *MockDB) SelectFromCrossClusterTasks(ctx context.Context, filter *CrossClusterTasksFilter) ([]CrossClusterTasksRow, error)

SelectFromCrossClusterTasks mocks base method.

func (*MockDB) SelectFromCurrentExecutions added in v1.2.7 

func (m *MockDB) SelectFromCurrentExecutions(ctx context.Context, filter *CurrentExecutionsFilter) (*CurrentExecutionsRow, error)

SelectFromCurrentExecutions mocks base method.

func (*MockDB) SelectFromDomain added in v1.2.7 

func (m *MockDB) SelectFromDomain(ctx context.Context, filter *DomainFilter) ([]DomainRow, error)

SelectFromDomain mocks base method.

func (*MockDB) SelectFromDomainMetadata added in v1.2.7 

func (m *MockDB) SelectFromDomainMetadata(ctx context.Context) (*DomainMetadataRow, error)

SelectFromDomainMetadata mocks base method.

func (*MockDB) SelectFromExecutions added in v1.2.7 

func (m *MockDB) SelectFromExecutions(ctx context.Context, filter *ExecutionsFilter) ([]ExecutionsRow, error)

SelectFromExecutions mocks base method.

func (*MockDB) SelectFromHistoryNode added in v1.2.7 

func (m *MockDB) SelectFromHistoryNode(ctx context.Context, filter *HistoryNodeFilter) ([]HistoryNodeRow, error)

SelectFromHistoryNode mocks base method.

func (*MockDB) SelectFromHistoryTree added in v1.2.7 

func (m *MockDB) SelectFromHistoryTree(ctx context.Context, filter *HistoryTreeFilter) ([]HistoryTreeRow, error)

SelectFromHistoryTree mocks base method.

func (*MockDB) SelectFromReplicationDLQ added in v1.2.7 

func (m *MockDB) SelectFromReplicationDLQ(ctx context.Context, filter *ReplicationTaskDLQFilter) (int64, error)

SelectFromReplicationDLQ mocks base method.

func (*MockDB) SelectFromReplicationTasks added in v1.2.7 

func (m *MockDB) SelectFromReplicationTasks(ctx context.Context, filter *ReplicationTasksFilter) ([]ReplicationTasksRow, error)

SelectFromReplicationTasks mocks base method.

func (*MockDB) SelectFromReplicationTasksDLQ added in v1.2.7 

func (m *MockDB) SelectFromReplicationTasksDLQ(ctx context.Context, filter *ReplicationTasksDLQFilter) ([]ReplicationTasksRow, error)

SelectFromReplicationTasksDLQ mocks base method.

func (*MockDB) SelectFromRequestCancelInfoMaps added in v1.2.7 

func (m *MockDB) SelectFromRequestCancelInfoMaps(ctx context.Context, filter *RequestCancelInfoMapsFilter) ([]RequestCancelInfoMapsRow, error)

SelectFromRequestCancelInfoMaps mocks base method.

func (*MockDB) SelectFromShards added in v1.2.7 

func (m *MockDB) SelectFromShards(ctx context.Context, filter *ShardsFilter) (*ShardsRow, error)

SelectFromShards mocks base method.

func (*MockDB) SelectFromSignalInfoMaps added in v1.2.7 

func (m *MockDB) SelectFromSignalInfoMaps(ctx context.Context, filter *SignalInfoMapsFilter) ([]SignalInfoMapsRow, error)

SelectFromSignalInfoMaps mocks base method.

func (*MockDB) SelectFromSignalsRequestedSets added in v1.2.7 

func (m *MockDB) SelectFromSignalsRequestedSets(ctx context.Context, filter *SignalsRequestedSetsFilter) ([]SignalsRequestedSetsRow, error)

SelectFromSignalsRequestedSets mocks base method.

func (*MockDB) SelectFromTaskLists added in v1.2.7 

func (m *MockDB) SelectFromTaskLists(ctx context.Context, filter *TaskListsFilter) ([]TaskListsRow, error)

SelectFromTaskLists mocks base method.

func (*MockDB) SelectFromTasks added in v1.2.7 

func (m *MockDB) SelectFromTasks(ctx context.Context, filter *TasksFilter) ([]TasksRow, error)

SelectFromTasks mocks base method.

func (*MockDB) SelectFromTimerInfoMaps added in v1.2.7 

func (m *MockDB) SelectFromTimerInfoMaps(ctx context.Context, filter *TimerInfoMapsFilter) ([]TimerInfoMapsRow, error)

SelectFromTimerInfoMaps mocks base method.

func (*MockDB) SelectFromTimerTasks added in v1.2.7 

func (m *MockDB) SelectFromTimerTasks(ctx context.Context, filter *TimerTasksFilter) ([]TimerTasksRow, error)

SelectFromTimerTasks mocks base method.

func (*MockDB) SelectFromTransferTasks added in v1.2.7 

func (m *MockDB) SelectFromTransferTasks(ctx context.Context, filter *TransferTasksFilter) ([]TransferTasksRow, error)

SelectFromTransferTasks mocks base method.

func (*MockDB) SelectFromVisibility added in v1.2.7 

func (m *MockDB) SelectFromVisibility(ctx context.Context, filter *VisibilityFilter) ([]VisibilityRow, error)

SelectFromVisibility mocks base method.

func (*MockDB) SelectLatestConfig added in v1.2.7 

func (m *MockDB) SelectLatestConfig(ctx context.Context, rowType int) (*persistence.InternalConfigStoreEntry, error)

SelectLatestConfig mocks base method.

func (*MockDB) SupportsAsyncTransaction added in v1.2.7 

func (m *MockDB) SupportsAsyncTransaction() bool

SupportsAsyncTransaction mocks base method.

func (*MockDB) SupportsTTL added in v1.2.7 

func (m *MockDB) SupportsTTL() bool

SupportsTTL mocks base method.

func (*MockDB) UpdateAckLevels added in v1.2.7 

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

UpdateAckLevels mocks base method.

func (*MockDB) UpdateCurrentExecutions added in v1.2.7 

func (m *MockDB) UpdateCurrentExecutions(ctx context.Context, row *CurrentExecutionsRow) (sql.Result, error)

UpdateCurrentExecutions mocks base method.

func (*MockDB) UpdateDomain added in v1.2.7 

func (m *MockDB) UpdateDomain(ctx context.Context, row *DomainRow) (sql.Result, error)

UpdateDomain mocks base method.

func (*MockDB) UpdateDomainMetadata added in v1.2.7 

func (m *MockDB) UpdateDomainMetadata(ctx context.Context, row *DomainMetadataRow) (sql.Result, error)

UpdateDomainMetadata mocks base method.

func (*MockDB) UpdateExecutions added in v1.2.7 

func (m *MockDB) UpdateExecutions(ctx context.Context, row *ExecutionsRow) (sql.Result, error)

UpdateExecutions mocks base method.

func (*MockDB) UpdateShards added in v1.2.7 

func (m *MockDB) UpdateShards(ctx context.Context, row *ShardsRow) (sql.Result, error)

UpdateShards mocks base method.

func (*MockDB) UpdateTaskLists added in v1.2.7 

func (m *MockDB) UpdateTaskLists(ctx context.Context, row *TaskListsRow) (sql.Result, error)

UpdateTaskLists mocks base method.

func (*MockDB) UpdateTaskListsWithTTL added in v1.2.7 

func (m *MockDB) UpdateTaskListsWithTTL(ctx context.Context, row *TaskListsRowWithTTL) (sql.Result, error)

UpdateTaskListsWithTTL mocks base method.

func (*MockDB) WriteLockExecutions added in v1.2.7 

func (m *MockDB) WriteLockExecutions(ctx context.Context, filter *ExecutionsFilter) (int, error)

WriteLockExecutions mocks base method.

func (*MockDB) WriteLockShards added in v1.2.7 

func (m *MockDB) WriteLockShards(ctx context.Context, filter *ShardsFilter) (int, error)

WriteLockShards mocks base method.

type MockDBMockRecorder added in v1.2.7 

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

MockDBMockRecorder is the mock recorder for MockDB.

func (*MockDBMockRecorder) BeginTx added in v1.2.7 

func (mr *MockDBMockRecorder) BeginTx(ctx, dbShardID interface{}) *gomock.Call

BeginTx indicates an expected call of BeginTx.

func (*MockDBMockRecorder) Close added in v1.2.7 

func (mr *MockDBMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockDBMockRecorder) DeleteFromActivityInfoMaps added in v1.2.7 

func (mr *MockDBMockRecorder) DeleteFromActivityInfoMaps(ctx, filter interface{}) *gomock.Call

DeleteFromActivityInfoMaps indicates an expected call of DeleteFromActivityInfoMaps.

func (*MockDBMockRecorder) DeleteFromBufferedEvents added in v1.2.7 

func (mr *MockDBMockRecorder) DeleteFromBufferedEvents(ctx, filter interface{}) *gomock.Call

DeleteFromBufferedEvents indicates an expected call of DeleteFromBufferedEvents.

func (*MockDBMockRecorder) DeleteFromChildExecutionInfoMaps added in v1.2.7 

func (mr *MockDBMockRecorder) DeleteFromChildExecutionInfoMaps(ctx, filter interface{}) *gomock.Call

DeleteFromChildExecutionInfoMaps indicates an expected call of DeleteFromChildExecutionInfoMaps.

func (*MockDBMockRecorder) DeleteFromCrossClusterTasks added in v1.2.7 

func (mr *MockDBMockRecorder) DeleteFromCrossClusterTasks(ctx, filter interface{}) *gomock.Call

DeleteFromCrossClusterTasks indicates an expected call of DeleteFromCrossClusterTasks.

func (*MockDBMockRecorder) DeleteFromCurrentExecutions added in v1.2.7 

func (mr *MockDBMockRecorder) DeleteFromCurrentExecutions(ctx, filter interface{}) *gomock.Call

DeleteFromCurrentExecutions indicates an expected call of DeleteFromCurrentExecutions.

func (*MockDBMockRecorder) DeleteFromDomain added in v1.2.7 

func (mr *MockDBMockRecorder) DeleteFromDomain(ctx, filter interface{}) *gomock.Call

DeleteFromDomain indicates an expected call of DeleteFromDomain.

func (*MockDBMockRecorder) DeleteFromExecutions added in v1.2.7 

func (mr *MockDBMockRecorder) DeleteFromExecutions(ctx, filter interface{}) *gomock.Call

DeleteFromExecutions indicates an expected call of DeleteFromExecutions.

func (*MockDBMockRecorder) DeleteFromHistoryNode added in v1.2.7 

func (mr *MockDBMockRecorder) DeleteFromHistoryNode(ctx, filter interface{}) *gomock.Call

DeleteFromHistoryNode indicates an expected call of DeleteFromHistoryNode.

func (*MockDBMockRecorder) DeleteFromHistoryTree added in v1.2.7 

func (mr *MockDBMockRecorder) DeleteFromHistoryTree(ctx, filter interface{}) *gomock.Call

DeleteFromHistoryTree indicates an expected call of DeleteFromHistoryTree.

func (*MockDBMockRecorder) DeleteFromReplicationTasks added in v1.2.7 

func (mr *MockDBMockRecorder) DeleteFromReplicationTasks(ctx, filter interface{}) *gomock.Call

DeleteFromReplicationTasks indicates an expected call of DeleteFromReplicationTasks.

func (*MockDBMockRecorder) DeleteFromRequestCancelInfoMaps added in v1.2.7 

func (mr *MockDBMockRecorder) DeleteFromRequestCancelInfoMaps(ctx, filter interface{}) *gomock.Call

DeleteFromRequestCancelInfoMaps indicates an expected call of DeleteFromRequestCancelInfoMaps.

func (*MockDBMockRecorder) DeleteFromSignalInfoMaps added in v1.2.7 

func (mr *MockDBMockRecorder) DeleteFromSignalInfoMaps(ctx, filter interface{}) *gomock.Call

DeleteFromSignalInfoMaps indicates an expected call of DeleteFromSignalInfoMaps.

func (*MockDBMockRecorder) DeleteFromSignalsRequestedSets added in v1.2.7 

func (mr *MockDBMockRecorder) DeleteFromSignalsRequestedSets(ctx, filter interface{}) *gomock.Call

DeleteFromSignalsRequestedSets indicates an expected call of DeleteFromSignalsRequestedSets.

func (*MockDBMockRecorder) DeleteFromTaskLists added in v1.2.7 

func (mr *MockDBMockRecorder) DeleteFromTaskLists(ctx, filter interface{}) *gomock.Call

DeleteFromTaskLists indicates an expected call of DeleteFromTaskLists.

func (*MockDBMockRecorder) DeleteFromTasks added in v1.2.7 

func (mr *MockDBMockRecorder) DeleteFromTasks(ctx, filter interface{}) *gomock.Call

DeleteFromTasks indicates an expected call of DeleteFromTasks.

func (*MockDBMockRecorder) DeleteFromTimerInfoMaps added in v1.2.7 

func (mr *MockDBMockRecorder) DeleteFromTimerInfoMaps(ctx, filter interface{}) *gomock.Call

DeleteFromTimerInfoMaps indicates an expected call of DeleteFromTimerInfoMaps.

func (*MockDBMockRecorder) DeleteFromTimerTasks added in v1.2.7 

func (mr *MockDBMockRecorder) DeleteFromTimerTasks(ctx, filter interface{}) *gomock.Call

DeleteFromTimerTasks indicates an expected call of DeleteFromTimerTasks.

func (*MockDBMockRecorder) DeleteFromTransferTasks added in v1.2.7 

func (mr *MockDBMockRecorder) DeleteFromTransferTasks(ctx, filter interface{}) *gomock.Call

DeleteFromTransferTasks indicates an expected call of DeleteFromTransferTasks.

func (*MockDBMockRecorder) DeleteFromVisibility added in v1.2.7 

func (mr *MockDBMockRecorder) DeleteFromVisibility(ctx, filter interface{}) *gomock.Call

DeleteFromVisibility indicates an expected call of DeleteFromVisibility.

func (*MockDBMockRecorder) DeleteMessage added in v1.2.7 

func (mr *MockDBMockRecorder) DeleteMessage(ctx, queueType, messageID interface{}) *gomock.Call

DeleteMessage indicates an expected call of DeleteMessage.

func (*MockDBMockRecorder) DeleteMessageFromReplicationTasksDLQ added in v1.2.7 

func (mr *MockDBMockRecorder) DeleteMessageFromReplicationTasksDLQ(ctx, filter interface{}) *gomock.Call

DeleteMessageFromReplicationTasksDLQ indicates an expected call of DeleteMessageFromReplicationTasksDLQ.

func (*MockDBMockRecorder) DeleteMessagesBefore added in v1.2.7 

func (mr *MockDBMockRecorder) DeleteMessagesBefore(ctx, queueType, messageID interface{}) *gomock.Call

DeleteMessagesBefore indicates an expected call of DeleteMessagesBefore.

func (*MockDBMockRecorder) GetAckLevels added in v1.2.7 

func (mr *MockDBMockRecorder) GetAckLevels(ctx, queueType, forUpdate interface{}) *gomock.Call

GetAckLevels indicates an expected call of GetAckLevels.

func (*MockDBMockRecorder) GetAllHistoryTreeBranches added in v1.2.7 

func (mr *MockDBMockRecorder) GetAllHistoryTreeBranches(ctx, filter interface{}) *gomock.Call

GetAllHistoryTreeBranches indicates an expected call of GetAllHistoryTreeBranches.

func (*MockDBMockRecorder) GetLastEnqueuedMessageIDForUpdate added in v1.2.7 

func (mr *MockDBMockRecorder) GetLastEnqueuedMessageIDForUpdate(ctx, queueType interface{}) *gomock.Call

GetLastEnqueuedMessageIDForUpdate indicates an expected call of GetLastEnqueuedMessageIDForUpdate.

func (*MockDBMockRecorder) GetMessagesBetween added in v1.2.7 

func (mr *MockDBMockRecorder) GetMessagesBetween(ctx, queueType, firstMessageID, lastMessageID, maxRows interface{}) *gomock.Call

GetMessagesBetween indicates an expected call of GetMessagesBetween.

func (*MockDBMockRecorder) GetMessagesFromQueue added in v1.2.7 

func (mr *MockDBMockRecorder) GetMessagesFromQueue(ctx, queueType, lastMessageID, maxRows interface{}) *gomock.Call

GetMessagesFromQueue indicates an expected call of GetMessagesFromQueue.

func (*MockDBMockRecorder) GetOrphanTasks added in v1.2.7 

func (mr *MockDBMockRecorder) GetOrphanTasks(ctx, filter interface{}) *gomock.Call

GetOrphanTasks indicates an expected call of GetOrphanTasks.

func (*MockDBMockRecorder) GetQueueSize added in v1.2.7 

func (mr *MockDBMockRecorder) GetQueueSize(ctx, queueType interface{}) *gomock.Call

GetQueueSize indicates an expected call of GetQueueSize.

func (*MockDBMockRecorder) GetTasksCount added in v1.2.7 

func (mr *MockDBMockRecorder) GetTasksCount(ctx, filter interface{}) *gomock.Call

GetTasksCount indicates an expected call of GetTasksCount.

func (*MockDBMockRecorder) GetTotalNumDBShards added in v1.2.7 

func (mr *MockDBMockRecorder) GetTotalNumDBShards() *gomock.Call

GetTotalNumDBShards indicates an expected call of GetTotalNumDBShards.

func (*MockDBMockRecorder) InsertAckLevel added in v1.2.7 

func (mr *MockDBMockRecorder) InsertAckLevel(ctx, queueType, messageID, clusterName interface{}) *gomock.Call

InsertAckLevel indicates an expected call of InsertAckLevel.

func (*MockDBMockRecorder) InsertConfig added in v1.2.7 

func (mr *MockDBMockRecorder) InsertConfig(ctx, row interface{}) *gomock.Call

InsertConfig indicates an expected call of InsertConfig.

func (*MockDBMockRecorder) InsertIntoBufferedEvents added in v1.2.7 

func (mr *MockDBMockRecorder) InsertIntoBufferedEvents(ctx, rows interface{}) *gomock.Call

InsertIntoBufferedEvents indicates an expected call of InsertIntoBufferedEvents.

func (*MockDBMockRecorder) InsertIntoCrossClusterTasks added in v1.2.7 

func (mr *MockDBMockRecorder) InsertIntoCrossClusterTasks(ctx, rows interface{}) *gomock.Call

InsertIntoCrossClusterTasks indicates an expected call of InsertIntoCrossClusterTasks.

func (*MockDBMockRecorder) InsertIntoCurrentExecutions added in v1.2.7 

func (mr *MockDBMockRecorder) InsertIntoCurrentExecutions(ctx, row interface{}) *gomock.Call

InsertIntoCurrentExecutions indicates an expected call of InsertIntoCurrentExecutions.

func (*MockDBMockRecorder) InsertIntoDomain added in v1.2.7 

func (mr *MockDBMockRecorder) InsertIntoDomain(ctx, rows interface{}) *gomock.Call

InsertIntoDomain indicates an expected call of InsertIntoDomain.

func (*MockDBMockRecorder) InsertIntoExecutions added in v1.2.7 

func (mr *MockDBMockRecorder) InsertIntoExecutions(ctx, row interface{}) *gomock.Call

InsertIntoExecutions indicates an expected call of InsertIntoExecutions.

func (*MockDBMockRecorder) InsertIntoHistoryNode added in v1.2.7 

func (mr *MockDBMockRecorder) InsertIntoHistoryNode(ctx, row interface{}) *gomock.Call

InsertIntoHistoryNode indicates an expected call of InsertIntoHistoryNode.

func (*MockDBMockRecorder) InsertIntoHistoryTree added in v1.2.7 

func (mr *MockDBMockRecorder) InsertIntoHistoryTree(ctx, row interface{}) *gomock.Call

InsertIntoHistoryTree indicates an expected call of InsertIntoHistoryTree.

func (*MockDBMockRecorder) InsertIntoQueue added in v1.2.7 

func (mr *MockDBMockRecorder) InsertIntoQueue(ctx, row interface{}) *gomock.Call

InsertIntoQueue indicates an expected call of InsertIntoQueue.

func (*MockDBMockRecorder) InsertIntoReplicationTasks added in v1.2.7 

func (mr *MockDBMockRecorder) InsertIntoReplicationTasks(ctx, rows interface{}) *gomock.Call

InsertIntoReplicationTasks indicates an expected call of InsertIntoReplicationTasks.

func (*MockDBMockRecorder) InsertIntoReplicationTasksDLQ added in v1.2.7 

func (mr *MockDBMockRecorder) InsertIntoReplicationTasksDLQ(ctx, row interface{}) *gomock.Call

InsertIntoReplicationTasksDLQ indicates an expected call of InsertIntoReplicationTasksDLQ.

func (*MockDBMockRecorder) InsertIntoShards added in v1.2.7 

func (mr *MockDBMockRecorder) InsertIntoShards(ctx, rows interface{}) *gomock.Call

InsertIntoShards indicates an expected call of InsertIntoShards.

func (*MockDBMockRecorder) InsertIntoSignalsRequestedSets added in v1.2.7 

func (mr *MockDBMockRecorder) InsertIntoSignalsRequestedSets(ctx, rows interface{}) *gomock.Call

InsertIntoSignalsRequestedSets indicates an expected call of InsertIntoSignalsRequestedSets.

func (*MockDBMockRecorder) InsertIntoTaskLists added in v1.2.7 

func (mr *MockDBMockRecorder) InsertIntoTaskLists(ctx, row interface{}) *gomock.Call

InsertIntoTaskLists indicates an expected call of InsertIntoTaskLists.

func (*MockDBMockRecorder) InsertIntoTaskListsWithTTL added in v1.2.7 

func (mr *MockDBMockRecorder) InsertIntoTaskListsWithTTL(ctx, row interface{}) *gomock.Call

InsertIntoTaskListsWithTTL indicates an expected call of InsertIntoTaskListsWithTTL.

func (*MockDBMockRecorder) InsertIntoTasks added in v1.2.7 

func (mr *MockDBMockRecorder) InsertIntoTasks(ctx, rows interface{}) *gomock.Call

InsertIntoTasks indicates an expected call of InsertIntoTasks.

func (*MockDBMockRecorder) InsertIntoTasksWithTTL added in v1.2.7 

func (mr *MockDBMockRecorder) InsertIntoTasksWithTTL(ctx, rows interface{}) *gomock.Call

InsertIntoTasksWithTTL indicates an expected call of InsertIntoTasksWithTTL.

func (*MockDBMockRecorder) InsertIntoTimerTasks added in v1.2.7 

func (mr *MockDBMockRecorder) InsertIntoTimerTasks(ctx, rows interface{}) *gomock.Call

InsertIntoTimerTasks indicates an expected call of InsertIntoTimerTasks.

func (*MockDBMockRecorder) InsertIntoTransferTasks added in v1.2.7 

func (mr *MockDBMockRecorder) InsertIntoTransferTasks(ctx, rows interface{}) *gomock.Call

InsertIntoTransferTasks indicates an expected call of InsertIntoTransferTasks.

func (*MockDBMockRecorder) InsertIntoVisibility added in v1.2.7 

func (mr *MockDBMockRecorder) InsertIntoVisibility(ctx, row interface{}) *gomock.Call

InsertIntoVisibility indicates an expected call of InsertIntoVisibility.

func (*MockDBMockRecorder) IsDupEntryError added in v1.2.7 

func (mr *MockDBMockRecorder) IsDupEntryError(err interface{}) *gomock.Call

IsDupEntryError indicates an expected call of IsDupEntryError.

func (*MockDBMockRecorder) IsNotFoundError added in v1.2.7 

func (mr *MockDBMockRecorder) IsNotFoundError(err interface{}) *gomock.Call

IsNotFoundError indicates an expected call of IsNotFoundError.

func (*MockDBMockRecorder) IsThrottlingError added in v1.2.7 

func (mr *MockDBMockRecorder) IsThrottlingError(err interface{}) *gomock.Call

IsThrottlingError indicates an expected call of IsThrottlingError.

func (*MockDBMockRecorder) IsTimeoutError added in v1.2.7 

func (mr *MockDBMockRecorder) IsTimeoutError(err interface{}) *gomock.Call

IsTimeoutError indicates an expected call of IsTimeoutError.

func (*MockDBMockRecorder) LockCurrentExecutions added in v1.2.7 

func (mr *MockDBMockRecorder) LockCurrentExecutions(ctx, filter interface{}) *gomock.Call

LockCurrentExecutions indicates an expected call of LockCurrentExecutions.

func (*MockDBMockRecorder) LockCurrentExecutionsJoinExecutions added in v1.2.7 

func (mr *MockDBMockRecorder) LockCurrentExecutionsJoinExecutions(ctx, filter interface{}) *gomock.Call

LockCurrentExecutionsJoinExecutions indicates an expected call of LockCurrentExecutionsJoinExecutions.

func (*MockDBMockRecorder) LockDomainMetadata added in v1.2.7 

func (mr *MockDBMockRecorder) LockDomainMetadata(ctx interface{}) *gomock.Call

LockDomainMetadata indicates an expected call of LockDomainMetadata.

func (*MockDBMockRecorder) LockTaskLists added in v1.2.7 

func (mr *MockDBMockRecorder) LockTaskLists(ctx, filter interface{}) *gomock.Call

LockTaskLists indicates an expected call of LockTaskLists.

func (*MockDBMockRecorder) MaxAllowedTTL added in v1.2.7 

func (mr *MockDBMockRecorder) MaxAllowedTTL() *gomock.Call

MaxAllowedTTL indicates an expected call of MaxAllowedTTL.

func (*MockDBMockRecorder) PluginName added in v1.2.7 

func (mr *MockDBMockRecorder) PluginName() *gomock.Call

PluginName indicates an expected call of PluginName.

func (*MockDBMockRecorder) RangeDeleteFromCrossClusterTasks added in v1.2.7 

func (mr *MockDBMockRecorder) RangeDeleteFromCrossClusterTasks(ctx, filter interface{}) *gomock.Call

RangeDeleteFromCrossClusterTasks indicates an expected call of RangeDeleteFromCrossClusterTasks.

func (*MockDBMockRecorder) RangeDeleteFromReplicationTasks added in v1.2.7 

func (mr *MockDBMockRecorder) RangeDeleteFromReplicationTasks(ctx, filter interface{}) *gomock.Call

RangeDeleteFromReplicationTasks indicates an expected call of RangeDeleteFromReplicationTasks.

func (*MockDBMockRecorder) RangeDeleteFromTimerTasks added in v1.2.7 

func (mr *MockDBMockRecorder) RangeDeleteFromTimerTasks(ctx, filter interface{}) *gomock.Call

RangeDeleteFromTimerTasks indicates an expected call of RangeDeleteFromTimerTasks.

func (*MockDBMockRecorder) RangeDeleteFromTransferTasks added in v1.2.7 

func (mr *MockDBMockRecorder) RangeDeleteFromTransferTasks(ctx, filter interface{}) *gomock.Call

RangeDeleteFromTransferTasks indicates an expected call of RangeDeleteFromTransferTasks.

func (*MockDBMockRecorder) RangeDeleteMessageFromReplicationTasksDLQ added in v1.2.7 

func (mr *MockDBMockRecorder) RangeDeleteMessageFromReplicationTasksDLQ(ctx, filter interface{}) *gomock.Call

RangeDeleteMessageFromReplicationTasksDLQ indicates an expected call of RangeDeleteMessageFromReplicationTasksDLQ.

func (*MockDBMockRecorder) RangeDeleteMessages added in v1.2.7 

func (mr *MockDBMockRecorder) RangeDeleteMessages(ctx, queueType, exclusiveBeginMessageID, inclusiveEndMessageID interface{}) *gomock.Call

RangeDeleteMessages indicates an expected call of RangeDeleteMessages.

func (*MockDBMockRecorder) ReadLockExecutions added in v1.2.7 

func (mr *MockDBMockRecorder) ReadLockExecutions(ctx, filter interface{}) *gomock.Call

ReadLockExecutions indicates an expected call of ReadLockExecutions.

func (*MockDBMockRecorder) ReadLockShards added in v1.2.7 

func (mr *MockDBMockRecorder) ReadLockShards(ctx, filter interface{}) *gomock.Call

ReadLockShards indicates an expected call of ReadLockShards.

func (*MockDBMockRecorder) ReplaceIntoActivityInfoMaps added in v1.2.7 

func (mr *MockDBMockRecorder) ReplaceIntoActivityInfoMaps(ctx, rows interface{}) *gomock.Call

ReplaceIntoActivityInfoMaps indicates an expected call of ReplaceIntoActivityInfoMaps.

func (*MockDBMockRecorder) ReplaceIntoChildExecutionInfoMaps added in v1.2.7 

func (mr *MockDBMockRecorder) ReplaceIntoChildExecutionInfoMaps(ctx, rows interface{}) *gomock.Call

ReplaceIntoChildExecutionInfoMaps indicates an expected call of ReplaceIntoChildExecutionInfoMaps.

func (*MockDBMockRecorder) ReplaceIntoRequestCancelInfoMaps added in v1.2.7 

func (mr *MockDBMockRecorder) ReplaceIntoRequestCancelInfoMaps(ctx, rows interface{}) *gomock.Call

ReplaceIntoRequestCancelInfoMaps indicates an expected call of ReplaceIntoRequestCancelInfoMaps.

func (*MockDBMockRecorder) ReplaceIntoSignalInfoMaps added in v1.2.7 

func (mr *MockDBMockRecorder) ReplaceIntoSignalInfoMaps(ctx, rows interface{}) *gomock.Call

ReplaceIntoSignalInfoMaps indicates an expected call of ReplaceIntoSignalInfoMaps.

func (*MockDBMockRecorder) ReplaceIntoTimerInfoMaps added in v1.2.7 

func (mr *MockDBMockRecorder) ReplaceIntoTimerInfoMaps(ctx, rows interface{}) *gomock.Call

ReplaceIntoTimerInfoMaps indicates an expected call of ReplaceIntoTimerInfoMaps.

func (*MockDBMockRecorder) ReplaceIntoVisibility added in v1.2.7 

func (mr *MockDBMockRecorder) ReplaceIntoVisibility(ctx, row interface{}) *gomock.Call

ReplaceIntoVisibility indicates an expected call of ReplaceIntoVisibility.

func (*MockDBMockRecorder) SelectFromActivityInfoMaps added in v1.2.7 

func (mr *MockDBMockRecorder) SelectFromActivityInfoMaps(ctx, filter interface{}) *gomock.Call

SelectFromActivityInfoMaps indicates an expected call of SelectFromActivityInfoMaps.

func (*MockDBMockRecorder) SelectFromBufferedEvents added in v1.2.7 

func (mr *MockDBMockRecorder) SelectFromBufferedEvents(ctx, filter interface{}) *gomock.Call

SelectFromBufferedEvents indicates an expected call of SelectFromBufferedEvents.

func (*MockDBMockRecorder) SelectFromChildExecutionInfoMaps added in v1.2.7 

func (mr *MockDBMockRecorder) SelectFromChildExecutionInfoMaps(ctx, filter interface{}) *gomock.Call

SelectFromChildExecutionInfoMaps indicates an expected call of SelectFromChildExecutionInfoMaps.

func (*MockDBMockRecorder) SelectFromCrossClusterTasks added in v1.2.7 

func (mr *MockDBMockRecorder) SelectFromCrossClusterTasks(ctx, filter interface{}) *gomock.Call

SelectFromCrossClusterTasks indicates an expected call of SelectFromCrossClusterTasks.

func (*MockDBMockRecorder) SelectFromCurrentExecutions added in v1.2.7 

func (mr *MockDBMockRecorder) SelectFromCurrentExecutions(ctx, filter interface{}) *gomock.Call

SelectFromCurrentExecutions indicates an expected call of SelectFromCurrentExecutions.

func (*MockDBMockRecorder) SelectFromDomain added in v1.2.7 

func (mr *MockDBMockRecorder) SelectFromDomain(ctx, filter interface{}) *gomock.Call

SelectFromDomain indicates an expected call of SelectFromDomain.

func (*MockDBMockRecorder) SelectFromDomainMetadata added in v1.2.7 

func (mr *MockDBMockRecorder) SelectFromDomainMetadata(ctx interface{}) *gomock.Call

SelectFromDomainMetadata indicates an expected call of SelectFromDomainMetadata.

func (*MockDBMockRecorder) SelectFromExecutions added in v1.2.7 

func (mr *MockDBMockRecorder) SelectFromExecutions(ctx, filter interface{}) *gomock.Call

SelectFromExecutions indicates an expected call of SelectFromExecutions.

func (*MockDBMockRecorder) SelectFromHistoryNode added in v1.2.7 

func (mr *MockDBMockRecorder) SelectFromHistoryNode(ctx, filter interface{}) *gomock.Call

SelectFromHistoryNode indicates an expected call of SelectFromHistoryNode.

func (*MockDBMockRecorder) SelectFromHistoryTree added in v1.2.7 

func (mr *MockDBMockRecorder) SelectFromHistoryTree(ctx, filter interface{}) *gomock.Call

SelectFromHistoryTree indicates an expected call of SelectFromHistoryTree.

func (*MockDBMockRecorder) SelectFromReplicationDLQ added in v1.2.7 

func (mr *MockDBMockRecorder) SelectFromReplicationDLQ(ctx, filter interface{}) *gomock.Call

SelectFromReplicationDLQ indicates an expected call of SelectFromReplicationDLQ.

func (*MockDBMockRecorder) SelectFromReplicationTasks added in v1.2.7 

func (mr *MockDBMockRecorder) SelectFromReplicationTasks(ctx, filter interface{}) *gomock.Call

SelectFromReplicationTasks indicates an expected call of SelectFromReplicationTasks.

func (*MockDBMockRecorder) SelectFromReplicationTasksDLQ added in v1.2.7 

func (mr *MockDBMockRecorder) SelectFromReplicationTasksDLQ(ctx, filter interface{}) *gomock.Call

SelectFromReplicationTasksDLQ indicates an expected call of SelectFromReplicationTasksDLQ.

func (*MockDBMockRecorder) SelectFromRequestCancelInfoMaps added in v1.2.7 

func (mr *MockDBMockRecorder) SelectFromRequestCancelInfoMaps(ctx, filter interface{}) *gomock.Call

SelectFromRequestCancelInfoMaps indicates an expected call of SelectFromRequestCancelInfoMaps.

func (*MockDBMockRecorder) SelectFromShards added in v1.2.7 

func (mr *MockDBMockRecorder) SelectFromShards(ctx, filter interface{}) *gomock.Call

SelectFromShards indicates an expected call of SelectFromShards.

func (*MockDBMockRecorder) SelectFromSignalInfoMaps added in v1.2.7 

func (mr *MockDBMockRecorder) SelectFromSignalInfoMaps(ctx, filter interface{}) *gomock.Call

SelectFromSignalInfoMaps indicates an expected call of SelectFromSignalInfoMaps.

func (*MockDBMockRecorder) SelectFromSignalsRequestedSets added in v1.2.7 

func (mr *MockDBMockRecorder) SelectFromSignalsRequestedSets(ctx, filter interface{}) *gomock.Call

SelectFromSignalsRequestedSets indicates an expected call of SelectFromSignalsRequestedSets.

func (*MockDBMockRecorder) SelectFromTaskLists added in v1.2.7 

func (mr *MockDBMockRecorder) SelectFromTaskLists(ctx, filter interface{}) *gomock.Call

SelectFromTaskLists indicates an expected call of SelectFromTaskLists.

func (*MockDBMockRecorder) SelectFromTasks added in v1.2.7 

func (mr *MockDBMockRecorder) SelectFromTasks(ctx, filter interface{}) *gomock.Call

SelectFromTasks indicates an expected call of SelectFromTasks.

func (*MockDBMockRecorder) SelectFromTimerInfoMaps added in v1.2.7 

func (mr *MockDBMockRecorder) SelectFromTimerInfoMaps(ctx, filter interface{}) *gomock.Call

SelectFromTimerInfoMaps indicates an expected call of SelectFromTimerInfoMaps.

func (*MockDBMockRecorder) SelectFromTimerTasks added in v1.2.7 

func (mr *MockDBMockRecorder) SelectFromTimerTasks(ctx, filter interface{}) *gomock.Call

SelectFromTimerTasks indicates an expected call of SelectFromTimerTasks.

func (*MockDBMockRecorder) SelectFromTransferTasks added in v1.2.7 

func (mr *MockDBMockRecorder) SelectFromTransferTasks(ctx, filter interface{}) *gomock.Call

SelectFromTransferTasks indicates an expected call of SelectFromTransferTasks.

func (*MockDBMockRecorder) SelectFromVisibility added in v1.2.7 

func (mr *MockDBMockRecorder) SelectFromVisibility(ctx, filter interface{}) *gomock.Call

SelectFromVisibility indicates an expected call of SelectFromVisibility.

func (*MockDBMockRecorder) SelectLatestConfig added in v1.2.7 

func (mr *MockDBMockRecorder) SelectLatestConfig(ctx, rowType interface{}) *gomock.Call

SelectLatestConfig indicates an expected call of SelectLatestConfig.

func (*MockDBMockRecorder) SupportsAsyncTransaction added in v1.2.7 

func (mr *MockDBMockRecorder) SupportsAsyncTransaction() *gomock.Call

SupportsAsyncTransaction indicates an expected call of SupportsAsyncTransaction.

func (*MockDBMockRecorder) SupportsTTL added in v1.2.7 

func (mr *MockDBMockRecorder) SupportsTTL() *gomock.Call

SupportsTTL indicates an expected call of SupportsTTL.

func (*MockDBMockRecorder) UpdateAckLevels added in v1.2.7 

func (mr *MockDBMockRecorder) UpdateAckLevels(ctx, queueType, clusterAckLevels interface{}) *gomock.Call

UpdateAckLevels indicates an expected call of UpdateAckLevels.

func (*MockDBMockRecorder) UpdateCurrentExecutions added in v1.2.7 

func (mr *MockDBMockRecorder) UpdateCurrentExecutions(ctx, row interface{}) *gomock.Call

UpdateCurrentExecutions indicates an expected call of UpdateCurrentExecutions.

func (*MockDBMockRecorder) UpdateDomain added in v1.2.7 

func (mr *MockDBMockRecorder) UpdateDomain(ctx, row interface{}) *gomock.Call

UpdateDomain indicates an expected call of UpdateDomain.

func (*MockDBMockRecorder) UpdateDomainMetadata added in v1.2.7 

func (mr *MockDBMockRecorder) UpdateDomainMetadata(ctx, row interface{}) *gomock.Call

UpdateDomainMetadata indicates an expected call of UpdateDomainMetadata.

func (*MockDBMockRecorder) UpdateExecutions added in v1.2.7 

func (mr *MockDBMockRecorder) UpdateExecutions(ctx, row interface{}) *gomock.Call

UpdateExecutions indicates an expected call of UpdateExecutions.

func (*MockDBMockRecorder) UpdateShards added in v1.2.7 

func (mr *MockDBMockRecorder) UpdateShards(ctx, row interface{}) *gomock.Call

UpdateShards indicates an expected call of UpdateShards.

func (*MockDBMockRecorder) UpdateTaskLists added in v1.2.7 

func (mr *MockDBMockRecorder) UpdateTaskLists(ctx, row interface{}) *gomock.Call

UpdateTaskLists indicates an expected call of UpdateTaskLists.

func (*MockDBMockRecorder) UpdateTaskListsWithTTL added in v1.2.7 

func (mr *MockDBMockRecorder) UpdateTaskListsWithTTL(ctx, row interface{}) *gomock.Call

UpdateTaskListsWithTTL indicates an expected call of UpdateTaskListsWithTTL.

func (*MockDBMockRecorder) WriteLockExecutions added in v1.2.7 

func (mr *MockDBMockRecorder) WriteLockExecutions(ctx, filter interface{}) *gomock.Call

WriteLockExecutions indicates an expected call of WriteLockExecutions.

func (*MockDBMockRecorder) WriteLockShards added in v1.2.7 

func (mr *MockDBMockRecorder) WriteLockShards(ctx, filter interface{}) *gomock.Call

WriteLockShards indicates an expected call of WriteLockShards.

type MockErrorChecker added in v1.2.7 

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

MockErrorChecker is a mock of ErrorChecker interface.

func NewMockErrorChecker added in v1.2.7 

func NewMockErrorChecker(ctrl *gomock.Controller) *MockErrorChecker

NewMockErrorChecker creates a new mock instance.

func (*MockErrorChecker) EXPECT added in v1.2.7 

func (m *MockErrorChecker) EXPECT() *MockErrorCheckerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockErrorChecker) IsDupEntryError added in v1.2.7 

func (m *MockErrorChecker) IsDupEntryError(err error) bool

IsDupEntryError mocks base method.

func (*MockErrorChecker) IsNotFoundError added in v1.2.7 

func (m *MockErrorChecker) IsNotFoundError(err error) bool

IsNotFoundError mocks base method.

func (*MockErrorChecker) IsThrottlingError added in v1.2.7 

func (m *MockErrorChecker) IsThrottlingError(err error) bool

IsThrottlingError mocks base method.

func (*MockErrorChecker) IsTimeoutError added in v1.2.7 

func (m *MockErrorChecker) IsTimeoutError(err error) bool

IsTimeoutError mocks base method.

type MockErrorCheckerMockRecorder added in v1.2.7 

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

MockErrorCheckerMockRecorder is the mock recorder for MockErrorChecker.

func (*MockErrorCheckerMockRecorder) IsDupEntryError added in v1.2.7 

func (mr *MockErrorCheckerMockRecorder) IsDupEntryError(err interface{}) *gomock.Call

IsDupEntryError indicates an expected call of IsDupEntryError.

func (*MockErrorCheckerMockRecorder) IsNotFoundError added in v1.2.7 

func (mr *MockErrorCheckerMockRecorder) IsNotFoundError(err interface{}) *gomock.Call

IsNotFoundError indicates an expected call of IsNotFoundError.

func (*MockErrorCheckerMockRecorder) IsThrottlingError added in v1.2.7 

func (mr *MockErrorCheckerMockRecorder) IsThrottlingError(err interface{}) *gomock.Call

IsThrottlingError indicates an expected call of IsThrottlingError.

func (*MockErrorCheckerMockRecorder) IsTimeoutError added in v1.2.7 

func (mr *MockErrorCheckerMockRecorder) IsTimeoutError(err interface{}) *gomock.Call

IsTimeoutError indicates an expected call of IsTimeoutError.

type MockPlugin added in v1.2.7 

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

MockPlugin is a mock of Plugin interface.

func NewMockPlugin added in v1.2.7 

func NewMockPlugin(ctrl *gomock.Controller) *MockPlugin

NewMockPlugin creates a new mock instance.

func (*MockPlugin) CreateAdminDB added in v1.2.7 

func (m *MockPlugin) CreateAdminDB(cfg *config.SQL) (AdminDB, error)

CreateAdminDB mocks base method.

func (*MockPlugin) CreateDB added in v1.2.7 

func (m *MockPlugin) CreateDB(cfg *config.SQL) (DB, error)

CreateDB mocks base method.

func (*MockPlugin) EXPECT added in v1.2.7 

func (m *MockPlugin) EXPECT() *MockPluginMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

type MockPluginMockRecorder added in v1.2.7 

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

MockPluginMockRecorder is the mock recorder for MockPlugin.

func (*MockPluginMockRecorder) CreateAdminDB added in v1.2.7 

func (mr *MockPluginMockRecorder) CreateAdminDB(cfg interface{}) *gomock.Call

CreateAdminDB indicates an expected call of CreateAdminDB.

func (*MockPluginMockRecorder) CreateDB added in v1.2.7 

func (mr *MockPluginMockRecorder) CreateDB(cfg interface{}) *gomock.Call

CreateDB indicates an expected call of CreateDB.

type MockTx added in v1.2.7 

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

MockTx is a mock of Tx interface.

func NewMockTx added in v1.2.7 

func NewMockTx(ctrl *gomock.Controller) *MockTx

NewMockTx creates a new mock instance.

func (*MockTx) Commit added in v1.2.7 

func (m *MockTx) Commit() error

Commit mocks base method.

func (*MockTx) DeleteFromActivityInfoMaps added in v1.2.7 

func (m *MockTx) DeleteFromActivityInfoMaps(ctx context.Context, filter *ActivityInfoMapsFilter) (sql.Result, error)

DeleteFromActivityInfoMaps mocks base method.

func (*MockTx) DeleteFromBufferedEvents added in v1.2.7 

func (m *MockTx) DeleteFromBufferedEvents(ctx context.Context, filter *BufferedEventsFilter) (sql.Result, error)

DeleteFromBufferedEvents mocks base method.

func (*MockTx) DeleteFromChildExecutionInfoMaps added in v1.2.7 

func (m *MockTx) DeleteFromChildExecutionInfoMaps(ctx context.Context, filter *ChildExecutionInfoMapsFilter) (sql.Result, error)

DeleteFromChildExecutionInfoMaps mocks base method.

func (*MockTx) DeleteFromCrossClusterTasks added in v1.2.7 

func (m *MockTx) DeleteFromCrossClusterTasks(ctx context.Context, filter *CrossClusterTasksFilter) (sql.Result, error)

DeleteFromCrossClusterTasks mocks base method.

func (*MockTx) DeleteFromCurrentExecutions added in v1.2.7 

func (m *MockTx) DeleteFromCurrentExecutions(ctx context.Context, filter *CurrentExecutionsFilter) (sql.Result, error)

DeleteFromCurrentExecutions mocks base method.

func (*MockTx) DeleteFromDomain added in v1.2.7 

func (m *MockTx) DeleteFromDomain(ctx context.Context, filter *DomainFilter) (sql.Result, error)

DeleteFromDomain mocks base method.

func (*MockTx) DeleteFromExecutions added in v1.2.7 

func (m *MockTx) DeleteFromExecutions(ctx context.Context, filter *ExecutionsFilter) (sql.Result, error)

DeleteFromExecutions mocks base method.

func (*MockTx) DeleteFromHistoryNode added in v1.2.7 

func (m *MockTx) DeleteFromHistoryNode(ctx context.Context, filter *HistoryNodeFilter) (sql.Result, error)

DeleteFromHistoryNode mocks base method.

func (*MockTx) DeleteFromHistoryTree added in v1.2.7 

func (m *MockTx) DeleteFromHistoryTree(ctx context.Context, filter *HistoryTreeFilter) (sql.Result, error)

DeleteFromHistoryTree mocks base method.

func (*MockTx) DeleteFromReplicationTasks added in v1.2.7 

func (m *MockTx) DeleteFromReplicationTasks(ctx context.Context, filter *ReplicationTasksFilter) (sql.Result, error)

DeleteFromReplicationTasks mocks base method.

func (*MockTx) DeleteFromRequestCancelInfoMaps added in v1.2.7 

func (m *MockTx) DeleteFromRequestCancelInfoMaps(ctx context.Context, filter *RequestCancelInfoMapsFilter) (sql.Result, error)

DeleteFromRequestCancelInfoMaps mocks base method.

func (*MockTx) DeleteFromSignalInfoMaps added in v1.2.7 

func (m *MockTx) DeleteFromSignalInfoMaps(ctx context.Context, filter *SignalInfoMapsFilter) (sql.Result, error)

DeleteFromSignalInfoMaps mocks base method.

func (*MockTx) DeleteFromSignalsRequestedSets added in v1.2.7 

func (m *MockTx) DeleteFromSignalsRequestedSets(ctx context.Context, filter *SignalsRequestedSetsFilter) (sql.Result, error)

DeleteFromSignalsRequestedSets mocks base method.

func (*MockTx) DeleteFromTaskLists added in v1.2.7 

func (m *MockTx) DeleteFromTaskLists(ctx context.Context, filter *TaskListsFilter) (sql.Result, error)

DeleteFromTaskLists mocks base method.

func (*MockTx) DeleteFromTasks added in v1.2.7 

func (m *MockTx) DeleteFromTasks(ctx context.Context, filter *TasksFilter) (sql.Result, error)

DeleteFromTasks mocks base method.

func (*MockTx) DeleteFromTimerInfoMaps added in v1.2.7 

func (m *MockTx) DeleteFromTimerInfoMaps(ctx context.Context, filter *TimerInfoMapsFilter) (sql.Result, error)

DeleteFromTimerInfoMaps mocks base method.

func (*MockTx) DeleteFromTimerTasks added in v1.2.7 

func (m *MockTx) DeleteFromTimerTasks(ctx context.Context, filter *TimerTasksFilter) (sql.Result, error)

DeleteFromTimerTasks mocks base method.

func (*MockTx) DeleteFromTransferTasks added in v1.2.7 

func (m *MockTx) DeleteFromTransferTasks(ctx context.Context, filter *TransferTasksFilter) (sql.Result, error)

DeleteFromTransferTasks mocks base method.

func (*MockTx) DeleteFromVisibility added in v1.2.7 

func (m *MockTx) DeleteFromVisibility(ctx context.Context, filter *VisibilityFilter) (sql.Result, error)

DeleteFromVisibility mocks base method.

func (*MockTx) DeleteMessage added in v1.2.7 

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

DeleteMessage mocks base method.

func (*MockTx) DeleteMessageFromReplicationTasksDLQ added in v1.2.7 

func (m *MockTx) DeleteMessageFromReplicationTasksDLQ(ctx context.Context, filter *ReplicationTasksDLQFilter) (sql.Result, error)

DeleteMessageFromReplicationTasksDLQ mocks base method.

func (*MockTx) DeleteMessagesBefore added in v1.2.7 

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

DeleteMessagesBefore mocks base method.

func (*MockTx) EXPECT added in v1.2.7 

func (m *MockTx) EXPECT() *MockTxMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockTx) GetAckLevels added in v1.2.7 

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

GetAckLevels mocks base method.

func (*MockTx) GetAllHistoryTreeBranches added in v1.2.7 

func (m *MockTx) GetAllHistoryTreeBranches(ctx context.Context, filter *HistoryTreeFilter) ([]HistoryTreeRow, error)

GetAllHistoryTreeBranches mocks base method.

func (*MockTx) GetLastEnqueuedMessageIDForUpdate added in v1.2.7 

func (m *MockTx) GetLastEnqueuedMessageIDForUpdate(ctx context.Context, queueType persistence.QueueType) (int64, error)

GetLastEnqueuedMessageIDForUpdate mocks base method.

func (*MockTx) GetMessagesBetween added in v1.2.7 

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

GetMessagesBetween mocks base method.

func (*MockTx) GetMessagesFromQueue added in v1.2.7 

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

GetMessagesFromQueue mocks base method.

func (*MockTx) GetOrphanTasks added in v1.2.7 

func (m *MockTx) GetOrphanTasks(ctx context.Context, filter *OrphanTasksFilter) ([]TaskKeyRow, error)

GetOrphanTasks mocks base method.

func (*MockTx) GetQueueSize added in v1.2.7 

func (m *MockTx) GetQueueSize(ctx context.Context, queueType persistence.QueueType) (int64, error)

GetQueueSize mocks base method.

func (*MockTx) GetTasksCount added in v1.2.7 

func (m *MockTx) GetTasksCount(ctx context.Context, filter *TasksFilter) (int64, error)

GetTasksCount mocks base method.

func (*MockTx) InsertAckLevel added in v1.2.7 

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

InsertAckLevel mocks base method.

func (*MockTx) InsertConfig added in v1.2.7 

func (m *MockTx) InsertConfig(ctx context.Context, row *persistence.InternalConfigStoreEntry) error

InsertConfig mocks base method.

func (*MockTx) InsertIntoBufferedEvents added in v1.2.7 

func (m *MockTx) InsertIntoBufferedEvents(ctx context.Context, rows []BufferedEventsRow) (sql.Result, error)

InsertIntoBufferedEvents mocks base method.

func (*MockTx) InsertIntoCrossClusterTasks added in v1.2.7 

func (m *MockTx) InsertIntoCrossClusterTasks(ctx context.Context, rows []CrossClusterTasksRow) (sql.Result, error)

InsertIntoCrossClusterTasks mocks base method.

func (*MockTx) InsertIntoCurrentExecutions added in v1.2.7 

func (m *MockTx) InsertIntoCurrentExecutions(ctx context.Context, row *CurrentExecutionsRow) (sql.Result, error)

InsertIntoCurrentExecutions mocks base method.

func (*MockTx) InsertIntoDomain added in v1.2.7 

func (m *MockTx) InsertIntoDomain(ctx context.Context, rows *DomainRow) (sql.Result, error)

InsertIntoDomain mocks base method.

func (*MockTx) InsertIntoExecutions added in v1.2.7 

func (m *MockTx) InsertIntoExecutions(ctx context.Context, row *ExecutionsRow) (sql.Result, error)

InsertIntoExecutions mocks base method.

func (*MockTx) InsertIntoHistoryNode added in v1.2.7 

func (m *MockTx) InsertIntoHistoryNode(ctx context.Context, row *HistoryNodeRow) (sql.Result, error)

InsertIntoHistoryNode mocks base method.

func (*MockTx) InsertIntoHistoryTree added in v1.2.7 

func (m *MockTx) InsertIntoHistoryTree(ctx context.Context, row *HistoryTreeRow) (sql.Result, error)

InsertIntoHistoryTree mocks base method.

func (*MockTx) InsertIntoQueue added in v1.2.7 

func (m *MockTx) InsertIntoQueue(ctx context.Context, row *QueueRow) (sql.Result, error)

InsertIntoQueue mocks base method.

func (*MockTx) InsertIntoReplicationTasks added in v1.2.7 

func (m *MockTx) InsertIntoReplicationTasks(ctx context.Context, rows []ReplicationTasksRow) (sql.Result, error)

InsertIntoReplicationTasks mocks base method.

func (*MockTx) InsertIntoReplicationTasksDLQ added in v1.2.7 

func (m *MockTx) InsertIntoReplicationTasksDLQ(ctx context.Context, row *ReplicationTaskDLQRow) (sql.Result, error)

InsertIntoReplicationTasksDLQ mocks base method.

func (*MockTx) InsertIntoShards added in v1.2.7 

func (m *MockTx) InsertIntoShards(ctx context.Context, rows *ShardsRow) (sql.Result, error)

InsertIntoShards mocks base method.

func (*MockTx) InsertIntoSignalsRequestedSets added in v1.2.7 

func (m *MockTx) InsertIntoSignalsRequestedSets(ctx context.Context, rows []SignalsRequestedSetsRow) (sql.Result, error)

InsertIntoSignalsRequestedSets mocks base method.

func (*MockTx) InsertIntoTaskLists added in v1.2.7 

func (m *MockTx) InsertIntoTaskLists(ctx context.Context, row *TaskListsRow) (sql.Result, error)

InsertIntoTaskLists mocks base method.

func (*MockTx) InsertIntoTaskListsWithTTL added in v1.2.7 

func (m *MockTx) InsertIntoTaskListsWithTTL(ctx context.Context, row *TaskListsRowWithTTL) (sql.Result, error)

InsertIntoTaskListsWithTTL mocks base method.

func (*MockTx) InsertIntoTasks added in v1.2.7 

func (m *MockTx) InsertIntoTasks(ctx context.Context, rows []TasksRow) (sql.Result, error)

InsertIntoTasks mocks base method.

func (*MockTx) InsertIntoTasksWithTTL added in v1.2.7 

func (m *MockTx) InsertIntoTasksWithTTL(ctx context.Context, rows []TasksRowWithTTL) (sql.Result, error)

InsertIntoTasksWithTTL mocks base method.

func (*MockTx) InsertIntoTimerTasks added in v1.2.7 

func (m *MockTx) InsertIntoTimerTasks(ctx context.Context, rows []TimerTasksRow) (sql.Result, error)

InsertIntoTimerTasks mocks base method.

func (*MockTx) InsertIntoTransferTasks added in v1.2.7 

func (m *MockTx) InsertIntoTransferTasks(ctx context.Context, rows []TransferTasksRow) (sql.Result, error)

InsertIntoTransferTasks mocks base method.

func (*MockTx) InsertIntoVisibility added in v1.2.7 

func (m *MockTx) InsertIntoVisibility(ctx context.Context, row *VisibilityRow) (sql.Result, error)

InsertIntoVisibility mocks base method.

func (*MockTx) IsDupEntryError added in v1.2.7 

func (m *MockTx) IsDupEntryError(err error) bool

IsDupEntryError mocks base method.

func (*MockTx) IsNotFoundError added in v1.2.7 

func (m *MockTx) IsNotFoundError(err error) bool

IsNotFoundError mocks base method.

func (*MockTx) IsThrottlingError added in v1.2.7 

func (m *MockTx) IsThrottlingError(err error) bool

IsThrottlingError mocks base method.

func (*MockTx) IsTimeoutError added in v1.2.7 

func (m *MockTx) IsTimeoutError(err error) bool

IsTimeoutError mocks base method.

func (*MockTx) LockCurrentExecutions added in v1.2.7 

func (m *MockTx) LockCurrentExecutions(ctx context.Context, filter *CurrentExecutionsFilter) (*CurrentExecutionsRow, error)

LockCurrentExecutions mocks base method.

func (*MockTx) LockCurrentExecutionsJoinExecutions added in v1.2.7 

func (m *MockTx) LockCurrentExecutionsJoinExecutions(ctx context.Context, filter *CurrentExecutionsFilter) ([]CurrentExecutionsRow, error)

LockCurrentExecutionsJoinExecutions mocks base method.

func (*MockTx) LockDomainMetadata added in v1.2.7 

func (m *MockTx) LockDomainMetadata(ctx context.Context) error

LockDomainMetadata mocks base method.

func (*MockTx) LockTaskLists added in v1.2.7 

func (m *MockTx) LockTaskLists(ctx context.Context, filter *TaskListsFilter) (int64, error)

LockTaskLists mocks base method.

func (*MockTx) MaxAllowedTTL added in v1.2.7 

func (m *MockTx) MaxAllowedTTL() (*time.Duration, error)

MaxAllowedTTL mocks base method.

func (*MockTx) RangeDeleteFromCrossClusterTasks added in v1.2.7 

func (m *MockTx) RangeDeleteFromCrossClusterTasks(ctx context.Context, filter *CrossClusterTasksFilter) (sql.Result, error)

RangeDeleteFromCrossClusterTasks mocks base method.

func (*MockTx) RangeDeleteFromReplicationTasks added in v1.2.7 

func (m *MockTx) RangeDeleteFromReplicationTasks(ctx context.Context, filter *ReplicationTasksFilter) (sql.Result, error)

RangeDeleteFromReplicationTasks mocks base method.

func (*MockTx) RangeDeleteFromTimerTasks added in v1.2.7 

func (m *MockTx) RangeDeleteFromTimerTasks(ctx context.Context, filter *TimerTasksFilter) (sql.Result, error)

RangeDeleteFromTimerTasks mocks base method.

func (*MockTx) RangeDeleteFromTransferTasks added in v1.2.7 

func (m *MockTx) RangeDeleteFromTransferTasks(ctx context.Context, filter *TransferTasksFilter) (sql.Result, error)

RangeDeleteFromTransferTasks mocks base method.

func (*MockTx) RangeDeleteMessageFromReplicationTasksDLQ added in v1.2.7 

func (m *MockTx) RangeDeleteMessageFromReplicationTasksDLQ(ctx context.Context, filter *ReplicationTasksDLQFilter) (sql.Result, error)

RangeDeleteMessageFromReplicationTasksDLQ mocks base method.

func (*MockTx) RangeDeleteMessages added in v1.2.7 

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

RangeDeleteMessages mocks base method.

func (*MockTx) ReadLockExecutions added in v1.2.7 

func (m *MockTx) ReadLockExecutions(ctx context.Context, filter *ExecutionsFilter) (int, error)

ReadLockExecutions mocks base method.

func (*MockTx) ReadLockShards added in v1.2.7 

func (m *MockTx) ReadLockShards(ctx context.Context, filter *ShardsFilter) (int, error)

ReadLockShards mocks base method.

func (*MockTx) ReplaceIntoActivityInfoMaps added in v1.2.7 

func (m *MockTx) ReplaceIntoActivityInfoMaps(ctx context.Context, rows []ActivityInfoMapsRow) (sql.Result, error)

ReplaceIntoActivityInfoMaps mocks base method.

func (*MockTx) ReplaceIntoChildExecutionInfoMaps added in v1.2.7 

func (m *MockTx) ReplaceIntoChildExecutionInfoMaps(ctx context.Context, rows []ChildExecutionInfoMapsRow) (sql.Result, error)

ReplaceIntoChildExecutionInfoMaps mocks base method.

func (*MockTx) ReplaceIntoRequestCancelInfoMaps added in v1.2.7 

func (m *MockTx) ReplaceIntoRequestCancelInfoMaps(ctx context.Context, rows []RequestCancelInfoMapsRow) (sql.Result, error)

ReplaceIntoRequestCancelInfoMaps mocks base method.

func (*MockTx) ReplaceIntoSignalInfoMaps added in v1.2.7 

func (m *MockTx) ReplaceIntoSignalInfoMaps(ctx context.Context, rows []SignalInfoMapsRow) (sql.Result, error)

ReplaceIntoSignalInfoMaps mocks base method.

func (*MockTx) ReplaceIntoTimerInfoMaps added in v1.2.7 

func (m *MockTx) ReplaceIntoTimerInfoMaps(ctx context.Context, rows []TimerInfoMapsRow) (sql.Result, error)

ReplaceIntoTimerInfoMaps mocks base method.

func (*MockTx) ReplaceIntoVisibility added in v1.2.7 

func (m *MockTx) ReplaceIntoVisibility(ctx context.Context, row *VisibilityRow) (sql.Result, error)

ReplaceIntoVisibility mocks base method.

func (*MockTx) Rollback added in v1.2.7 

func (m *MockTx) Rollback() error

Rollback mocks base method.

func (*MockTx) SelectFromActivityInfoMaps added in v1.2.7 

func (m *MockTx) SelectFromActivityInfoMaps(ctx context.Context, filter *ActivityInfoMapsFilter) ([]ActivityInfoMapsRow, error)

SelectFromActivityInfoMaps mocks base method.

func (*MockTx) SelectFromBufferedEvents added in v1.2.7 

func (m *MockTx) SelectFromBufferedEvents(ctx context.Context, filter *BufferedEventsFilter) ([]BufferedEventsRow, error)

SelectFromBufferedEvents mocks base method.

func (*MockTx) SelectFromChildExecutionInfoMaps added in v1.2.7 

func (m *MockTx) SelectFromChildExecutionInfoMaps(ctx context.Context, filter *ChildExecutionInfoMapsFilter) ([]ChildExecutionInfoMapsRow, error)

SelectFromChildExecutionInfoMaps mocks base method.

func (*MockTx) SelectFromCrossClusterTasks added in v1.2.7 

func (m *MockTx) SelectFromCrossClusterTasks(ctx context.Context, filter *CrossClusterTasksFilter) ([]CrossClusterTasksRow, error)

SelectFromCrossClusterTasks mocks base method.

func (*MockTx) SelectFromCurrentExecutions added in v1.2.7 

func (m *MockTx) SelectFromCurrentExecutions(ctx context.Context, filter *CurrentExecutionsFilter) (*CurrentExecutionsRow, error)

SelectFromCurrentExecutions mocks base method.

func (*MockTx) SelectFromDomain added in v1.2.7 

func (m *MockTx) SelectFromDomain(ctx context.Context, filter *DomainFilter) ([]DomainRow, error)

SelectFromDomain mocks base method.

func (*MockTx) SelectFromDomainMetadata added in v1.2.7 

func (m *MockTx) SelectFromDomainMetadata(ctx context.Context) (*DomainMetadataRow, error)

SelectFromDomainMetadata mocks base method.

func (*MockTx) SelectFromExecutions added in v1.2.7 

func (m *MockTx) SelectFromExecutions(ctx context.Context, filter *ExecutionsFilter) ([]ExecutionsRow, error)

SelectFromExecutions mocks base method.

func (*MockTx) SelectFromHistoryNode added in v1.2.7 

func (m *MockTx) SelectFromHistoryNode(ctx context.Context, filter *HistoryNodeFilter) ([]HistoryNodeRow, error)

SelectFromHistoryNode mocks base method.

func (*MockTx) SelectFromHistoryTree added in v1.2.7 

func (m *MockTx) SelectFromHistoryTree(ctx context.Context, filter *HistoryTreeFilter) ([]HistoryTreeRow, error)

SelectFromHistoryTree mocks base method.

func (*MockTx) SelectFromReplicationDLQ added in v1.2.7 

func (m *MockTx) SelectFromReplicationDLQ(ctx context.Context, filter *ReplicationTaskDLQFilter) (int64, error)

SelectFromReplicationDLQ mocks base method.

func (*MockTx) SelectFromReplicationTasks added in v1.2.7 

func (m *MockTx) SelectFromReplicationTasks(ctx context.Context, filter *ReplicationTasksFilter) ([]ReplicationTasksRow, error)

SelectFromReplicationTasks mocks base method.

func (*MockTx) SelectFromReplicationTasksDLQ added in v1.2.7 

func (m *MockTx) SelectFromReplicationTasksDLQ(ctx context.Context, filter *ReplicationTasksDLQFilter) ([]ReplicationTasksRow, error)

SelectFromReplicationTasksDLQ mocks base method.

func (*MockTx) SelectFromRequestCancelInfoMaps added in v1.2.7 

func (m *MockTx) SelectFromRequestCancelInfoMaps(ctx context.Context, filter *RequestCancelInfoMapsFilter) ([]RequestCancelInfoMapsRow, error)

SelectFromRequestCancelInfoMaps mocks base method.

func (*MockTx) SelectFromShards added in v1.2.7 

func (m *MockTx) SelectFromShards(ctx context.Context, filter *ShardsFilter) (*ShardsRow, error)

SelectFromShards mocks base method.

func (*MockTx) SelectFromSignalInfoMaps added in v1.2.7 

func (m *MockTx) SelectFromSignalInfoMaps(ctx context.Context, filter *SignalInfoMapsFilter) ([]SignalInfoMapsRow, error)

SelectFromSignalInfoMaps mocks base method.

func (*MockTx) SelectFromSignalsRequestedSets added in v1.2.7 

func (m *MockTx) SelectFromSignalsRequestedSets(ctx context.Context, filter *SignalsRequestedSetsFilter) ([]SignalsRequestedSetsRow, error)

SelectFromSignalsRequestedSets mocks base method.

func (*MockTx) SelectFromTaskLists added in v1.2.7 

func (m *MockTx) SelectFromTaskLists(ctx context.Context, filter *TaskListsFilter) ([]TaskListsRow, error)

SelectFromTaskLists mocks base method.

func (*MockTx) SelectFromTasks added in v1.2.7 

func (m *MockTx) SelectFromTasks(ctx context.Context, filter *TasksFilter) ([]TasksRow, error)

SelectFromTasks mocks base method.

func (*MockTx) SelectFromTimerInfoMaps added in v1.2.7 

func (m *MockTx) SelectFromTimerInfoMaps(ctx context.Context, filter *TimerInfoMapsFilter) ([]TimerInfoMapsRow, error)

SelectFromTimerInfoMaps mocks base method.

func (*MockTx) SelectFromTimerTasks added in v1.2.7 

func (m *MockTx) SelectFromTimerTasks(ctx context.Context, filter *TimerTasksFilter) ([]TimerTasksRow, error)

SelectFromTimerTasks mocks base method.

func (*MockTx) SelectFromTransferTasks added in v1.2.7 

func (m *MockTx) SelectFromTransferTasks(ctx context.Context, filter *TransferTasksFilter) ([]TransferTasksRow, error)

SelectFromTransferTasks mocks base method.

func (*MockTx) SelectFromVisibility added in v1.2.7 

func (m *MockTx) SelectFromVisibility(ctx context.Context, filter *VisibilityFilter) ([]VisibilityRow, error)

SelectFromVisibility mocks base method.

func (*MockTx) SelectLatestConfig added in v1.2.7 

func (m *MockTx) SelectLatestConfig(ctx context.Context, rowType int) (*persistence.InternalConfigStoreEntry, error)

SelectLatestConfig mocks base method.

func (*MockTx) SupportsAsyncTransaction added in v1.2.7 

func (m *MockTx) SupportsAsyncTransaction() bool

SupportsAsyncTransaction mocks base method.

func (*MockTx) SupportsTTL added in v1.2.7 

func (m *MockTx) SupportsTTL() bool

SupportsTTL mocks base method.

func (*MockTx) UpdateAckLevels added in v1.2.7 

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

UpdateAckLevels mocks base method.

func (*MockTx) UpdateCurrentExecutions added in v1.2.7 

func (m *MockTx) UpdateCurrentExecutions(ctx context.Context, row *CurrentExecutionsRow) (sql.Result, error)

UpdateCurrentExecutions mocks base method.

func (*MockTx) UpdateDomain added in v1.2.7 

func (m *MockTx) UpdateDomain(ctx context.Context, row *DomainRow) (sql.Result, error)

UpdateDomain mocks base method.

func (*MockTx) UpdateDomainMetadata added in v1.2.7 

func (m *MockTx) UpdateDomainMetadata(ctx context.Context, row *DomainMetadataRow) (sql.Result, error)

UpdateDomainMetadata mocks base method.

func (*MockTx) UpdateExecutions added in v1.2.7 

func (m *MockTx) UpdateExecutions(ctx context.Context, row *ExecutionsRow) (sql.Result, error)

UpdateExecutions mocks base method.

func (*MockTx) UpdateShards added in v1.2.7 

func (m *MockTx) UpdateShards(ctx context.Context, row *ShardsRow) (sql.Result, error)

UpdateShards mocks base method.

func (*MockTx) UpdateTaskLists added in v1.2.7 

func (m *MockTx) UpdateTaskLists(ctx context.Context, row *TaskListsRow) (sql.Result, error)

UpdateTaskLists mocks base method.

func (*MockTx) UpdateTaskListsWithTTL added in v1.2.7 

func (m *MockTx) UpdateTaskListsWithTTL(ctx context.Context, row *TaskListsRowWithTTL) (sql.Result, error)

UpdateTaskListsWithTTL mocks base method.

func (*MockTx) WriteLockExecutions added in v1.2.7 

func (m *MockTx) WriteLockExecutions(ctx context.Context, filter *ExecutionsFilter) (int, error)

WriteLockExecutions mocks base method.

func (*MockTx) WriteLockShards added in v1.2.7 

func (m *MockTx) WriteLockShards(ctx context.Context, filter *ShardsFilter) (int, error)

WriteLockShards mocks base method.

type MockTxMockRecorder added in v1.2.7 

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

MockTxMockRecorder is the mock recorder for MockTx.

func (*MockTxMockRecorder) Commit added in v1.2.7 

func (mr *MockTxMockRecorder) Commit() *gomock.Call

Commit indicates an expected call of Commit.

func (*MockTxMockRecorder) DeleteFromActivityInfoMaps added in v1.2.7 

func (mr *MockTxMockRecorder) DeleteFromActivityInfoMaps(ctx, filter interface{}) *gomock.Call

DeleteFromActivityInfoMaps indicates an expected call of DeleteFromActivityInfoMaps.

func (*MockTxMockRecorder) DeleteFromBufferedEvents added in v1.2.7 

func (mr *MockTxMockRecorder) DeleteFromBufferedEvents(ctx, filter interface{}) *gomock.Call

DeleteFromBufferedEvents indicates an expected call of DeleteFromBufferedEvents.

func (*MockTxMockRecorder) DeleteFromChildExecutionInfoMaps added in v1.2.7 

func (mr *MockTxMockRecorder) DeleteFromChildExecutionInfoMaps(ctx, filter interface{}) *gomock.Call

DeleteFromChildExecutionInfoMaps indicates an expected call of DeleteFromChildExecutionInfoMaps.

func (*MockTxMockRecorder) DeleteFromCrossClusterTasks added in v1.2.7 

func (mr *MockTxMockRecorder) DeleteFromCrossClusterTasks(ctx, filter interface{}) *gomock.Call

DeleteFromCrossClusterTasks indicates an expected call of DeleteFromCrossClusterTasks.

func (*MockTxMockRecorder) DeleteFromCurrentExecutions added in v1.2.7 

func (mr *MockTxMockRecorder) DeleteFromCurrentExecutions(ctx, filter interface{}) *gomock.Call

DeleteFromCurrentExecutions indicates an expected call of DeleteFromCurrentExecutions.

func (*MockTxMockRecorder) DeleteFromDomain added in v1.2.7 

func (mr *MockTxMockRecorder) DeleteFromDomain(ctx, filter interface{}) *gomock.Call

DeleteFromDomain indicates an expected call of DeleteFromDomain.

func (*MockTxMockRecorder) DeleteFromExecutions added in v1.2.7 

func (mr *MockTxMockRecorder) DeleteFromExecutions(ctx, filter interface{}) *gomock.Call

DeleteFromExecutions indicates an expected call of DeleteFromExecutions.

func (*MockTxMockRecorder) DeleteFromHistoryNode added in v1.2.7 

func (mr *MockTxMockRecorder) DeleteFromHistoryNode(ctx, filter interface{}) *gomock.Call

DeleteFromHistoryNode indicates an expected call of DeleteFromHistoryNode.

func (*MockTxMockRecorder) DeleteFromHistoryTree added in v1.2.7 

func (mr *MockTxMockRecorder) DeleteFromHistoryTree(ctx, filter interface{}) *gomock.Call

DeleteFromHistoryTree indicates an expected call of DeleteFromHistoryTree.

func (*MockTxMockRecorder) DeleteFromReplicationTasks added in v1.2.7 

func (mr *MockTxMockRecorder) DeleteFromReplicationTasks(ctx, filter interface{}) *gomock.Call

DeleteFromReplicationTasks indicates an expected call of DeleteFromReplicationTasks.

func (*MockTxMockRecorder) DeleteFromRequestCancelInfoMaps added in v1.2.7 

func (mr *MockTxMockRecorder) DeleteFromRequestCancelInfoMaps(ctx, filter interface{}) *gomock.Call

DeleteFromRequestCancelInfoMaps indicates an expected call of DeleteFromRequestCancelInfoMaps.

func (*MockTxMockRecorder) DeleteFromSignalInfoMaps added in v1.2.7 

func (mr *MockTxMockRecorder) DeleteFromSignalInfoMaps(ctx, filter interface{}) *gomock.Call

DeleteFromSignalInfoMaps indicates an expected call of DeleteFromSignalInfoMaps.

func (*MockTxMockRecorder) DeleteFromSignalsRequestedSets added in v1.2.7 

func (mr *MockTxMockRecorder) DeleteFromSignalsRequestedSets(ctx, filter interface{}) *gomock.Call

DeleteFromSignalsRequestedSets indicates an expected call of DeleteFromSignalsRequestedSets.

func (*MockTxMockRecorder) DeleteFromTaskLists added in v1.2.7 

func (mr *MockTxMockRecorder) DeleteFromTaskLists(ctx, filter interface{}) *gomock.Call

DeleteFromTaskLists indicates an expected call of DeleteFromTaskLists.

func (*MockTxMockRecorder) DeleteFromTasks added in v1.2.7 

func (mr *MockTxMockRecorder) DeleteFromTasks(ctx, filter interface{}) *gomock.Call

DeleteFromTasks indicates an expected call of DeleteFromTasks.

func (*MockTxMockRecorder) DeleteFromTimerInfoMaps added in v1.2.7 

func (mr *MockTxMockRecorder) DeleteFromTimerInfoMaps(ctx, filter interface{}) *gomock.Call

DeleteFromTimerInfoMaps indicates an expected call of DeleteFromTimerInfoMaps.

func (*MockTxMockRecorder) DeleteFromTimerTasks added in v1.2.7 

func (mr *MockTxMockRecorder) DeleteFromTimerTasks(ctx, filter interface{}) *gomock.Call

DeleteFromTimerTasks indicates an expected call of DeleteFromTimerTasks.

func (*MockTxMockRecorder) DeleteFromTransferTasks added in v1.2.7 

func (mr *MockTxMockRecorder) DeleteFromTransferTasks(ctx, filter interface{}) *gomock.Call

DeleteFromTransferTasks indicates an expected call of DeleteFromTransferTasks.

func (*MockTxMockRecorder) DeleteFromVisibility added in v1.2.7 

func (mr *MockTxMockRecorder) DeleteFromVisibility(ctx, filter interface{}) *gomock.Call

DeleteFromVisibility indicates an expected call of DeleteFromVisibility.

func (*MockTxMockRecorder) DeleteMessage added in v1.2.7 

func (mr *MockTxMockRecorder) DeleteMessage(ctx, queueType, messageID interface{}) *gomock.Call

DeleteMessage indicates an expected call of DeleteMessage.

func (*MockTxMockRecorder) DeleteMessageFromReplicationTasksDLQ added in v1.2.7 

func (mr *MockTxMockRecorder) DeleteMessageFromReplicationTasksDLQ(ctx, filter interface{}) *gomock.Call

DeleteMessageFromReplicationTasksDLQ indicates an expected call of DeleteMessageFromReplicationTasksDLQ.

func (*MockTxMockRecorder) DeleteMessagesBefore added in v1.2.7 

func (mr *MockTxMockRecorder) DeleteMessagesBefore(ctx, queueType, messageID interface{}) *gomock.Call

DeleteMessagesBefore indicates an expected call of DeleteMessagesBefore.

func (*MockTxMockRecorder) GetAckLevels added in v1.2.7 

func (mr *MockTxMockRecorder) GetAckLevels(ctx, queueType, forUpdate interface{}) *gomock.Call

GetAckLevels indicates an expected call of GetAckLevels.

func (*MockTxMockRecorder) GetAllHistoryTreeBranches added in v1.2.7 

func (mr *MockTxMockRecorder) GetAllHistoryTreeBranches(ctx, filter interface{}) *gomock.Call

GetAllHistoryTreeBranches indicates an expected call of GetAllHistoryTreeBranches.

func (*MockTxMockRecorder) GetLastEnqueuedMessageIDForUpdate added in v1.2.7 

func (mr *MockTxMockRecorder) GetLastEnqueuedMessageIDForUpdate(ctx, queueType interface{}) *gomock.Call

GetLastEnqueuedMessageIDForUpdate indicates an expected call of GetLastEnqueuedMessageIDForUpdate.

func (*MockTxMockRecorder) GetMessagesBetween added in v1.2.7 

func (mr *MockTxMockRecorder) GetMessagesBetween(ctx, queueType, firstMessageID, lastMessageID, maxRows interface{}) *gomock.Call

GetMessagesBetween indicates an expected call of GetMessagesBetween.

func (*MockTxMockRecorder) GetMessagesFromQueue added in v1.2.7 

func (mr *MockTxMockRecorder) GetMessagesFromQueue(ctx, queueType, lastMessageID, maxRows interface{}) *gomock.Call

GetMessagesFromQueue indicates an expected call of GetMessagesFromQueue.

func (*MockTxMockRecorder) GetOrphanTasks added in v1.2.7 

func (mr *MockTxMockRecorder) GetOrphanTasks(ctx, filter interface{}) *gomock.Call

GetOrphanTasks indicates an expected call of GetOrphanTasks.

func (*MockTxMockRecorder) GetQueueSize added in v1.2.7 

func (mr *MockTxMockRecorder) GetQueueSize(ctx, queueType interface{}) *gomock.Call

GetQueueSize indicates an expected call of GetQueueSize.

func (*MockTxMockRecorder) GetTasksCount added in v1.2.7 

func (mr *MockTxMockRecorder) GetTasksCount(ctx, filter interface{}) *gomock.Call

GetTasksCount indicates an expected call of GetTasksCount.

func (*MockTxMockRecorder) InsertAckLevel added in v1.2.7 

func (mr *MockTxMockRecorder) InsertAckLevel(ctx, queueType, messageID, clusterName interface{}) *gomock.Call

InsertAckLevel indicates an expected call of InsertAckLevel.

func (*MockTxMockRecorder) InsertConfig added in v1.2.7 

func (mr *MockTxMockRecorder) InsertConfig(ctx, row interface{}) *gomock.Call

InsertConfig indicates an expected call of InsertConfig.

func (*MockTxMockRecorder) InsertIntoBufferedEvents added in v1.2.7 

func (mr *MockTxMockRecorder) InsertIntoBufferedEvents(ctx, rows interface{}) *gomock.Call

InsertIntoBufferedEvents indicates an expected call of InsertIntoBufferedEvents.

func (*MockTxMockRecorder) InsertIntoCrossClusterTasks added in v1.2.7 

func (mr *MockTxMockRecorder) InsertIntoCrossClusterTasks(ctx, rows interface{}) *gomock.Call

InsertIntoCrossClusterTasks indicates an expected call of InsertIntoCrossClusterTasks.

func (*MockTxMockRecorder) InsertIntoCurrentExecutions added in v1.2.7 

func (mr *MockTxMockRecorder) InsertIntoCurrentExecutions(ctx, row interface{}) *gomock.Call

InsertIntoCurrentExecutions indicates an expected call of InsertIntoCurrentExecutions.

func (*MockTxMockRecorder) InsertIntoDomain added in v1.2.7 

func (mr *MockTxMockRecorder) InsertIntoDomain(ctx, rows interface{}) *gomock.Call

InsertIntoDomain indicates an expected call of InsertIntoDomain.

func (*MockTxMockRecorder) InsertIntoExecutions added in v1.2.7 

func (mr *MockTxMockRecorder) InsertIntoExecutions(ctx, row interface{}) *gomock.Call

InsertIntoExecutions indicates an expected call of InsertIntoExecutions.

func (*MockTxMockRecorder) InsertIntoHistoryNode added in v1.2.7 

func (mr *MockTxMockRecorder) InsertIntoHistoryNode(ctx, row interface{}) *gomock.Call

InsertIntoHistoryNode indicates an expected call of InsertIntoHistoryNode.

func (*MockTxMockRecorder) InsertIntoHistoryTree added in v1.2.7 

func (mr *MockTxMockRecorder) InsertIntoHistoryTree(ctx, row interface{}) *gomock.Call

InsertIntoHistoryTree indicates an expected call of InsertIntoHistoryTree.

func (*MockTxMockRecorder) InsertIntoQueue added in v1.2.7 

func (mr *MockTxMockRecorder) InsertIntoQueue(ctx, row interface{}) *gomock.Call

InsertIntoQueue indicates an expected call of InsertIntoQueue.

func (*MockTxMockRecorder) InsertIntoReplicationTasks added in v1.2.7 

func (mr *MockTxMockRecorder) InsertIntoReplicationTasks(ctx, rows interface{}) *gomock.Call

InsertIntoReplicationTasks indicates an expected call of InsertIntoReplicationTasks.

func (*MockTxMockRecorder) InsertIntoReplicationTasksDLQ added in v1.2.7 

func (mr *MockTxMockRecorder) InsertIntoReplicationTasksDLQ(ctx, row interface{}) *gomock.Call

InsertIntoReplicationTasksDLQ indicates an expected call of InsertIntoReplicationTasksDLQ.

func (*MockTxMockRecorder) InsertIntoShards added in v1.2.7 

func (mr *MockTxMockRecorder) InsertIntoShards(ctx, rows interface{}) *gomock.Call

InsertIntoShards indicates an expected call of InsertIntoShards.

func (*MockTxMockRecorder) InsertIntoSignalsRequestedSets added in v1.2.7 

func (mr *MockTxMockRecorder) InsertIntoSignalsRequestedSets(ctx, rows interface{}) *gomock.Call

InsertIntoSignalsRequestedSets indicates an expected call of InsertIntoSignalsRequestedSets.

func (*MockTxMockRecorder) InsertIntoTaskLists added in v1.2.7 

func (mr *MockTxMockRecorder) InsertIntoTaskLists(ctx, row interface{}) *gomock.Call

InsertIntoTaskLists indicates an expected call of InsertIntoTaskLists.

func (*MockTxMockRecorder) InsertIntoTaskListsWithTTL added in v1.2.7 

func (mr *MockTxMockRecorder) InsertIntoTaskListsWithTTL(ctx, row interface{}) *gomock.Call

InsertIntoTaskListsWithTTL indicates an expected call of InsertIntoTaskListsWithTTL.

func (*MockTxMockRecorder) InsertIntoTasks added in v1.2.7 

func (mr *MockTxMockRecorder) InsertIntoTasks(ctx, rows interface{}) *gomock.Call

InsertIntoTasks indicates an expected call of InsertIntoTasks.

func (*MockTxMockRecorder) InsertIntoTasksWithTTL added in v1.2.7 

func (mr *MockTxMockRecorder) InsertIntoTasksWithTTL(ctx, rows interface{}) *gomock.Call

InsertIntoTasksWithTTL indicates an expected call of InsertIntoTasksWithTTL.

func (*MockTxMockRecorder) InsertIntoTimerTasks added in v1.2.7 

func (mr *MockTxMockRecorder) InsertIntoTimerTasks(ctx, rows interface{}) *gomock.Call

InsertIntoTimerTasks indicates an expected call of InsertIntoTimerTasks.

func (*MockTxMockRecorder) InsertIntoTransferTasks added in v1.2.7 

func (mr *MockTxMockRecorder) InsertIntoTransferTasks(ctx, rows interface{}) *gomock.Call

InsertIntoTransferTasks indicates an expected call of InsertIntoTransferTasks.

func (*MockTxMockRecorder) InsertIntoVisibility added in v1.2.7 

func (mr *MockTxMockRecorder) InsertIntoVisibility(ctx, row interface{}) *gomock.Call

InsertIntoVisibility indicates an expected call of InsertIntoVisibility.

func (*MockTxMockRecorder) IsDupEntryError added in v1.2.7 

func (mr *MockTxMockRecorder) IsDupEntryError(err interface{}) *gomock.Call

IsDupEntryError indicates an expected call of IsDupEntryError.

func (*MockTxMockRecorder) IsNotFoundError added in v1.2.7 

func (mr *MockTxMockRecorder) IsNotFoundError(err interface{}) *gomock.Call

IsNotFoundError indicates an expected call of IsNotFoundError.

func (*MockTxMockRecorder) IsThrottlingError added in v1.2.7 

func (mr *MockTxMockRecorder) IsThrottlingError(err interface{}) *gomock.Call

IsThrottlingError indicates an expected call of IsThrottlingError.

func (*MockTxMockRecorder) IsTimeoutError added in v1.2.7 

func (mr *MockTxMockRecorder) IsTimeoutError(err interface{}) *gomock.Call

IsTimeoutError indicates an expected call of IsTimeoutError.

func (*MockTxMockRecorder) LockCurrentExecutions added in v1.2.7 

func (mr *MockTxMockRecorder) LockCurrentExecutions(ctx, filter interface{}) *gomock.Call

LockCurrentExecutions indicates an expected call of LockCurrentExecutions.

func (*MockTxMockRecorder) LockCurrentExecutionsJoinExecutions added in v1.2.7 

func (mr *MockTxMockRecorder) LockCurrentExecutionsJoinExecutions(ctx, filter interface{}) *gomock.Call

LockCurrentExecutionsJoinExecutions indicates an expected call of LockCurrentExecutionsJoinExecutions.

func (*MockTxMockRecorder) LockDomainMetadata added in v1.2.7 

func (mr *MockTxMockRecorder) LockDomainMetadata(ctx interface{}) *gomock.Call

LockDomainMetadata indicates an expected call of LockDomainMetadata.

func (*MockTxMockRecorder) LockTaskLists added in v1.2.7 

func (mr *MockTxMockRecorder) LockTaskLists(ctx, filter interface{}) *gomock.Call

LockTaskLists indicates an expected call of LockTaskLists.

func (*MockTxMockRecorder) MaxAllowedTTL added in v1.2.7 

func (mr *MockTxMockRecorder) MaxAllowedTTL() *gomock.Call

MaxAllowedTTL indicates an expected call of MaxAllowedTTL.

func (*MockTxMockRecorder) RangeDeleteFromCrossClusterTasks added in v1.2.7 

func (mr *MockTxMockRecorder) RangeDeleteFromCrossClusterTasks(ctx, filter interface{}) *gomock.Call

RangeDeleteFromCrossClusterTasks indicates an expected call of RangeDeleteFromCrossClusterTasks.

func (*MockTxMockRecorder) RangeDeleteFromReplicationTasks added in v1.2.7 

func (mr *MockTxMockRecorder) RangeDeleteFromReplicationTasks(ctx, filter interface{}) *gomock.Call

RangeDeleteFromReplicationTasks indicates an expected call of RangeDeleteFromReplicationTasks.

func (*MockTxMockRecorder) RangeDeleteFromTimerTasks added in v1.2.7 

func (mr *MockTxMockRecorder) RangeDeleteFromTimerTasks(ctx, filter interface{}) *gomock.Call

RangeDeleteFromTimerTasks indicates an expected call of RangeDeleteFromTimerTasks.

func (*MockTxMockRecorder) RangeDeleteFromTransferTasks added in v1.2.7 

func (mr *MockTxMockRecorder) RangeDeleteFromTransferTasks(ctx, filter interface{}) *gomock.Call

RangeDeleteFromTransferTasks indicates an expected call of RangeDeleteFromTransferTasks.

func (*MockTxMockRecorder) RangeDeleteMessageFromReplicationTasksDLQ added in v1.2.7 

func (mr *MockTxMockRecorder) RangeDeleteMessageFromReplicationTasksDLQ(ctx, filter interface{}) *gomock.Call

RangeDeleteMessageFromReplicationTasksDLQ indicates an expected call of RangeDeleteMessageFromReplicationTasksDLQ.

func (*MockTxMockRecorder) RangeDeleteMessages added in v1.2.7 

func (mr *MockTxMockRecorder) RangeDeleteMessages(ctx, queueType, exclusiveBeginMessageID, inclusiveEndMessageID interface{}) *gomock.Call

RangeDeleteMessages indicates an expected call of RangeDeleteMessages.

func (*MockTxMockRecorder) ReadLockExecutions added in v1.2.7 

func (mr *MockTxMockRecorder) ReadLockExecutions(ctx, filter interface{}) *gomock.Call

ReadLockExecutions indicates an expected call of ReadLockExecutions.

func (*MockTxMockRecorder) ReadLockShards added in v1.2.7 

func (mr *MockTxMockRecorder) ReadLockShards(ctx, filter interface{}) *gomock.Call

ReadLockShards indicates an expected call of ReadLockShards.

func (*MockTxMockRecorder) ReplaceIntoActivityInfoMaps added in v1.2.7 

func (mr *MockTxMockRecorder) ReplaceIntoActivityInfoMaps(ctx, rows interface{}) *gomock.Call

ReplaceIntoActivityInfoMaps indicates an expected call of ReplaceIntoActivityInfoMaps.

func (*MockTxMockRecorder) ReplaceIntoChildExecutionInfoMaps added in v1.2.7 

func (mr *MockTxMockRecorder) ReplaceIntoChildExecutionInfoMaps(ctx, rows interface{}) *gomock.Call

ReplaceIntoChildExecutionInfoMaps indicates an expected call of ReplaceIntoChildExecutionInfoMaps.

func (*MockTxMockRecorder) ReplaceIntoRequestCancelInfoMaps added in v1.2.7 

func (mr *MockTxMockRecorder) ReplaceIntoRequestCancelInfoMaps(ctx, rows interface{}) *gomock.Call

ReplaceIntoRequestCancelInfoMaps indicates an expected call of ReplaceIntoRequestCancelInfoMaps.

func (*MockTxMockRecorder) ReplaceIntoSignalInfoMaps added in v1.2.7 

func (mr *MockTxMockRecorder) ReplaceIntoSignalInfoMaps(ctx, rows interface{}) *gomock.Call

ReplaceIntoSignalInfoMaps indicates an expected call of ReplaceIntoSignalInfoMaps.

func (*MockTxMockRecorder) ReplaceIntoTimerInfoMaps added in v1.2.7 

func (mr *MockTxMockRecorder) ReplaceIntoTimerInfoMaps(ctx, rows interface{}) *gomock.Call

ReplaceIntoTimerInfoMaps indicates an expected call of ReplaceIntoTimerInfoMaps.

func (*MockTxMockRecorder) ReplaceIntoVisibility added in v1.2.7 

func (mr *MockTxMockRecorder) ReplaceIntoVisibility(ctx, row interface{}) *gomock.Call

ReplaceIntoVisibility indicates an expected call of ReplaceIntoVisibility.

func (*MockTxMockRecorder) Rollback added in v1.2.7 

func (mr *MockTxMockRecorder) Rollback() *gomock.Call

Rollback indicates an expected call of Rollback.

func (*MockTxMockRecorder) SelectFromActivityInfoMaps added in v1.2.7 

func (mr *MockTxMockRecorder) SelectFromActivityInfoMaps(ctx, filter interface{}) *gomock.Call

SelectFromActivityInfoMaps indicates an expected call of SelectFromActivityInfoMaps.

func (*MockTxMockRecorder) SelectFromBufferedEvents added in v1.2.7 

func (mr *MockTxMockRecorder) SelectFromBufferedEvents(ctx, filter interface{}) *gomock.Call

SelectFromBufferedEvents indicates an expected call of SelectFromBufferedEvents.

func (*MockTxMockRecorder) SelectFromChildExecutionInfoMaps added in v1.2.7 

func (mr *MockTxMockRecorder) SelectFromChildExecutionInfoMaps(ctx, filter interface{}) *gomock.Call

SelectFromChildExecutionInfoMaps indicates an expected call of SelectFromChildExecutionInfoMaps.

func (*MockTxMockRecorder) SelectFromCrossClusterTasks added in v1.2.7 

func (mr *MockTxMockRecorder) SelectFromCrossClusterTasks(ctx, filter interface{}) *gomock.Call

SelectFromCrossClusterTasks indicates an expected call of SelectFromCrossClusterTasks.

func (*MockTxMockRecorder) SelectFromCurrentExecutions added in v1.2.7 

func (mr *MockTxMockRecorder) SelectFromCurrentExecutions(ctx, filter interface{}) *gomock.Call

SelectFromCurrentExecutions indicates an expected call of SelectFromCurrentExecutions.

func (*MockTxMockRecorder) SelectFromDomain added in v1.2.7 

func (mr *MockTxMockRecorder) SelectFromDomain(ctx, filter interface{}) *gomock.Call

SelectFromDomain indicates an expected call of SelectFromDomain.

func (*MockTxMockRecorder) SelectFromDomainMetadata added in v1.2.7 

func (mr *MockTxMockRecorder) SelectFromDomainMetadata(ctx interface{}) *gomock.Call

SelectFromDomainMetadata indicates an expected call of SelectFromDomainMetadata.

func (*MockTxMockRecorder) SelectFromExecutions added in v1.2.7 

func (mr *MockTxMockRecorder) SelectFromExecutions(ctx, filter interface{}) *gomock.Call

SelectFromExecutions indicates an expected call of SelectFromExecutions.

func (*MockTxMockRecorder) SelectFromHistoryNode added in v1.2.7 

func (mr *MockTxMockRecorder) SelectFromHistoryNode(ctx, filter interface{}) *gomock.Call

SelectFromHistoryNode indicates an expected call of SelectFromHistoryNode.

func (*MockTxMockRecorder) SelectFromHistoryTree added in v1.2.7 

func (mr *MockTxMockRecorder) SelectFromHistoryTree(ctx, filter interface{}) *gomock.Call

SelectFromHistoryTree indicates an expected call of SelectFromHistoryTree.

func (*MockTxMockRecorder) SelectFromReplicationDLQ added in v1.2.7 

func (mr *MockTxMockRecorder) SelectFromReplicationDLQ(ctx, filter interface{}) *gomock.Call

SelectFromReplicationDLQ indicates an expected call of SelectFromReplicationDLQ.

func (*MockTxMockRecorder) SelectFromReplicationTasks added in v1.2.7 

func (mr *MockTxMockRecorder) SelectFromReplicationTasks(ctx, filter interface{}) *gomock.Call

SelectFromReplicationTasks indicates an expected call of SelectFromReplicationTasks.

func (*MockTxMockRecorder) SelectFromReplicationTasksDLQ added in v1.2.7 

func (mr *MockTxMockRecorder) SelectFromReplicationTasksDLQ(ctx, filter interface{}) *gomock.Call

SelectFromReplicationTasksDLQ indicates an expected call of SelectFromReplicationTasksDLQ.

func (*MockTxMockRecorder) SelectFromRequestCancelInfoMaps added in v1.2.7 

func (mr *MockTxMockRecorder) SelectFromRequestCancelInfoMaps(ctx, filter interface{}) *gomock.Call

SelectFromRequestCancelInfoMaps indicates an expected call of SelectFromRequestCancelInfoMaps.

func (*MockTxMockRecorder) SelectFromShards added in v1.2.7 

func (mr *MockTxMockRecorder) SelectFromShards(ctx, filter interface{}) *gomock.Call

SelectFromShards indicates an expected call of SelectFromShards.

func (*MockTxMockRecorder) SelectFromSignalInfoMaps added in v1.2.7 

func (mr *MockTxMockRecorder) SelectFromSignalInfoMaps(ctx, filter interface{}) *gomock.Call

SelectFromSignalInfoMaps indicates an expected call of SelectFromSignalInfoMaps.

func (*MockTxMockRecorder) SelectFromSignalsRequestedSets added in v1.2.7 

func (mr *MockTxMockRecorder) SelectFromSignalsRequestedSets(ctx, filter interface{}) *gomock.Call

SelectFromSignalsRequestedSets indicates an expected call of SelectFromSignalsRequestedSets.

func (*MockTxMockRecorder) SelectFromTaskLists added in v1.2.7 

func (mr *MockTxMockRecorder) SelectFromTaskLists(ctx, filter interface{}) *gomock.Call

SelectFromTaskLists indicates an expected call of SelectFromTaskLists.

func (*MockTxMockRecorder) SelectFromTasks added in v1.2.7 

func (mr *MockTxMockRecorder) SelectFromTasks(ctx, filter interface{}) *gomock.Call

SelectFromTasks indicates an expected call of SelectFromTasks.

func (*MockTxMockRecorder) SelectFromTimerInfoMaps added in v1.2.7 

func (mr *MockTxMockRecorder) SelectFromTimerInfoMaps(ctx, filter interface{}) *gomock.Call

SelectFromTimerInfoMaps indicates an expected call of SelectFromTimerInfoMaps.

func (*MockTxMockRecorder) SelectFromTimerTasks added in v1.2.7 

func (mr *MockTxMockRecorder) SelectFromTimerTasks(ctx, filter interface{}) *gomock.Call

SelectFromTimerTasks indicates an expected call of SelectFromTimerTasks.

func (*MockTxMockRecorder) SelectFromTransferTasks added in v1.2.7 

func (mr *MockTxMockRecorder) SelectFromTransferTasks(ctx, filter interface{}) *gomock.Call

SelectFromTransferTasks indicates an expected call of SelectFromTransferTasks.

func (*MockTxMockRecorder) SelectFromVisibility added in v1.2.7 

func (mr *MockTxMockRecorder) SelectFromVisibility(ctx, filter interface{}) *gomock.Call

SelectFromVisibility indicates an expected call of SelectFromVisibility.

func (*MockTxMockRecorder) SelectLatestConfig added in v1.2.7 

func (mr *MockTxMockRecorder) SelectLatestConfig(ctx, rowType interface{}) *gomock.Call

SelectLatestConfig indicates an expected call of SelectLatestConfig.

func (*MockTxMockRecorder) SupportsAsyncTransaction added in v1.2.7 

func (mr *MockTxMockRecorder) SupportsAsyncTransaction() *gomock.Call

SupportsAsyncTransaction indicates an expected call of SupportsAsyncTransaction.

func (*MockTxMockRecorder) SupportsTTL added in v1.2.7 

func (mr *MockTxMockRecorder) SupportsTTL() *gomock.Call

SupportsTTL indicates an expected call of SupportsTTL.

func (*MockTxMockRecorder) UpdateAckLevels added in v1.2.7 

func (mr *MockTxMockRecorder) UpdateAckLevels(ctx, queueType, clusterAckLevels interface{}) *gomock.Call

UpdateAckLevels indicates an expected call of UpdateAckLevels.

func (*MockTxMockRecorder) UpdateCurrentExecutions added in v1.2.7 

func (mr *MockTxMockRecorder) UpdateCurrentExecutions(ctx, row interface{}) *gomock.Call

UpdateCurrentExecutions indicates an expected call of UpdateCurrentExecutions.

func (*MockTxMockRecorder) UpdateDomain added in v1.2.7 

func (mr *MockTxMockRecorder) UpdateDomain(ctx, row interface{}) *gomock.Call

UpdateDomain indicates an expected call of UpdateDomain.

func (*MockTxMockRecorder) UpdateDomainMetadata added in v1.2.7 

func (mr *MockTxMockRecorder) UpdateDomainMetadata(ctx, row interface{}) *gomock.Call

UpdateDomainMetadata indicates an expected call of UpdateDomainMetadata.

func (*MockTxMockRecorder) UpdateExecutions added in v1.2.7 

func (mr *MockTxMockRecorder) UpdateExecutions(ctx, row interface{}) *gomock.Call

UpdateExecutions indicates an expected call of UpdateExecutions.

func (*MockTxMockRecorder) UpdateShards added in v1.2.7 

func (mr *MockTxMockRecorder) UpdateShards(ctx, row interface{}) *gomock.Call

UpdateShards indicates an expected call of UpdateShards.

func (*MockTxMockRecorder) UpdateTaskLists added in v1.2.7 

func (mr *MockTxMockRecorder) UpdateTaskLists(ctx, row interface{}) *gomock.Call

UpdateTaskLists indicates an expected call of UpdateTaskLists.

func (*MockTxMockRecorder) UpdateTaskListsWithTTL added in v1.2.7 

func (mr *MockTxMockRecorder) UpdateTaskListsWithTTL(ctx, row interface{}) *gomock.Call

UpdateTaskListsWithTTL indicates an expected call of UpdateTaskListsWithTTL.

func (*MockTxMockRecorder) WriteLockExecutions added in v1.2.7 

func (mr *MockTxMockRecorder) WriteLockExecutions(ctx, filter interface{}) *gomock.Call

WriteLockExecutions indicates an expected call of WriteLockExecutions.

func (*MockTxMockRecorder) WriteLockShards added in v1.2.7 

func (mr *MockTxMockRecorder) WriteLockShards(ctx, filter interface{}) *gomock.Call

WriteLockShards indicates an expected call of WriteLockShards.

type MockadminCRUD added in v1.2.7 

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

MockadminCRUD is a mock of adminCRUD interface.

func NewMockadminCRUD added in v1.2.7 

func NewMockadminCRUD(ctrl *gomock.Controller) *MockadminCRUD

NewMockadminCRUD creates a new mock instance.

func (*MockadminCRUD) CreateDatabase added in v1.2.7 

func (m *MockadminCRUD) CreateDatabase(database string) error

CreateDatabase mocks base method.

func (*MockadminCRUD) CreateSchemaVersionTables added in v1.2.7 

func (m *MockadminCRUD) CreateSchemaVersionTables() error

CreateSchemaVersionTables mocks base method.

func (*MockadminCRUD) DropAllTables added in v1.2.7 

func (m *MockadminCRUD) DropAllTables(database string) error

DropAllTables mocks base method.

func (*MockadminCRUD) DropDatabase added in v1.2.7 

func (m *MockadminCRUD) DropDatabase(database string) error

DropDatabase mocks base method.

func (*MockadminCRUD) DropTable added in v1.2.7 

func (m *MockadminCRUD) DropTable(table string) error

DropTable mocks base method.

func (*MockadminCRUD) EXPECT added in v1.2.7 

func (m *MockadminCRUD) EXPECT() *MockadminCRUDMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockadminCRUD) ExecSchemaOperationQuery added in v1.2.7 

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

ExecSchemaOperationQuery mocks base method.

func (*MockadminCRUD) ListTables added in v1.2.7 

func (m *MockadminCRUD) ListTables(database string) ([]string, error)

ListTables mocks base method.

func (*MockadminCRUD) ReadSchemaVersion added in v1.2.7 

func (m *MockadminCRUD) ReadSchemaVersion(database string) (string, error)

ReadSchemaVersion mocks base method.

func (*MockadminCRUD) UpdateSchemaVersion added in v1.2.7 

func (m *MockadminCRUD) UpdateSchemaVersion(database, newVersion, minCompatibleVersion string) error

UpdateSchemaVersion mocks base method.

func (*MockadminCRUD) WriteSchemaUpdateLog added in v1.2.7 

func (m *MockadminCRUD) WriteSchemaUpdateLog(oldVersion, newVersion, manifestMD5, desc string) error

WriteSchemaUpdateLog mocks base method.

type MockadminCRUDMockRecorder added in v1.2.7 

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

MockadminCRUDMockRecorder is the mock recorder for MockadminCRUD.

func (*MockadminCRUDMockRecorder) CreateDatabase added in v1.2.7 

func (mr *MockadminCRUDMockRecorder) CreateDatabase(database interface{}) *gomock.Call

CreateDatabase indicates an expected call of CreateDatabase.

func (*MockadminCRUDMockRecorder) CreateSchemaVersionTables added in v1.2.7 

func (mr *MockadminCRUDMockRecorder) CreateSchemaVersionTables() *gomock.Call

CreateSchemaVersionTables indicates an expected call of CreateSchemaVersionTables.

func (*MockadminCRUDMockRecorder) DropAllTables added in v1.2.7 

func (mr *MockadminCRUDMockRecorder) DropAllTables(database interface{}) *gomock.Call

DropAllTables indicates an expected call of DropAllTables.

func (*MockadminCRUDMockRecorder) DropDatabase added in v1.2.7 

func (mr *MockadminCRUDMockRecorder) DropDatabase(database interface{}) *gomock.Call

DropDatabase indicates an expected call of DropDatabase.

func (*MockadminCRUDMockRecorder) DropTable added in v1.2.7 

func (mr *MockadminCRUDMockRecorder) DropTable(table interface{}) *gomock.Call

DropTable indicates an expected call of DropTable.

func (*MockadminCRUDMockRecorder) ExecSchemaOperationQuery added in v1.2.7 

func (mr *MockadminCRUDMockRecorder) ExecSchemaOperationQuery(ctx, stmt interface{}, args ...interface{}) *gomock.Call

ExecSchemaOperationQuery indicates an expected call of ExecSchemaOperationQuery.

func (*MockadminCRUDMockRecorder) ListTables added in v1.2.7 

func (mr *MockadminCRUDMockRecorder) ListTables(database interface{}) *gomock.Call

ListTables indicates an expected call of ListTables.

func (*MockadminCRUDMockRecorder) ReadSchemaVersion added in v1.2.7 

func (mr *MockadminCRUDMockRecorder) ReadSchemaVersion(database interface{}) *gomock.Call

ReadSchemaVersion indicates an expected call of ReadSchemaVersion.

func (*MockadminCRUDMockRecorder) UpdateSchemaVersion added in v1.2.7 

func (mr *MockadminCRUDMockRecorder) UpdateSchemaVersion(database, newVersion, minCompatibleVersion interface{}) *gomock.Call

UpdateSchemaVersion indicates an expected call of UpdateSchemaVersion.

func (*MockadminCRUDMockRecorder) WriteSchemaUpdateLog added in v1.2.7 

func (mr *MockadminCRUDMockRecorder) WriteSchemaUpdateLog(oldVersion, newVersion, manifestMD5, desc interface{}) *gomock.Call

WriteSchemaUpdateLog indicates an expected call of WriteSchemaUpdateLog.

type MocktableCRUD added in v1.2.7 

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

MocktableCRUD is a mock of tableCRUD interface.

func NewMocktableCRUD added in v1.2.7 

func NewMocktableCRUD(ctrl *gomock.Controller) *MocktableCRUD

NewMocktableCRUD creates a new mock instance.

func (*MocktableCRUD) DeleteFromActivityInfoMaps added in v1.2.7 

func (m *MocktableCRUD) DeleteFromActivityInfoMaps(ctx context.Context, filter *ActivityInfoMapsFilter) (sql.Result, error)

DeleteFromActivityInfoMaps mocks base method.

func (*MocktableCRUD) DeleteFromBufferedEvents added in v1.2.7 

func (m *MocktableCRUD) DeleteFromBufferedEvents(ctx context.Context, filter *BufferedEventsFilter) (sql.Result, error)

DeleteFromBufferedEvents mocks base method.

func (*MocktableCRUD) DeleteFromChildExecutionInfoMaps added in v1.2.7 

func (m *MocktableCRUD) DeleteFromChildExecutionInfoMaps(ctx context.Context, filter *ChildExecutionInfoMapsFilter) (sql.Result, error)

DeleteFromChildExecutionInfoMaps mocks base method.

func (*MocktableCRUD) DeleteFromCrossClusterTasks added in v1.2.7 

func (m *MocktableCRUD) DeleteFromCrossClusterTasks(ctx context.Context, filter *CrossClusterTasksFilter) (sql.Result, error)

DeleteFromCrossClusterTasks mocks base method.

func (*MocktableCRUD) DeleteFromCurrentExecutions added in v1.2.7 

func (m *MocktableCRUD) DeleteFromCurrentExecutions(ctx context.Context, filter *CurrentExecutionsFilter) (sql.Result, error)

DeleteFromCurrentExecutions mocks base method.

func (*MocktableCRUD) DeleteFromDomain added in v1.2.7 

func (m *MocktableCRUD) DeleteFromDomain(ctx context.Context, filter *DomainFilter) (sql.Result, error)

DeleteFromDomain mocks base method.

func (*MocktableCRUD) DeleteFromExecutions added in v1.2.7 

func (m *MocktableCRUD) DeleteFromExecutions(ctx context.Context, filter *ExecutionsFilter) (sql.Result, error)

DeleteFromExecutions mocks base method.

func (*MocktableCRUD) DeleteFromHistoryNode added in v1.2.7 

func (m *MocktableCRUD) DeleteFromHistoryNode(ctx context.Context, filter *HistoryNodeFilter) (sql.Result, error)

DeleteFromHistoryNode mocks base method.

func (*MocktableCRUD) DeleteFromHistoryTree added in v1.2.7 

func (m *MocktableCRUD) DeleteFromHistoryTree(ctx context.Context, filter *HistoryTreeFilter) (sql.Result, error)

DeleteFromHistoryTree mocks base method.

func (*MocktableCRUD) DeleteFromReplicationTasks added in v1.2.7 

func (m *MocktableCRUD) DeleteFromReplicationTasks(ctx context.Context, filter *ReplicationTasksFilter) (sql.Result, error)

DeleteFromReplicationTasks mocks base method.

func (*MocktableCRUD) DeleteFromRequestCancelInfoMaps added in v1.2.7 

func (m *MocktableCRUD) DeleteFromRequestCancelInfoMaps(ctx context.Context, filter *RequestCancelInfoMapsFilter) (sql.Result, error)

DeleteFromRequestCancelInfoMaps mocks base method.

func (*MocktableCRUD) DeleteFromSignalInfoMaps added in v1.2.7 

func (m *MocktableCRUD) DeleteFromSignalInfoMaps(ctx context.Context, filter *SignalInfoMapsFilter) (sql.Result, error)

DeleteFromSignalInfoMaps mocks base method.

func (*MocktableCRUD) DeleteFromSignalsRequestedSets added in v1.2.7 

func (m *MocktableCRUD) DeleteFromSignalsRequestedSets(ctx context.Context, filter *SignalsRequestedSetsFilter) (sql.Result, error)

DeleteFromSignalsRequestedSets mocks base method.

func (*MocktableCRUD) DeleteFromTaskLists added in v1.2.7 

func (m *MocktableCRUD) DeleteFromTaskLists(ctx context.Context, filter *TaskListsFilter) (sql.Result, error)

DeleteFromTaskLists mocks base method.

func (*MocktableCRUD) DeleteFromTasks added in v1.2.7 

func (m *MocktableCRUD) DeleteFromTasks(ctx context.Context, filter *TasksFilter) (sql.Result, error)

DeleteFromTasks mocks base method.

func (*MocktableCRUD) DeleteFromTimerInfoMaps added in v1.2.7 

func (m *MocktableCRUD) DeleteFromTimerInfoMaps(ctx context.Context, filter *TimerInfoMapsFilter) (sql.Result, error)

DeleteFromTimerInfoMaps mocks base method.

func (*MocktableCRUD) DeleteFromTimerTasks added in v1.2.7 

func (m *MocktableCRUD) DeleteFromTimerTasks(ctx context.Context, filter *TimerTasksFilter) (sql.Result, error)

DeleteFromTimerTasks mocks base method.

func (*MocktableCRUD) DeleteFromTransferTasks added in v1.2.7 

func (m *MocktableCRUD) DeleteFromTransferTasks(ctx context.Context, filter *TransferTasksFilter) (sql.Result, error)

DeleteFromTransferTasks mocks base method.

func (*MocktableCRUD) DeleteFromVisibility added in v1.2.7 

func (m *MocktableCRUD) DeleteFromVisibility(ctx context.Context, filter *VisibilityFilter) (sql.Result, error)

DeleteFromVisibility mocks base method.

func (*MocktableCRUD) DeleteMessage added in v1.2.7 

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

DeleteMessage mocks base method.

func (*MocktableCRUD) DeleteMessageFromReplicationTasksDLQ added in v1.2.7 

func (m *MocktableCRUD) DeleteMessageFromReplicationTasksDLQ(ctx context.Context, filter *ReplicationTasksDLQFilter) (sql.Result, error)

DeleteMessageFromReplicationTasksDLQ mocks base method.

func (*MocktableCRUD) DeleteMessagesBefore added in v1.2.7 

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

DeleteMessagesBefore mocks base method.

func (*MocktableCRUD) EXPECT added in v1.2.7 

func (m *MocktableCRUD) EXPECT() *MocktableCRUDMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MocktableCRUD) GetAckLevels added in v1.2.7 

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

GetAckLevels mocks base method.

func (*MocktableCRUD) GetAllHistoryTreeBranches added in v1.2.7 

func (m *MocktableCRUD) GetAllHistoryTreeBranches(ctx context.Context, filter *HistoryTreeFilter) ([]HistoryTreeRow, error)

GetAllHistoryTreeBranches mocks base method.

func (*MocktableCRUD) GetLastEnqueuedMessageIDForUpdate added in v1.2.7 

func (m *MocktableCRUD) GetLastEnqueuedMessageIDForUpdate(ctx context.Context, queueType persistence.QueueType) (int64, error)

GetLastEnqueuedMessageIDForUpdate mocks base method.

func (*MocktableCRUD) GetMessagesBetween added in v1.2.7 

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

GetMessagesBetween mocks base method.

func (*MocktableCRUD) GetMessagesFromQueue added in v1.2.7 

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

GetMessagesFromQueue mocks base method.

func (*MocktableCRUD) GetOrphanTasks added in v1.2.7 

func (m *MocktableCRUD) GetOrphanTasks(ctx context.Context, filter *OrphanTasksFilter) ([]TaskKeyRow, error)

GetOrphanTasks mocks base method.

func (*MocktableCRUD) GetQueueSize added in v1.2.7 

func (m *MocktableCRUD) GetQueueSize(ctx context.Context, queueType persistence.QueueType) (int64, error)

GetQueueSize mocks base method.

func (*MocktableCRUD) GetTasksCount added in v1.2.7 

func (m *MocktableCRUD) GetTasksCount(ctx context.Context, filter *TasksFilter) (int64, error)

GetTasksCount mocks base method.

func (*MocktableCRUD) InsertAckLevel added in v1.2.7 

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

InsertAckLevel mocks base method.

func (*MocktableCRUD) InsertConfig added in v1.2.7 

func (m *MocktableCRUD) InsertConfig(ctx context.Context, row *persistence.InternalConfigStoreEntry) error

InsertConfig mocks base method.

func (*MocktableCRUD) InsertIntoBufferedEvents added in v1.2.7 

func (m *MocktableCRUD) InsertIntoBufferedEvents(ctx context.Context, rows []BufferedEventsRow) (sql.Result, error)

InsertIntoBufferedEvents mocks base method.

func (*MocktableCRUD) InsertIntoCrossClusterTasks added in v1.2.7 

func (m *MocktableCRUD) InsertIntoCrossClusterTasks(ctx context.Context, rows []CrossClusterTasksRow) (sql.Result, error)

InsertIntoCrossClusterTasks mocks base method.

func (*MocktableCRUD) InsertIntoCurrentExecutions added in v1.2.7 

func (m *MocktableCRUD) InsertIntoCurrentExecutions(ctx context.Context, row *CurrentExecutionsRow) (sql.Result, error)

InsertIntoCurrentExecutions mocks base method.

func (*MocktableCRUD) InsertIntoDomain added in v1.2.7 

func (m *MocktableCRUD) InsertIntoDomain(ctx context.Context, rows *DomainRow) (sql.Result, error)

InsertIntoDomain mocks base method.

func (*MocktableCRUD) InsertIntoExecutions added in v1.2.7 

func (m *MocktableCRUD) InsertIntoExecutions(ctx context.Context, row *ExecutionsRow) (sql.Result, error)

InsertIntoExecutions mocks base method.

func (*MocktableCRUD) InsertIntoHistoryNode added in v1.2.7 

func (m *MocktableCRUD) InsertIntoHistoryNode(ctx context.Context, row *HistoryNodeRow) (sql.Result, error)

InsertIntoHistoryNode mocks base method.

func (*MocktableCRUD) InsertIntoHistoryTree added in v1.2.7 

func (m *MocktableCRUD) InsertIntoHistoryTree(ctx context.Context, row *HistoryTreeRow) (sql.Result, error)

InsertIntoHistoryTree mocks base method.

func (*MocktableCRUD) InsertIntoQueue added in v1.2.7 

func (m *MocktableCRUD) InsertIntoQueue(ctx context.Context, row *QueueRow) (sql.Result, error)

InsertIntoQueue mocks base method.

func (*MocktableCRUD) InsertIntoReplicationTasks added in v1.2.7 

func (m *MocktableCRUD) InsertIntoReplicationTasks(ctx context.Context, rows []ReplicationTasksRow) (sql.Result, error)

InsertIntoReplicationTasks mocks base method.

func (*MocktableCRUD) InsertIntoReplicationTasksDLQ added in v1.2.7 

func (m *MocktableCRUD) InsertIntoReplicationTasksDLQ(ctx context.Context, row *ReplicationTaskDLQRow) (sql.Result, error)

InsertIntoReplicationTasksDLQ mocks base method.

func (*MocktableCRUD) InsertIntoShards added in v1.2.7 

func (m *MocktableCRUD) InsertIntoShards(ctx context.Context, rows *ShardsRow) (sql.Result, error)

InsertIntoShards mocks base method.

func (*MocktableCRUD) InsertIntoSignalsRequestedSets added in v1.2.7 

func (m *MocktableCRUD) InsertIntoSignalsRequestedSets(ctx context.Context, rows []SignalsRequestedSetsRow) (sql.Result, error)

InsertIntoSignalsRequestedSets mocks base method.

func (*MocktableCRUD) InsertIntoTaskLists added in v1.2.7 

func (m *MocktableCRUD) InsertIntoTaskLists(ctx context.Context, row *TaskListsRow) (sql.Result, error)

InsertIntoTaskLists mocks base method.

func (*MocktableCRUD) InsertIntoTaskListsWithTTL added in v1.2.7 

func (m *MocktableCRUD) InsertIntoTaskListsWithTTL(ctx context.Context, row *TaskListsRowWithTTL) (sql.Result, error)

InsertIntoTaskListsWithTTL mocks base method.

func (*MocktableCRUD) InsertIntoTasks added in v1.2.7 

func (m *MocktableCRUD) InsertIntoTasks(ctx context.Context, rows []TasksRow) (sql.Result, error)

InsertIntoTasks mocks base method.

func (*MocktableCRUD) InsertIntoTasksWithTTL added in v1.2.7 

func (m *MocktableCRUD) InsertIntoTasksWithTTL(ctx context.Context, rows []TasksRowWithTTL) (sql.Result, error)

InsertIntoTasksWithTTL mocks base method.

func (*MocktableCRUD) InsertIntoTimerTasks added in v1.2.7 

func (m *MocktableCRUD) InsertIntoTimerTasks(ctx context.Context, rows []TimerTasksRow) (sql.Result, error)

InsertIntoTimerTasks mocks base method.

func (*MocktableCRUD) InsertIntoTransferTasks added in v1.2.7 

func (m *MocktableCRUD) InsertIntoTransferTasks(ctx context.Context, rows []TransferTasksRow) (sql.Result, error)

InsertIntoTransferTasks mocks base method.

func (*MocktableCRUD) InsertIntoVisibility added in v1.2.7 

func (m *MocktableCRUD) InsertIntoVisibility(ctx context.Context, row *VisibilityRow) (sql.Result, error)

InsertIntoVisibility mocks base method.

func (*MocktableCRUD) LockCurrentExecutions added in v1.2.7 

func (m *MocktableCRUD) LockCurrentExecutions(ctx context.Context, filter *CurrentExecutionsFilter) (*CurrentExecutionsRow, error)

LockCurrentExecutions mocks base method.

func (*MocktableCRUD) LockCurrentExecutionsJoinExecutions added in v1.2.7 

func (m *MocktableCRUD) LockCurrentExecutionsJoinExecutions(ctx context.Context, filter *CurrentExecutionsFilter) ([]CurrentExecutionsRow, error)

LockCurrentExecutionsJoinExecutions mocks base method.

func (*MocktableCRUD) LockDomainMetadata added in v1.2.7 

func (m *MocktableCRUD) LockDomainMetadata(ctx context.Context) error

LockDomainMetadata mocks base method.

func (*MocktableCRUD) LockTaskLists added in v1.2.7 

func (m *MocktableCRUD) LockTaskLists(ctx context.Context, filter *TaskListsFilter) (int64, error)

LockTaskLists mocks base method.

func (*MocktableCRUD) MaxAllowedTTL added in v1.2.7 

func (m *MocktableCRUD) MaxAllowedTTL() (*time.Duration, error)

MaxAllowedTTL mocks base method.

func (*MocktableCRUD) RangeDeleteFromCrossClusterTasks added in v1.2.7 

func (m *MocktableCRUD) RangeDeleteFromCrossClusterTasks(ctx context.Context, filter *CrossClusterTasksFilter) (sql.Result, error)

RangeDeleteFromCrossClusterTasks mocks base method.

func (*MocktableCRUD) RangeDeleteFromReplicationTasks added in v1.2.7 

func (m *MocktableCRUD) RangeDeleteFromReplicationTasks(ctx context.Context, filter *ReplicationTasksFilter) (sql.Result, error)

RangeDeleteFromReplicationTasks mocks base method.

func (*MocktableCRUD) RangeDeleteFromTimerTasks added in v1.2.7 

func (m *MocktableCRUD) RangeDeleteFromTimerTasks(ctx context.Context, filter *TimerTasksFilter) (sql.Result, error)

RangeDeleteFromTimerTasks mocks base method.

func (*MocktableCRUD) RangeDeleteFromTransferTasks added in v1.2.7 

func (m *MocktableCRUD) RangeDeleteFromTransferTasks(ctx context.Context, filter *TransferTasksFilter) (sql.Result, error)

RangeDeleteFromTransferTasks mocks base method.

func (*MocktableCRUD) RangeDeleteMessageFromReplicationTasksDLQ added in v1.2.7 

func (m *MocktableCRUD) RangeDeleteMessageFromReplicationTasksDLQ(ctx context.Context, filter *ReplicationTasksDLQFilter) (sql.Result, error)

RangeDeleteMessageFromReplicationTasksDLQ mocks base method.

func (*MocktableCRUD) RangeDeleteMessages added in v1.2.7 

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

RangeDeleteMessages mocks base method.

func (*MocktableCRUD) ReadLockExecutions added in v1.2.7 

func (m *MocktableCRUD) ReadLockExecutions(ctx context.Context, filter *ExecutionsFilter) (int, error)

ReadLockExecutions mocks base method.

func (*MocktableCRUD) ReadLockShards added in v1.2.7 

func (m *MocktableCRUD) ReadLockShards(ctx context.Context, filter *ShardsFilter) (int, error)

ReadLockShards mocks base method.

func (*MocktableCRUD) ReplaceIntoActivityInfoMaps added in v1.2.7 

func (m *MocktableCRUD) ReplaceIntoActivityInfoMaps(ctx context.Context, rows []ActivityInfoMapsRow) (sql.Result, error)

ReplaceIntoActivityInfoMaps mocks base method.

func (*MocktableCRUD) ReplaceIntoChildExecutionInfoMaps added in v1.2.7 

func (m *MocktableCRUD) ReplaceIntoChildExecutionInfoMaps(ctx context.Context, rows []ChildExecutionInfoMapsRow) (sql.Result, error)

ReplaceIntoChildExecutionInfoMaps mocks base method.

func (*MocktableCRUD) ReplaceIntoRequestCancelInfoMaps added in v1.2.7 

func (m *MocktableCRUD) ReplaceIntoRequestCancelInfoMaps(ctx context.Context, rows []RequestCancelInfoMapsRow) (sql.Result, error)

ReplaceIntoRequestCancelInfoMaps mocks base method.

func (*MocktableCRUD) ReplaceIntoSignalInfoMaps added in v1.2.7 

func (m *MocktableCRUD) ReplaceIntoSignalInfoMaps(ctx context.Context, rows []SignalInfoMapsRow) (sql.Result, error)

ReplaceIntoSignalInfoMaps mocks base method.

func (*MocktableCRUD) ReplaceIntoTimerInfoMaps added in v1.2.7 

func (m *MocktableCRUD) ReplaceIntoTimerInfoMaps(ctx context.Context, rows []TimerInfoMapsRow) (sql.Result, error)

ReplaceIntoTimerInfoMaps mocks base method.

func (*MocktableCRUD) ReplaceIntoVisibility added in v1.2.7 

func (m *MocktableCRUD) ReplaceIntoVisibility(ctx context.Context, row *VisibilityRow) (sql.Result, error)

ReplaceIntoVisibility mocks base method.

func (*MocktableCRUD) SelectFromActivityInfoMaps added in v1.2.7 

func (m *MocktableCRUD) SelectFromActivityInfoMaps(ctx context.Context, filter *ActivityInfoMapsFilter) ([]ActivityInfoMapsRow, error)

SelectFromActivityInfoMaps mocks base method.

func (*MocktableCRUD) SelectFromBufferedEvents added in v1.2.7 

func (m *MocktableCRUD) SelectFromBufferedEvents(ctx context.Context, filter *BufferedEventsFilter) ([]BufferedEventsRow, error)

SelectFromBufferedEvents mocks base method.

func (*MocktableCRUD) SelectFromChildExecutionInfoMaps added in v1.2.7 

func (m *MocktableCRUD) SelectFromChildExecutionInfoMaps(ctx context.Context, filter *ChildExecutionInfoMapsFilter) ([]ChildExecutionInfoMapsRow, error)

SelectFromChildExecutionInfoMaps mocks base method.

func (*MocktableCRUD) SelectFromCrossClusterTasks added in v1.2.7 

func (m *MocktableCRUD) SelectFromCrossClusterTasks(ctx context.Context, filter *CrossClusterTasksFilter) ([]CrossClusterTasksRow, error)

SelectFromCrossClusterTasks mocks base method.

func (*MocktableCRUD) SelectFromCurrentExecutions added in v1.2.7 

func (m *MocktableCRUD) SelectFromCurrentExecutions(ctx context.Context, filter *CurrentExecutionsFilter) (*CurrentExecutionsRow, error)

SelectFromCurrentExecutions mocks base method.

func (*MocktableCRUD) SelectFromDomain added in v1.2.7 

func (m *MocktableCRUD) SelectFromDomain(ctx context.Context, filter *DomainFilter) ([]DomainRow, error)

SelectFromDomain mocks base method.

func (*MocktableCRUD) SelectFromDomainMetadata added in v1.2.7 

func (m *MocktableCRUD) SelectFromDomainMetadata(ctx context.Context) (*DomainMetadataRow, error)

SelectFromDomainMetadata mocks base method.

func (*MocktableCRUD) SelectFromExecutions added in v1.2.7 

func (m *MocktableCRUD) SelectFromExecutions(ctx context.Context, filter *ExecutionsFilter) ([]ExecutionsRow, error)

SelectFromExecutions mocks base method.

func (*MocktableCRUD) SelectFromHistoryNode added in v1.2.7 

func (m *MocktableCRUD) SelectFromHistoryNode(ctx context.Context, filter *HistoryNodeFilter) ([]HistoryNodeRow, error)

SelectFromHistoryNode mocks base method.

func (*MocktableCRUD) SelectFromHistoryTree added in v1.2.7 

func (m *MocktableCRUD) SelectFromHistoryTree(ctx context.Context, filter *HistoryTreeFilter) ([]HistoryTreeRow, error)

SelectFromHistoryTree mocks base method.

func (*MocktableCRUD) SelectFromReplicationDLQ added in v1.2.7 

func (m *MocktableCRUD) SelectFromReplicationDLQ(ctx context.Context, filter *ReplicationTaskDLQFilter) (int64, error)

SelectFromReplicationDLQ mocks base method.

func (*MocktableCRUD) SelectFromReplicationTasks added in v1.2.7 

func (m *MocktableCRUD) SelectFromReplicationTasks(ctx context.Context, filter *ReplicationTasksFilter) ([]ReplicationTasksRow, error)

SelectFromReplicationTasks mocks base method.

func (*MocktableCRUD) SelectFromReplicationTasksDLQ added in v1.2.7 

func (m *MocktableCRUD) SelectFromReplicationTasksDLQ(ctx context.Context, filter *ReplicationTasksDLQFilter) ([]ReplicationTasksRow, error)

SelectFromReplicationTasksDLQ mocks base method.

func (*MocktableCRUD) SelectFromRequestCancelInfoMaps added in v1.2.7 

func (m *MocktableCRUD) SelectFromRequestCancelInfoMaps(ctx context.Context, filter *RequestCancelInfoMapsFilter) ([]RequestCancelInfoMapsRow, error)

SelectFromRequestCancelInfoMaps mocks base method.

func (*MocktableCRUD) SelectFromShards added in v1.2.7 

func (m *MocktableCRUD) SelectFromShards(ctx context.Context, filter *ShardsFilter) (*ShardsRow, error)

SelectFromShards mocks base method.

func (*MocktableCRUD) SelectFromSignalInfoMaps added in v1.2.7 

func (m *MocktableCRUD) SelectFromSignalInfoMaps(ctx context.Context, filter *SignalInfoMapsFilter) ([]SignalInfoMapsRow, error)

SelectFromSignalInfoMaps mocks base method.

func (*MocktableCRUD) SelectFromSignalsRequestedSets added in v1.2.7 

func (m *MocktableCRUD) SelectFromSignalsRequestedSets(ctx context.Context, filter *SignalsRequestedSetsFilter) ([]SignalsRequestedSetsRow, error)

SelectFromSignalsRequestedSets mocks base method.

func (*MocktableCRUD) SelectFromTaskLists added in v1.2.7 

func (m *MocktableCRUD) SelectFromTaskLists(ctx context.Context, filter *TaskListsFilter) ([]TaskListsRow, error)

SelectFromTaskLists mocks base method.

func (*MocktableCRUD) SelectFromTasks added in v1.2.7 

func (m *MocktableCRUD) SelectFromTasks(ctx context.Context, filter *TasksFilter) ([]TasksRow, error)

SelectFromTasks mocks base method.

func (*MocktableCRUD) SelectFromTimerInfoMaps added in v1.2.7 

func (m *MocktableCRUD) SelectFromTimerInfoMaps(ctx context.Context, filter *TimerInfoMapsFilter) ([]TimerInfoMapsRow, error)

SelectFromTimerInfoMaps mocks base method.

func (*MocktableCRUD) SelectFromTimerTasks added in v1.2.7 

func (m *MocktableCRUD) SelectFromTimerTasks(ctx context.Context, filter *TimerTasksFilter) ([]TimerTasksRow, error)

SelectFromTimerTasks mocks base method.

func (*MocktableCRUD) SelectFromTransferTasks added in v1.2.7 

func (m *MocktableCRUD) SelectFromTransferTasks(ctx context.Context, filter *TransferTasksFilter) ([]TransferTasksRow, error)

SelectFromTransferTasks mocks base method.

func (*MocktableCRUD) SelectFromVisibility added in v1.2.7 

func (m *MocktableCRUD) SelectFromVisibility(ctx context.Context, filter *VisibilityFilter) ([]VisibilityRow, error)

SelectFromVisibility mocks base method.

func (*MocktableCRUD) SelectLatestConfig added in v1.2.7 

func (m *MocktableCRUD) SelectLatestConfig(ctx context.Context, rowType int) (*persistence.InternalConfigStoreEntry, error)

SelectLatestConfig mocks base method.

func (*MocktableCRUD) SupportsAsyncTransaction added in v1.2.7 

func (m *MocktableCRUD) SupportsAsyncTransaction() bool

SupportsAsyncTransaction mocks base method.

func (*MocktableCRUD) SupportsTTL added in v1.2.7 

func (m *MocktableCRUD) SupportsTTL() bool

SupportsTTL mocks base method.

func (*MocktableCRUD) UpdateAckLevels added in v1.2.7 

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

UpdateAckLevels mocks base method.

func (*MocktableCRUD) UpdateCurrentExecutions added in v1.2.7 

func (m *MocktableCRUD) UpdateCurrentExecutions(ctx context.Context, row *CurrentExecutionsRow) (sql.Result, error)

UpdateCurrentExecutions mocks base method.

func (*MocktableCRUD) UpdateDomain added in v1.2.7 

func (m *MocktableCRUD) UpdateDomain(ctx context.Context, row *DomainRow) (sql.Result, error)

UpdateDomain mocks base method.

func (*MocktableCRUD) UpdateDomainMetadata added in v1.2.7 

func (m *MocktableCRUD) UpdateDomainMetadata(ctx context.Context, row *DomainMetadataRow) (sql.Result, error)

UpdateDomainMetadata mocks base method.

func (*MocktableCRUD) UpdateExecutions added in v1.2.7 

func (m *MocktableCRUD) UpdateExecutions(ctx context.Context, row *ExecutionsRow) (sql.Result, error)

UpdateExecutions mocks base method.

func (*MocktableCRUD) UpdateShards added in v1.2.7 

func (m *MocktableCRUD) UpdateShards(ctx context.Context, row *ShardsRow) (sql.Result, error)

UpdateShards mocks base method.

func (*MocktableCRUD) UpdateTaskLists added in v1.2.7 

func (m *MocktableCRUD) UpdateTaskLists(ctx context.Context, row *TaskListsRow) (sql.Result, error)

UpdateTaskLists mocks base method.

func (*MocktableCRUD) UpdateTaskListsWithTTL added in v1.2.7 

func (m *MocktableCRUD) UpdateTaskListsWithTTL(ctx context.Context, row *TaskListsRowWithTTL) (sql.Result, error)

UpdateTaskListsWithTTL mocks base method.

func (*MocktableCRUD) WriteLockExecutions added in v1.2.7 

func (m *MocktableCRUD) WriteLockExecutions(ctx context.Context, filter *ExecutionsFilter) (int, error)

WriteLockExecutions mocks base method.

func (*MocktableCRUD) WriteLockShards added in v1.2.7 

func (m *MocktableCRUD) WriteLockShards(ctx context.Context, filter *ShardsFilter) (int, error)

WriteLockShards mocks base method.

type MocktableCRUDMockRecorder added in v1.2.7 

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

MocktableCRUDMockRecorder is the mock recorder for MocktableCRUD.

func (*MocktableCRUDMockRecorder) DeleteFromActivityInfoMaps added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) DeleteFromActivityInfoMaps(ctx, filter interface{}) *gomock.Call

DeleteFromActivityInfoMaps indicates an expected call of DeleteFromActivityInfoMaps.

func (*MocktableCRUDMockRecorder) DeleteFromBufferedEvents added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) DeleteFromBufferedEvents(ctx, filter interface{}) *gomock.Call

DeleteFromBufferedEvents indicates an expected call of DeleteFromBufferedEvents.

func (*MocktableCRUDMockRecorder) DeleteFromChildExecutionInfoMaps added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) DeleteFromChildExecutionInfoMaps(ctx, filter interface{}) *gomock.Call

DeleteFromChildExecutionInfoMaps indicates an expected call of DeleteFromChildExecutionInfoMaps.

func (*MocktableCRUDMockRecorder) DeleteFromCrossClusterTasks added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) DeleteFromCrossClusterTasks(ctx, filter interface{}) *gomock.Call

DeleteFromCrossClusterTasks indicates an expected call of DeleteFromCrossClusterTasks.

func (*MocktableCRUDMockRecorder) DeleteFromCurrentExecutions added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) DeleteFromCurrentExecutions(ctx, filter interface{}) *gomock.Call

DeleteFromCurrentExecutions indicates an expected call of DeleteFromCurrentExecutions.

func (*MocktableCRUDMockRecorder) DeleteFromDomain added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) DeleteFromDomain(ctx, filter interface{}) *gomock.Call

DeleteFromDomain indicates an expected call of DeleteFromDomain.

func (*MocktableCRUDMockRecorder) DeleteFromExecutions added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) DeleteFromExecutions(ctx, filter interface{}) *gomock.Call

DeleteFromExecutions indicates an expected call of DeleteFromExecutions.

func (*MocktableCRUDMockRecorder) DeleteFromHistoryNode added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) DeleteFromHistoryNode(ctx, filter interface{}) *gomock.Call

DeleteFromHistoryNode indicates an expected call of DeleteFromHistoryNode.

func (*MocktableCRUDMockRecorder) DeleteFromHistoryTree added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) DeleteFromHistoryTree(ctx, filter interface{}) *gomock.Call

DeleteFromHistoryTree indicates an expected call of DeleteFromHistoryTree.

func (*MocktableCRUDMockRecorder) DeleteFromReplicationTasks added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) DeleteFromReplicationTasks(ctx, filter interface{}) *gomock.Call

DeleteFromReplicationTasks indicates an expected call of DeleteFromReplicationTasks.

func (*MocktableCRUDMockRecorder) DeleteFromRequestCancelInfoMaps added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) DeleteFromRequestCancelInfoMaps(ctx, filter interface{}) *gomock.Call

DeleteFromRequestCancelInfoMaps indicates an expected call of DeleteFromRequestCancelInfoMaps.

func (*MocktableCRUDMockRecorder) DeleteFromSignalInfoMaps added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) DeleteFromSignalInfoMaps(ctx, filter interface{}) *gomock.Call

DeleteFromSignalInfoMaps indicates an expected call of DeleteFromSignalInfoMaps.

func (*MocktableCRUDMockRecorder) DeleteFromSignalsRequestedSets added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) DeleteFromSignalsRequestedSets(ctx, filter interface{}) *gomock.Call

DeleteFromSignalsRequestedSets indicates an expected call of DeleteFromSignalsRequestedSets.

func (*MocktableCRUDMockRecorder) DeleteFromTaskLists added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) DeleteFromTaskLists(ctx, filter interface{}) *gomock.Call

DeleteFromTaskLists indicates an expected call of DeleteFromTaskLists.

func (*MocktableCRUDMockRecorder) DeleteFromTasks added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) DeleteFromTasks(ctx, filter interface{}) *gomock.Call

DeleteFromTasks indicates an expected call of DeleteFromTasks.

func (*MocktableCRUDMockRecorder) DeleteFromTimerInfoMaps added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) DeleteFromTimerInfoMaps(ctx, filter interface{}) *gomock.Call

DeleteFromTimerInfoMaps indicates an expected call of DeleteFromTimerInfoMaps.

func (*MocktableCRUDMockRecorder) DeleteFromTimerTasks added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) DeleteFromTimerTasks(ctx, filter interface{}) *gomock.Call

DeleteFromTimerTasks indicates an expected call of DeleteFromTimerTasks.

func (*MocktableCRUDMockRecorder) DeleteFromTransferTasks added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) DeleteFromTransferTasks(ctx, filter interface{}) *gomock.Call

DeleteFromTransferTasks indicates an expected call of DeleteFromTransferTasks.

func (*MocktableCRUDMockRecorder) DeleteFromVisibility added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) DeleteFromVisibility(ctx, filter interface{}) *gomock.Call

DeleteFromVisibility indicates an expected call of DeleteFromVisibility.

func (*MocktableCRUDMockRecorder) DeleteMessage added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) DeleteMessage(ctx, queueType, messageID interface{}) *gomock.Call

DeleteMessage indicates an expected call of DeleteMessage.

func (*MocktableCRUDMockRecorder) DeleteMessageFromReplicationTasksDLQ added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) DeleteMessageFromReplicationTasksDLQ(ctx, filter interface{}) *gomock.Call

DeleteMessageFromReplicationTasksDLQ indicates an expected call of DeleteMessageFromReplicationTasksDLQ.

func (*MocktableCRUDMockRecorder) DeleteMessagesBefore added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) DeleteMessagesBefore(ctx, queueType, messageID interface{}) *gomock.Call

DeleteMessagesBefore indicates an expected call of DeleteMessagesBefore.

func (*MocktableCRUDMockRecorder) GetAckLevels added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) GetAckLevels(ctx, queueType, forUpdate interface{}) *gomock.Call

GetAckLevels indicates an expected call of GetAckLevels.

func (*MocktableCRUDMockRecorder) GetAllHistoryTreeBranches added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) GetAllHistoryTreeBranches(ctx, filter interface{}) *gomock.Call

GetAllHistoryTreeBranches indicates an expected call of GetAllHistoryTreeBranches.

func (*MocktableCRUDMockRecorder) GetLastEnqueuedMessageIDForUpdate added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) GetLastEnqueuedMessageIDForUpdate(ctx, queueType interface{}) *gomock.Call

GetLastEnqueuedMessageIDForUpdate indicates an expected call of GetLastEnqueuedMessageIDForUpdate.

func (*MocktableCRUDMockRecorder) GetMessagesBetween added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) GetMessagesBetween(ctx, queueType, firstMessageID, lastMessageID, maxRows interface{}) *gomock.Call

GetMessagesBetween indicates an expected call of GetMessagesBetween.

func (*MocktableCRUDMockRecorder) GetMessagesFromQueue added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) GetMessagesFromQueue(ctx, queueType, lastMessageID, maxRows interface{}) *gomock.Call

GetMessagesFromQueue indicates an expected call of GetMessagesFromQueue.

func (*MocktableCRUDMockRecorder) GetOrphanTasks added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) GetOrphanTasks(ctx, filter interface{}) *gomock.Call

GetOrphanTasks indicates an expected call of GetOrphanTasks.

func (*MocktableCRUDMockRecorder) GetQueueSize added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) GetQueueSize(ctx, queueType interface{}) *gomock.Call

GetQueueSize indicates an expected call of GetQueueSize.

func (*MocktableCRUDMockRecorder) GetTasksCount added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) GetTasksCount(ctx, filter interface{}) *gomock.Call

GetTasksCount indicates an expected call of GetTasksCount.

func (*MocktableCRUDMockRecorder) InsertAckLevel added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) InsertAckLevel(ctx, queueType, messageID, clusterName interface{}) *gomock.Call

InsertAckLevel indicates an expected call of InsertAckLevel.

func (*MocktableCRUDMockRecorder) InsertConfig added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) InsertConfig(ctx, row interface{}) *gomock.Call

InsertConfig indicates an expected call of InsertConfig.

func (*MocktableCRUDMockRecorder) InsertIntoBufferedEvents added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) InsertIntoBufferedEvents(ctx, rows interface{}) *gomock.Call

InsertIntoBufferedEvents indicates an expected call of InsertIntoBufferedEvents.

func (*MocktableCRUDMockRecorder) InsertIntoCrossClusterTasks added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) InsertIntoCrossClusterTasks(ctx, rows interface{}) *gomock.Call

InsertIntoCrossClusterTasks indicates an expected call of InsertIntoCrossClusterTasks.

func (*MocktableCRUDMockRecorder) InsertIntoCurrentExecutions added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) InsertIntoCurrentExecutions(ctx, row interface{}) *gomock.Call

InsertIntoCurrentExecutions indicates an expected call of InsertIntoCurrentExecutions.

func (*MocktableCRUDMockRecorder) InsertIntoDomain added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) InsertIntoDomain(ctx, rows interface{}) *gomock.Call

InsertIntoDomain indicates an expected call of InsertIntoDomain.

func (*MocktableCRUDMockRecorder) InsertIntoExecutions added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) InsertIntoExecutions(ctx, row interface{}) *gomock.Call

InsertIntoExecutions indicates an expected call of InsertIntoExecutions.

func (*MocktableCRUDMockRecorder) InsertIntoHistoryNode added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) InsertIntoHistoryNode(ctx, row interface{}) *gomock.Call

InsertIntoHistoryNode indicates an expected call of InsertIntoHistoryNode.

func (*MocktableCRUDMockRecorder) InsertIntoHistoryTree added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) InsertIntoHistoryTree(ctx, row interface{}) *gomock.Call

InsertIntoHistoryTree indicates an expected call of InsertIntoHistoryTree.

func (*MocktableCRUDMockRecorder) InsertIntoQueue added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) InsertIntoQueue(ctx, row interface{}) *gomock.Call

InsertIntoQueue indicates an expected call of InsertIntoQueue.

func (*MocktableCRUDMockRecorder) InsertIntoReplicationTasks added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) InsertIntoReplicationTasks(ctx, rows interface{}) *gomock.Call

InsertIntoReplicationTasks indicates an expected call of InsertIntoReplicationTasks.

func (*MocktableCRUDMockRecorder) InsertIntoReplicationTasksDLQ added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) InsertIntoReplicationTasksDLQ(ctx, row interface{}) *gomock.Call

InsertIntoReplicationTasksDLQ indicates an expected call of InsertIntoReplicationTasksDLQ.

func (*MocktableCRUDMockRecorder) InsertIntoShards added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) InsertIntoShards(ctx, rows interface{}) *gomock.Call

InsertIntoShards indicates an expected call of InsertIntoShards.

func (*MocktableCRUDMockRecorder) InsertIntoSignalsRequestedSets added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) InsertIntoSignalsRequestedSets(ctx, rows interface{}) *gomock.Call

InsertIntoSignalsRequestedSets indicates an expected call of InsertIntoSignalsRequestedSets.

func (*MocktableCRUDMockRecorder) InsertIntoTaskLists added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) InsertIntoTaskLists(ctx, row interface{}) *gomock.Call

InsertIntoTaskLists indicates an expected call of InsertIntoTaskLists.

func (*MocktableCRUDMockRecorder) InsertIntoTaskListsWithTTL added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) InsertIntoTaskListsWithTTL(ctx, row interface{}) *gomock.Call

InsertIntoTaskListsWithTTL indicates an expected call of InsertIntoTaskListsWithTTL.

func (*MocktableCRUDMockRecorder) InsertIntoTasks added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) InsertIntoTasks(ctx, rows interface{}) *gomock.Call

InsertIntoTasks indicates an expected call of InsertIntoTasks.

func (*MocktableCRUDMockRecorder) InsertIntoTasksWithTTL added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) InsertIntoTasksWithTTL(ctx, rows interface{}) *gomock.Call

InsertIntoTasksWithTTL indicates an expected call of InsertIntoTasksWithTTL.

func (*MocktableCRUDMockRecorder) InsertIntoTimerTasks added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) InsertIntoTimerTasks(ctx, rows interface{}) *gomock.Call

InsertIntoTimerTasks indicates an expected call of InsertIntoTimerTasks.

func (*MocktableCRUDMockRecorder) InsertIntoTransferTasks added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) InsertIntoTransferTasks(ctx, rows interface{}) *gomock.Call

InsertIntoTransferTasks indicates an expected call of InsertIntoTransferTasks.

func (*MocktableCRUDMockRecorder) InsertIntoVisibility added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) InsertIntoVisibility(ctx, row interface{}) *gomock.Call

InsertIntoVisibility indicates an expected call of InsertIntoVisibility.

func (*MocktableCRUDMockRecorder) LockCurrentExecutions added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) LockCurrentExecutions(ctx, filter interface{}) *gomock.Call

LockCurrentExecutions indicates an expected call of LockCurrentExecutions.

func (*MocktableCRUDMockRecorder) LockCurrentExecutionsJoinExecutions added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) LockCurrentExecutionsJoinExecutions(ctx, filter interface{}) *gomock.Call

LockCurrentExecutionsJoinExecutions indicates an expected call of LockCurrentExecutionsJoinExecutions.

func (*MocktableCRUDMockRecorder) LockDomainMetadata added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) LockDomainMetadata(ctx interface{}) *gomock.Call

LockDomainMetadata indicates an expected call of LockDomainMetadata.

func (*MocktableCRUDMockRecorder) LockTaskLists added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) LockTaskLists(ctx, filter interface{}) *gomock.Call

LockTaskLists indicates an expected call of LockTaskLists.

func (*MocktableCRUDMockRecorder) MaxAllowedTTL added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) MaxAllowedTTL() *gomock.Call

MaxAllowedTTL indicates an expected call of MaxAllowedTTL.

func (*MocktableCRUDMockRecorder) RangeDeleteFromCrossClusterTasks added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) RangeDeleteFromCrossClusterTasks(ctx, filter interface{}) *gomock.Call

RangeDeleteFromCrossClusterTasks indicates an expected call of RangeDeleteFromCrossClusterTasks.

func (*MocktableCRUDMockRecorder) RangeDeleteFromReplicationTasks added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) RangeDeleteFromReplicationTasks(ctx, filter interface{}) *gomock.Call

RangeDeleteFromReplicationTasks indicates an expected call of RangeDeleteFromReplicationTasks.

func (*MocktableCRUDMockRecorder) RangeDeleteFromTimerTasks added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) RangeDeleteFromTimerTasks(ctx, filter interface{}) *gomock.Call

RangeDeleteFromTimerTasks indicates an expected call of RangeDeleteFromTimerTasks.

func (*MocktableCRUDMockRecorder) RangeDeleteFromTransferTasks added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) RangeDeleteFromTransferTasks(ctx, filter interface{}) *gomock.Call

RangeDeleteFromTransferTasks indicates an expected call of RangeDeleteFromTransferTasks.

func (*MocktableCRUDMockRecorder) RangeDeleteMessageFromReplicationTasksDLQ added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) RangeDeleteMessageFromReplicationTasksDLQ(ctx, filter interface{}) *gomock.Call

RangeDeleteMessageFromReplicationTasksDLQ indicates an expected call of RangeDeleteMessageFromReplicationTasksDLQ.

func (*MocktableCRUDMockRecorder) RangeDeleteMessages added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) RangeDeleteMessages(ctx, queueType, exclusiveBeginMessageID, inclusiveEndMessageID interface{}) *gomock.Call

RangeDeleteMessages indicates an expected call of RangeDeleteMessages.

func (*MocktableCRUDMockRecorder) ReadLockExecutions added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) ReadLockExecutions(ctx, filter interface{}) *gomock.Call

ReadLockExecutions indicates an expected call of ReadLockExecutions.

func (*MocktableCRUDMockRecorder) ReadLockShards added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) ReadLockShards(ctx, filter interface{}) *gomock.Call

ReadLockShards indicates an expected call of ReadLockShards.

func (*MocktableCRUDMockRecorder) ReplaceIntoActivityInfoMaps added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) ReplaceIntoActivityInfoMaps(ctx, rows interface{}) *gomock.Call

ReplaceIntoActivityInfoMaps indicates an expected call of ReplaceIntoActivityInfoMaps.

func (*MocktableCRUDMockRecorder) ReplaceIntoChildExecutionInfoMaps added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) ReplaceIntoChildExecutionInfoMaps(ctx, rows interface{}) *gomock.Call

ReplaceIntoChildExecutionInfoMaps indicates an expected call of ReplaceIntoChildExecutionInfoMaps.

func (*MocktableCRUDMockRecorder) ReplaceIntoRequestCancelInfoMaps added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) ReplaceIntoRequestCancelInfoMaps(ctx, rows interface{}) *gomock.Call

ReplaceIntoRequestCancelInfoMaps indicates an expected call of ReplaceIntoRequestCancelInfoMaps.

func (*MocktableCRUDMockRecorder) ReplaceIntoSignalInfoMaps added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) ReplaceIntoSignalInfoMaps(ctx, rows interface{}) *gomock.Call

ReplaceIntoSignalInfoMaps indicates an expected call of ReplaceIntoSignalInfoMaps.

func (*MocktableCRUDMockRecorder) ReplaceIntoTimerInfoMaps added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) ReplaceIntoTimerInfoMaps(ctx, rows interface{}) *gomock.Call

ReplaceIntoTimerInfoMaps indicates an expected call of ReplaceIntoTimerInfoMaps.

func (*MocktableCRUDMockRecorder) ReplaceIntoVisibility added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) ReplaceIntoVisibility(ctx, row interface{}) *gomock.Call

ReplaceIntoVisibility indicates an expected call of ReplaceIntoVisibility.

func (*MocktableCRUDMockRecorder) SelectFromActivityInfoMaps added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) SelectFromActivityInfoMaps(ctx, filter interface{}) *gomock.Call

SelectFromActivityInfoMaps indicates an expected call of SelectFromActivityInfoMaps.

func (*MocktableCRUDMockRecorder) SelectFromBufferedEvents added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) SelectFromBufferedEvents(ctx, filter interface{}) *gomock.Call

SelectFromBufferedEvents indicates an expected call of SelectFromBufferedEvents.

func (*MocktableCRUDMockRecorder) SelectFromChildExecutionInfoMaps added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) SelectFromChildExecutionInfoMaps(ctx, filter interface{}) *gomock.Call

SelectFromChildExecutionInfoMaps indicates an expected call of SelectFromChildExecutionInfoMaps.

func (*MocktableCRUDMockRecorder) SelectFromCrossClusterTasks added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) SelectFromCrossClusterTasks(ctx, filter interface{}) *gomock.Call

SelectFromCrossClusterTasks indicates an expected call of SelectFromCrossClusterTasks.

func (*MocktableCRUDMockRecorder) SelectFromCurrentExecutions added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) SelectFromCurrentExecutions(ctx, filter interface{}) *gomock.Call

SelectFromCurrentExecutions indicates an expected call of SelectFromCurrentExecutions.

func (*MocktableCRUDMockRecorder) SelectFromDomain added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) SelectFromDomain(ctx, filter interface{}) *gomock.Call

SelectFromDomain indicates an expected call of SelectFromDomain.

func (*MocktableCRUDMockRecorder) SelectFromDomainMetadata added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) SelectFromDomainMetadata(ctx interface{}) *gomock.Call

SelectFromDomainMetadata indicates an expected call of SelectFromDomainMetadata.

func (*MocktableCRUDMockRecorder) SelectFromExecutions added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) SelectFromExecutions(ctx, filter interface{}) *gomock.Call

SelectFromExecutions indicates an expected call of SelectFromExecutions.

func (*MocktableCRUDMockRecorder) SelectFromHistoryNode added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) SelectFromHistoryNode(ctx, filter interface{}) *gomock.Call

SelectFromHistoryNode indicates an expected call of SelectFromHistoryNode.

func (*MocktableCRUDMockRecorder) SelectFromHistoryTree added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) SelectFromHistoryTree(ctx, filter interface{}) *gomock.Call

SelectFromHistoryTree indicates an expected call of SelectFromHistoryTree.

func (*MocktableCRUDMockRecorder) SelectFromReplicationDLQ added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) SelectFromReplicationDLQ(ctx, filter interface{}) *gomock.Call

SelectFromReplicationDLQ indicates an expected call of SelectFromReplicationDLQ.

func (*MocktableCRUDMockRecorder) SelectFromReplicationTasks added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) SelectFromReplicationTasks(ctx, filter interface{}) *gomock.Call

SelectFromReplicationTasks indicates an expected call of SelectFromReplicationTasks.

func (*MocktableCRUDMockRecorder) SelectFromReplicationTasksDLQ added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) SelectFromReplicationTasksDLQ(ctx, filter interface{}) *gomock.Call

SelectFromReplicationTasksDLQ indicates an expected call of SelectFromReplicationTasksDLQ.

func (*MocktableCRUDMockRecorder) SelectFromRequestCancelInfoMaps added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) SelectFromRequestCancelInfoMaps(ctx, filter interface{}) *gomock.Call

SelectFromRequestCancelInfoMaps indicates an expected call of SelectFromRequestCancelInfoMaps.

func (*MocktableCRUDMockRecorder) SelectFromShards added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) SelectFromShards(ctx, filter interface{}) *gomock.Call

SelectFromShards indicates an expected call of SelectFromShards.

func (*MocktableCRUDMockRecorder) SelectFromSignalInfoMaps added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) SelectFromSignalInfoMaps(ctx, filter interface{}) *gomock.Call

SelectFromSignalInfoMaps indicates an expected call of SelectFromSignalInfoMaps.

func (*MocktableCRUDMockRecorder) SelectFromSignalsRequestedSets added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) SelectFromSignalsRequestedSets(ctx, filter interface{}) *gomock.Call

SelectFromSignalsRequestedSets indicates an expected call of SelectFromSignalsRequestedSets.

func (*MocktableCRUDMockRecorder) SelectFromTaskLists added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) SelectFromTaskLists(ctx, filter interface{}) *gomock.Call

SelectFromTaskLists indicates an expected call of SelectFromTaskLists.

func (*MocktableCRUDMockRecorder) SelectFromTasks added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) SelectFromTasks(ctx, filter interface{}) *gomock.Call

SelectFromTasks indicates an expected call of SelectFromTasks.

func (*MocktableCRUDMockRecorder) SelectFromTimerInfoMaps added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) SelectFromTimerInfoMaps(ctx, filter interface{}) *gomock.Call

SelectFromTimerInfoMaps indicates an expected call of SelectFromTimerInfoMaps.

func (*MocktableCRUDMockRecorder) SelectFromTimerTasks added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) SelectFromTimerTasks(ctx, filter interface{}) *gomock.Call

SelectFromTimerTasks indicates an expected call of SelectFromTimerTasks.

func (*MocktableCRUDMockRecorder) SelectFromTransferTasks added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) SelectFromTransferTasks(ctx, filter interface{}) *gomock.Call

SelectFromTransferTasks indicates an expected call of SelectFromTransferTasks.

func (*MocktableCRUDMockRecorder) SelectFromVisibility added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) SelectFromVisibility(ctx, filter interface{}) *gomock.Call

SelectFromVisibility indicates an expected call of SelectFromVisibility.

func (*MocktableCRUDMockRecorder) SelectLatestConfig added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) SelectLatestConfig(ctx, rowType interface{}) *gomock.Call

SelectLatestConfig indicates an expected call of SelectLatestConfig.

func (*MocktableCRUDMockRecorder) SupportsAsyncTransaction added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) SupportsAsyncTransaction() *gomock.Call

SupportsAsyncTransaction indicates an expected call of SupportsAsyncTransaction.

func (*MocktableCRUDMockRecorder) SupportsTTL added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) SupportsTTL() *gomock.Call

SupportsTTL indicates an expected call of SupportsTTL.

func (*MocktableCRUDMockRecorder) UpdateAckLevels added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) UpdateAckLevels(ctx, queueType, clusterAckLevels interface{}) *gomock.Call

UpdateAckLevels indicates an expected call of UpdateAckLevels.

func (*MocktableCRUDMockRecorder) UpdateCurrentExecutions added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) UpdateCurrentExecutions(ctx, row interface{}) *gomock.Call

UpdateCurrentExecutions indicates an expected call of UpdateCurrentExecutions.

func (*MocktableCRUDMockRecorder) UpdateDomain added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) UpdateDomain(ctx, row interface{}) *gomock.Call

UpdateDomain indicates an expected call of UpdateDomain.

func (*MocktableCRUDMockRecorder) UpdateDomainMetadata added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) UpdateDomainMetadata(ctx, row interface{}) *gomock.Call

UpdateDomainMetadata indicates an expected call of UpdateDomainMetadata.

func (*MocktableCRUDMockRecorder) UpdateExecutions added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) UpdateExecutions(ctx, row interface{}) *gomock.Call

UpdateExecutions indicates an expected call of UpdateExecutions.

func (*MocktableCRUDMockRecorder) UpdateShards added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) UpdateShards(ctx, row interface{}) *gomock.Call

UpdateShards indicates an expected call of UpdateShards.

func (*MocktableCRUDMockRecorder) UpdateTaskLists added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) UpdateTaskLists(ctx, row interface{}) *gomock.Call

UpdateTaskLists indicates an expected call of UpdateTaskLists.

func (*MocktableCRUDMockRecorder) UpdateTaskListsWithTTL added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) UpdateTaskListsWithTTL(ctx, row interface{}) *gomock.Call

UpdateTaskListsWithTTL indicates an expected call of UpdateTaskListsWithTTL.

func (*MocktableCRUDMockRecorder) WriteLockExecutions added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) WriteLockExecutions(ctx, filter interface{}) *gomock.Call

WriteLockExecutions indicates an expected call of WriteLockExecutions.

func (*MocktableCRUDMockRecorder) WriteLockShards added in v1.2.7 

func (mr *MocktableCRUDMockRecorder) WriteLockShards(ctx, filter interface{}) *gomock.Call

WriteLockShards indicates an expected call of WriteLockShards.

type OrphanTasksFilter added in v0.21.0 

type OrphanTasksFilter struct {
	Limit *int
}

OrphanTasksFilter contains the parameters controlling orphan deletion

type Plugin 

type Plugin interface {
	CreateDB(cfg *config.SQL) (DB, error)
	CreateAdminDB(cfg *config.SQL) (AdminDB, error)
}

Plugin defines the interface for any SQL database that needs to implement

type QueueMetadataRow 

type QueueMetadataRow struct {
	QueueType persistence.QueueType
	Data      []byte
}

QueueMetadataRow represents a row in queue_metadata table

type QueueRow 

type QueueRow struct {
	QueueType      persistence.QueueType
	MessageID      int64
	MessagePayload []byte
}

QueueRow represents a row in queue table

type ReplicationTaskDLQFilter added in v0.14.0 

type ReplicationTaskDLQFilter struct {
	SourceClusterName string
	ShardID           int
}

ReplicationTaskDLQFilter contains the column names within replication_tasks_dlq table that can be used to filter results through a WHERE clause

type ReplicationTaskDLQRow 

type ReplicationTaskDLQRow struct {
	SourceClusterName string
	ShardID           int
	TaskID            int64
	Data              []byte
	DataEncoding      string
}

ReplicationTaskDLQRow represents a row in replication_tasks_dlq table

type ReplicationTasksDLQFilter 

type ReplicationTasksDLQFilter struct {
	ReplicationTasksFilter
	SourceClusterName string
}

ReplicationTasksDLQFilter contains the column names within replication_tasks_dlq table that can be used to filter results through a WHERE clause

type ReplicationTasksFilter 

type ReplicationTasksFilter struct {
	ShardID            int
	TaskID             int64
	InclusiveEndTaskID int64
	MinTaskID          int64
	MaxTaskID          int64
	PageSize           int
}

ReplicationTasksFilter contains the column names within replication_tasks table that can be used to filter results through a WHERE clause

type ReplicationTasksRow 

type ReplicationTasksRow struct {
	ShardID      int
	TaskID       int64
	Data         []byte
	DataEncoding string
}

ReplicationTasksRow represents a row in replication_tasks table

type RequestCancelInfoMapsFilter 

type RequestCancelInfoMapsFilter struct {
	ShardID      int64
	DomainID     serialization.UUID
	WorkflowID   string
	RunID        serialization.UUID
	InitiatedIDs []int64
}

RequestCancelInfoMapsFilter contains the column names within request_cancel_info_maps table that can be used to filter results through a WHERE clause

type RequestCancelInfoMapsRow 

type RequestCancelInfoMapsRow struct {
	ShardID      int64
	DomainID     serialization.UUID
	WorkflowID   string
	RunID        serialization.UUID
	InitiatedID  int64
	Data         []byte
	DataEncoding string
}

RequestCancelInfoMapsRow represents a row in request_cancel_info_maps table

type ShardsFilter 

type ShardsFilter struct {
	ShardID int64
}

ShardsFilter contains the column names within shards table that can be used to filter results through a WHERE clause

type ShardsRow 

type ShardsRow struct {
	ShardID      int64
	RangeID      int64
	Data         []byte
	DataEncoding string
}

ShardsRow represents a row in shards table

type SignalInfoMapsFilter 

type SignalInfoMapsFilter struct {
	ShardID      int64
	DomainID     serialization.UUID
	WorkflowID   string
	RunID        serialization.UUID
	InitiatedIDs []int64
}

SignalInfoMapsFilter contains the column names within signal_info_maps table that can be used to filter results through a WHERE clause

type SignalInfoMapsRow 

type SignalInfoMapsRow struct {
	ShardID      int64
	DomainID     serialization.UUID
	WorkflowID   string
	RunID        serialization.UUID
	InitiatedID  int64
	Data         []byte
	DataEncoding string
}

SignalInfoMapsRow represents a row in signal_info_maps table

type SignalsRequestedSetsFilter 

type SignalsRequestedSetsFilter struct {
	ShardID    int64
	DomainID   serialization.UUID
	WorkflowID string
	RunID      serialization.UUID
	SignalIDs  []string
}

SignalsRequestedSetsFilter contains the column names within signals_requested_sets table that can be used to filter results through a WHERE clause

type SignalsRequestedSetsRow 

type SignalsRequestedSetsRow struct {
	ShardID    int64
	DomainID   serialization.UUID
	WorkflowID string
	RunID      serialization.UUID
	SignalID   string
}

SignalsRequestedSetsRow represents a row in signals_requested_sets table

type TaskKeyRow added in v0.21.0 

type TaskKeyRow struct {
	DomainID     serialization.UUID
	TaskListName string
	TaskType     int64
	TaskID       int64
}

TaskKeyRow represents a result row giving task keys

type TaskListsFilter 

type TaskListsFilter struct {
	ShardID             int // this is DBShardID, not historyShardID (TODO: maybe rename it for clarification)
	DomainID            *serialization.UUID
	Name                *string
	TaskType            *int64
	DomainIDGreaterThan *serialization.UUID
	NameGreaterThan     *string
	TaskTypeGreaterThan *int64
	RangeID             *int64
	PageSize            *int
}

TaskListsFilter contains the column names within task_lists table that can be used to filter results through a WHERE clause

type TaskListsRow 

type TaskListsRow struct {
	ShardID      int // this is DBShardID, not historyShardID (TODO: maybe rename it for clarification)
	DomainID     serialization.UUID
	Name         string
	TaskType     int64
	RangeID      int64
	Data         []byte
	DataEncoding string
}

TaskListsRow represents a row in task_lists table

type TaskListsRowWithTTL added in v0.17.0 

type TaskListsRowWithTTL struct {
	TaskListsRow TaskListsRow
	TTL          time.Duration
}

TaskListsRowWithTTL represents a row in task_lists table with a ttl

type TasksFilter 

type TasksFilter struct {
	ShardID              int // this is DBShardID, not historyShardID (TODO: maybe rename it for clarification)
	DomainID             serialization.UUID
	TaskListName         string
	TaskType             int64
	TaskID               *int64
	MinTaskID            *int64
	MaxTaskID            *int64
	TaskIDLessThanEquals *int64
	Limit                *int
	PageSize             *int
}

TasksFilter contains the column names within tasks table that can be used to filter results through a WHERE clause

type TasksRow 

type TasksRow struct {
	ShardID      int // this is DBShardID, not historyShardID (TODO: maybe rename it for clarification)
	DomainID     serialization.UUID
	TaskType     int64
	TaskID       int64
	TaskListName string
	Data         []byte
	DataEncoding string
}

TasksRow represents a row in tasks table

type TasksRowWithTTL added in v0.17.0 

type TasksRowWithTTL struct {
	TasksRow TasksRow
	// TTL is optional because InsertIntoTasksWithTTL operates over a slice of TasksRowWithTTL.
	// Some items in the slice may have a TTL while others do not. It is the responsibility
	// of the plugin implementation to handle items with TTL set and items with TTL not set.
	TTL *time.Duration
}

TasksRowWithTTL represents a row in tasks table with a ttl

type TimerInfoMapsFilter 

type TimerInfoMapsFilter struct {
	ShardID    int64
	DomainID   serialization.UUID
	WorkflowID string
	RunID      serialization.UUID
	TimerIDs   []string
}

TimerInfoMapsFilter contains the column names within timer_info_maps table that can be used to filter results through a WHERE clause

type TimerInfoMapsRow 

type TimerInfoMapsRow struct {
	ShardID      int64
	DomainID     serialization.UUID
	WorkflowID   string
	RunID        serialization.UUID
	TimerID      string
	Data         []byte
	DataEncoding string
}

TimerInfoMapsRow represents a row in timer_info_maps table

type TimerTasksFilter 

type TimerTasksFilter struct {
	ShardID                int
	TaskID                 int64
	VisibilityTimestamp    time.Time
	MinVisibilityTimestamp time.Time
	MaxVisibilityTimestamp time.Time
	PageSize               int
}

TimerTasksFilter contains the column names within timer_tasks table that can be used to filter results through a WHERE clause

type TimerTasksRow 

type TimerTasksRow struct {
	ShardID             int
	VisibilityTimestamp time.Time
	TaskID              int64
	Data                []byte
	DataEncoding        string
}

TimerTasksRow represents a row in timer_tasks table

type TransferTasksFilter 

type TransferTasksFilter struct {
	ShardID   int
	TaskID    int64
	MinTaskID int64
	MaxTaskID int64
	PageSize  int
}

TransferTasksFilter contains the column names within transfer_tasks table that can be used to filter results through a WHERE clause

type TransferTasksRow 

type TransferTasksRow struct {
	ShardID      int
	TaskID       int64
	Data         []byte
	DataEncoding string
}

TransferTasksRow represents a row in transfer_tasks table

type Tx 

type Tx interface {
	ErrorChecker

	Commit() error
	Rollback() error
	// contains filtered or unexported methods
}

Tx defines the API for a SQL transaction

type VisibilityFilter 

type VisibilityFilter struct {
	DomainID         string
	Closed           bool
	RunID            *string
	WorkflowID       *string
	WorkflowTypeName *string
	CloseStatus      *int32
	MinStartTime     *time.Time
	MaxStartTime     *time.Time
	PageSize         *int
}

VisibilityFilter contains the column names within executions_visibility table that can be used to filter results through a WHERE clause

type VisibilityRow 

type VisibilityRow struct {
	DomainID         string
	RunID            string
	WorkflowTypeName string
	WorkflowID       string
	StartTime        time.Time
	ExecutionTime    time.Time
	CloseStatus      *int32
	CloseTime        *time.Time
	HistoryLength    *int64
	Memo             []byte
	Encoding         string
	IsCron           bool
	NumClusters      int16
	UpdateTime       time.Time
	ShardID          int16
}

VisibilityRow represents a row in executions_visibility table

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.