sqlite

Documentation

Index

• Constants
• func New(config *Config) (aio.Subsystem, error)
• type Config
• type SqliteStore
  • func (s *SqliteStore) NewWorker(int) aio.Worker
  • func (s *SqliteStore) Reset() error
  • func (s *SqliteStore) Start() error
  • func (s *SqliteStore) Stop() error
  • func (s *SqliteStore) String() string
• type SqliteStoreWorker
  • func (w *SqliteStoreWorker) Execute(transactions []*t_aio.Transaction) ([][]*t_aio.Result, error)
  • func (w *SqliteStoreWorker) Process(sqes []*bus.SQE[t_aio.Submission, t_aio.Completion]) []*bus.CQE[t_aio.Submission, t_aio.Completion]

Constants

const (
	CREATE_TABLE_STATEMENT = `` /* 3071-byte string literal not displayed */

	PROMISE_SELECT_STATEMENT = `` /* 206-byte string literal not displayed */

	PROMISE_SEARCH_STATEMENT = `` /* 313-byte string literal not displayed */

	PROMISE_INSERT_STATEMENT = `` /* 181-byte string literal not displayed */

	PROMISE_UPDATE_STATEMENT = `` /* 153-byte string literal not displayed */

	PROMISE_UPDATE_TIMEOUT_STATEMENT = `` /* 247-byte string literal not displayed */

	SCHEDULE_SELECT_STATEMENT = `` /* 217-byte string literal not displayed */

	SCHEDULE_SELECT_ALL_STATEMENT = `` /* 235-byte string literal not displayed */

	SCHEDULE_SEARCH_STATEMENT = `` /* 204-byte string literal not displayed */

	SCHEDULE_INSERT_STATEMENT = `` /* 260-byte string literal not displayed */

	SCHEDULE_UPDATE_STATEMENT = `
	UPDATE
		schedules
	SET
		last_run_time = next_run_time, next_run_time = ?
	WHERE
		id = ? AND next_run_time = ?`

	SCHEDULE_DELETE_STATEMENT = `
	DELETE FROM schedules WHERE id = ?`

	TASK_INSERT_STATEMENT = `` /* 203-byte string literal not displayed */

	TASK_UPDATE_STATEMENT = `` /* 128-byte string literal not displayed */

	TASK_SELECT_STATEMENT = `` /* 155-byte string literal not displayed */

	TASK_SELECT_ALL_STATEMENT = `` /* 276-byte string literal not displayed */

	LOCK_READ_STATEMENT = `
	SELECT 
		resource_id, process_id, execution_id, expiry_in_milliseconds, timeout
	FROM
		locks
	WHERE
		resource_id = ?`

	LOCK_ACQUIRE_STATEMENT = `` /* 333-byte string literal not displayed */

	LOCK_HEARTBEAT_STATEMENT = `
	UPDATE
		locks
	SET
		timeout = ? + expiry_in_milliseconds
	WHERE
		process_id = ?`

	LOCK_RELEASE_STATEMENT = `
	DELETE FROM locks WHERE resource_id = ? AND execution_id = ?`

	LOCK_TIMEOUT_STATEMENT = `
	DELETE FROM locks WHERE timeout <= ?`

	TIMEOUT_SELECT_STATEMENT = `
	SELECT
		id, time
	FROM
		timeouts
	ORDER BY
		time ASC, id
	LIMIT ?`

	TIMEOUT_INSERT_STATEMENT = `
	INSERT INTO timeouts
		(id, time)
	VALUES
		(?, ?)
	ON CONFLICT(id) DO NOTHING`

	TIMEOUT_DELETE_STATEMENT = `
	DELETE FROM timeouts WHERE id = ?`

	SUBSCRIPTION_SELECT_STATEMENT = `
	SELECT
		id, promise_id, url, retry_policy, created_on
	FROM
		subscriptions
	WHERE
		id = ? AND promise_id = ?`

	SUBSCRIPTION_SELECT_ALL_STATEMENT = `` /* 180-byte string literal not displayed */

	SUBSCRIPTION_INSERT_STATEMENT = `` /* 143-byte string literal not displayed */

	SUBSCRIPTION_DELETE_STATEMENT = `
	DELETE FROM subscriptions WHERE id = ? AND promise_id = ?`

	SUBSCRIPTION_DELETE_ALL_STATEMENT = `
	DELETE FROM subscriptions WHERE promise_id = ?`

	SUBSCRIPTION_DELETE_ALL_TIMEOUT_STATEMENT = `
	DELETE FROM
		subscriptions
	WHERE
		promise_id IN (SELECT id FROM promises WHERE state = 1 AND timeout <= ?)`

	NOTIFICATION_SELECT_STATEMENT = `` /* 127-byte string literal not displayed */

	NOTIFICATION_INSERT_STATEMENT = `` /* 216-byte string literal not displayed */

	NOTIFICATION_INSERT_TIMEOUT_STATEMENT = `` /* 274-byte string literal not displayed */

	NOTIFICATION_UPDATE_STATEMENT = `
	UPDATE
		notifications
	SET
		time = ?, attempt = ?
	WHERE
		id = ? AND promise_id = ?`

	NOTIFICATION_DELETE_STATEMENT = `
	DELETE FROM notifications WHERE id = ? AND promise_id = ?`
)

Functions

func New

func New(config *Config) (aio.Subsystem, error)

Types

type Config

type Config struct {
	Path      string
	TxTimeout time.Duration
	Reset     bool
}

type SqliteStore

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

func (*SqliteStore) NewWorker

func (s *SqliteStore) NewWorker(int) aio.Worker

func (*SqliteStore) Reset

func (s *SqliteStore) Reset() error

func (*SqliteStore) Start

func (s *SqliteStore) Start() error

func (*SqliteStore) Stop

func (s *SqliteStore) Stop() error

func (*SqliteStore) String

func (s *SqliteStore) String() string

type SqliteStoreWorker

type SqliteStoreWorker struct {
	*SqliteStore
}

func (*SqliteStoreWorker) Execute

func (w *SqliteStoreWorker) Execute(transactions []*t_aio.Transaction) ([][]*t_aio.Result, error)

func (*SqliteStoreWorker) Process

func (w *SqliteStoreWorker) Process(sqes []*bus.SQE[t_aio.Submission, t_aio.Completion]) []*bus.CQE[t_aio.Submission, t_aio.Completion]