sqlite

package
v1.3.0 Latest Latest
Warning

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

 Go to latest Published: Apr 29, 2025 License: MIT Imports: 24 Imported by: 1

Documentation

Index

Constants

View Source 
const (
	PluginName = "sqlite"
)

Variables

This section is empty.

Functions

func GetTestClusterOption added in v1.3.0 

func GetTestClusterOption() *pt.TestBaseOptions

GetTestClusterOption returns a test cluster option for sqlite plugin It uses a temporary directory for the database name

Types

type DB 

type DB struct {
	*mysql.DB
	// contains filtered or unexported fields
}

DB contains methods for managing objects in a sqlite database It inherits methods from the mysql.DB to reuse the implementation of the methods sqlplugin.ErrorChecker is customized for sqlite

func NewDB 

func NewDB(xdbs []*sqlx.DB, tx *sqlx.Tx, dbShardID int, numDBShards int, dataConverter mysql.DataConverter) (*DB, error)

NewDB returns an instance of DB, which contains a new created mysql.DB with sqlite specific methods

func (*DB) BeginTx added in v1.3.0 

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

BeginTx starts a new transaction and returns a new Tx

func (*DB) CreateDatabase added in v1.2.18 

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

CreateDatabase is not supported by sqlite each sqlite file is a database

func (*DB) DeleteFromHistoryNode added in v1.3.0 

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

DeleteFromHistoryNode deletes one or more rows from history_node table

func (*DB) DeleteFromTasks added in v1.3.0 

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

DeleteFromTasks deletes one or more rows from tasks table

func (*DB) DropDatabase added in v1.2.18 

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

DropDatabase is not supported by sqlite each sqlite file is a database

func (*DB) GetAckLevels added in v1.3.0 

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

GetAckLevels returns ack levels for pulling clusters

func (*DB) GetLastEnqueuedMessageIDForUpdate added in v1.3.0 

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

GetLastEnqueuedMessageIDForUpdate returns the last enqueued message ID

func (*DB) InsertIntoSignalsRequestedSets added in v1.3.0 

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

InsertIntoSignalsRequestedSets inserts one or more rows into signals_requested_sets table

func (*DB) InsertIntoVisibility added in v1.3.0 

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

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

func (*DB) IsDupEntryError 

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

IsDupEntryError verify if the error is a duplicate entry error

func (*DB) IsNotFoundError 

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

IsNotFoundError verify if the error is a not found error

func (*DB) IsThrottlingError 

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

IsThrottlingError verify if the error is a throttling error

func (*DB) IsTimeoutError 

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

IsTimeoutError verify if the error is a timeout error

func (*DB) LockCurrentExecutions added in v1.3.0 

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

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

func (*DB) LockCurrentExecutionsJoinExecutions added in v1.3.0 

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

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

func (*DB) LockDomainMetadata added in v1.3.0 

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

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

func (*DB) LockTaskLists added in v1.3.0 

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

LockTaskLists locks a row in task_lists table

func (*DB) PluginName 

func (mdb *DB) PluginName() string

PluginName returns the name of the plugin

func (*DB) RangeDeleteFromReplicationTasks added in v1.3.0 

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

RangeDeleteFromReplicationTasks deletes multi rows from replication_tasks table

func (*DB) RangeDeleteFromTimerTasks added in v1.3.0 

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

RangeDeleteFromTimerTasks deletes multi rows from timer_tasks table

func (*DB) RangeDeleteFromTransferTasks added in v1.3.0 

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

RangeDeleteFromTransferTasks deletes multi rows from transfer_tasks table

func (*DB) ReadLockExecutions added in v1.3.0 

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

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

func (*DB) ReadLockShards added in v1.3.0 

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

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

func (*DB) WriteLockExecutions added in v1.3.0 

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

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

func (*DB) WriteLockShards added in v1.3.0 

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

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

Source Files

View all Source files

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.