sqlite

Documentation

Index

• type DB
  • func New(ctx context.Context, l log.CtxLogger, path, table string) (*DB, error)
  • func (d *DB) Close() error
  • func (d *DB) Get(ctx context.Context, key string) ([]byte, error)
  • func (d *DB) GetKeys(ctx context.Context, prefix string) ([]string, error)
  • func (d *DB) NewTransaction(ctx context.Context, update bool) (database.Transaction, context.Context, error)
  • func (d *DB) Ping(ctx context.Context) error
  • func (d *DB) Set(ctx context.Context, key string, v []byte) error
• type Transaction
  • func (t *Transaction) Commit() error
  • func (t *Transaction) Discard()

Types

type DB

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

func New

func New(ctx context.Context, l log.CtxLogger, path, table string) (*DB, error)

New initializes the database structures needed by DB.

func (*DB) Close

func (d *DB) Close() error

Close closes all open connections.

func (*DB) Get

func (d *DB) Get(ctx context.Context, key string) ([]byte, error)

func (*DB) GetKeys

func (d *DB) GetKeys(ctx context.Context, prefix string) ([]string, error)

func (*DB) NewTransaction

func (d *DB) NewTransaction(ctx context.Context, update bool) (database.Transaction, context.Context, error)

NewTransaction starts a new transaction. The `update` parameter controls the access mode ("read only" or "read write"). It returns the transaction as well as a context that contains the transaction. Passing the context in future calls to *DB will execute that action in that transaction.

func (*DB) Ping

func (d *DB) Ping(ctx context.Context) error

func (*DB) Set

func (d *DB) Set(ctx context.Context, key string, v []byte) error

Set will store the value under the key. If value is `nil` we consider that a delete.

type Transaction

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

func (*Transaction) Commit

func (t *Transaction) Commit() error

func (*Transaction) Discard

func (t *Transaction) Discard()