bundb

Documentation

Index

• func NewBunDBService(ctx context.Context, state *state.State) (db.DB, error)
• type DBService
  • func (dbService *DBService) DB() *bun.DB
• type PostgreSQLConn
  • func (c *PostgreSQLConn) Begin() (driver.Tx, error)
  • func (c *PostgreSQLConn) BeginTx(ctx context.Context, opts driver.TxOptions) (driver.Tx, error)
  • func (c *PostgreSQLConn) Close() error
  • func (c *PostgreSQLConn) Exec(query string, args []driver.Value) (driver.Result, error)
  • func (c *PostgreSQLConn) ExecContext(ctx context.Context, query string, args []driver.NamedValue) (driver.Result, error)
  • func (c *PostgreSQLConn) Prepare(query string) (driver.Stmt, error)
  • func (c *PostgreSQLConn) PrepareContext(ctx context.Context, query string) (driver.Stmt, error)
  • func (c *PostgreSQLConn) Query(query string, args []driver.Value) (driver.Rows, error)
  • func (c *PostgreSQLConn) QueryContext(ctx context.Context, query string, args []driver.NamedValue) (driver.Rows, error)
• type PostgreSQLDriver
  • func (d *PostgreSQLDriver) Open(name string) (driver.Conn, error)
• type PostgreSQLStmt
  • func (stmt *PostgreSQLStmt) Exec(args []driver.Value) (driver.Result, error)
  • func (stmt *PostgreSQLStmt) ExecContext(ctx context.Context, args []driver.NamedValue) (driver.Result, error)
  • func (stmt *PostgreSQLStmt) Query(args []driver.Value) (driver.Rows, error)
  • func (stmt *PostgreSQLStmt) QueryContext(ctx context.Context, args []driver.NamedValue) (driver.Rows, error)
• type PostgreSQLTx
  • func (tx *PostgreSQLTx) Commit() error
  • func (tx *PostgreSQLTx) Rollback() error
• type SQLiteConn
  • func (c *SQLiteConn) Begin() (driver.Tx, error)
  • func (c *SQLiteConn) BeginTx(ctx context.Context, opts driver.TxOptions) (tx driver.Tx, err error)
  • func (c *SQLiteConn) Close() error
  • func (c *SQLiteConn) Exec(query string, args []driver.Value) (driver.Result, error)
  • func (c *SQLiteConn) ExecContext(ctx context.Context, query string, args []driver.NamedValue) (result driver.Result, err error)
  • func (c *SQLiteConn) Prepare(query string) (driver.Stmt, error)
  • func (c *SQLiteConn) PrepareContext(ctx context.Context, query string) (st driver.Stmt, err error)
  • func (c *SQLiteConn) Query(query string, args []driver.Value) (driver.Rows, error)
  • func (c *SQLiteConn) QueryContext(ctx context.Context, query string, args []driver.NamedValue) (rows driver.Rows, err error)
• type SQLiteDriver
  • func (d *SQLiteDriver) Open(name string) (driver.Conn, error)
• type SQLiteStmt
  • func (stmt *SQLiteStmt) Exec(args []driver.Value) (driver.Result, error)
  • func (stmt *SQLiteStmt) ExecContext(ctx context.Context, args []driver.NamedValue) (res driver.Result, err error)
  • func (stmt *SQLiteStmt) Query(args []driver.Value) (driver.Rows, error)
  • func (stmt *SQLiteStmt) QueryContext(ctx context.Context, args []driver.NamedValue) (rows driver.Rows, err error)
• type SQLiteTx
  • func (tx *SQLiteTx) Commit() (err error)
  • func (tx *SQLiteTx) Rollback() (err error)

Functions

func NewBunDBService

func NewBunDBService(ctx context.Context, state *state.State) (db.DB, error)

NewBunDBService returns a bunDB derived from the provided config, which implements the go-fed DB interface. Under the hood, it uses https://github.com/uptrace/bun to create and maintain a database connection.

Types

type DBService

type DBService struct {
	db.Account
	db.Admin
	db.Application
	db.Basic
	db.Domain
	db.Emoji
	db.HeaderFilter
	db.Instance
	db.List
	db.Marker
	db.Media
	db.Mention
	db.Notification
	db.Poll
	db.Relationship
	db.Report
	db.Rule
	db.Search
	db.Session
	db.Status
	db.StatusBookmark
	db.StatusFave
	db.Tag
	db.Thread
	db.Timeline
	db.User
	db.Tombstone
	// contains filtered or unexported fields
}

DBService satisfies the DB interface

func (*DBService) DB

func (dbService *DBService) DB() *bun.DB

GetDB returns the underlying database connection pool. Should only be used in testing + exceptional circumstance.

type PostgreSQLConn

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

func (*PostgreSQLConn) Begin

func (c *PostgreSQLConn) Begin() (driver.Tx, error)

func (*PostgreSQLConn) BeginTx

func (c *PostgreSQLConn) BeginTx(ctx context.Context, opts driver.TxOptions) (driver.Tx, error)

func (*PostgreSQLConn) Close

func (c *PostgreSQLConn) Close() error

func (*PostgreSQLConn) Exec

func (c *PostgreSQLConn) Exec(query string, args []driver.Value) (driver.Result, error)

func (*PostgreSQLConn) ExecContext

func (c *PostgreSQLConn) ExecContext(ctx context.Context, query string, args []driver.NamedValue) (driver.Result, error)

func (*PostgreSQLConn) Prepare

func (c *PostgreSQLConn) Prepare(query string) (driver.Stmt, error)

func (*PostgreSQLConn) PrepareContext

func (c *PostgreSQLConn) PrepareContext(ctx context.Context, query string) (driver.Stmt, error)

func (*PostgreSQLConn) Query

func (c *PostgreSQLConn) Query(query string, args []driver.Value) (driver.Rows, error)

func (*PostgreSQLConn) QueryContext

func (c *PostgreSQLConn) QueryContext(ctx context.Context, query string, args []driver.NamedValue) (driver.Rows, error)

type PostgreSQLDriver

type PostgreSQLDriver struct{}

PostgreSQLDriver is our own wrapper around the pgx/stdlib.Driver{} type in order to wrap further SQL driver types with our own err processing.

func (*PostgreSQLDriver) Open

func (d *PostgreSQLDriver) Open(name string) (driver.Conn, error)

type PostgreSQLStmt

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

func (*PostgreSQLStmt) Exec

func (stmt *PostgreSQLStmt) Exec(args []driver.Value) (driver.Result, error)

func (*PostgreSQLStmt) ExecContext

func (stmt *PostgreSQLStmt) ExecContext(ctx context.Context, args []driver.NamedValue) (driver.Result, error)

func (*PostgreSQLStmt) Query

func (stmt *PostgreSQLStmt) Query(args []driver.Value) (driver.Rows, error)

func (*PostgreSQLStmt) QueryContext

func (stmt *PostgreSQLStmt) QueryContext(ctx context.Context, args []driver.NamedValue) (driver.Rows, error)

type PostgreSQLTx

type PostgreSQLTx struct{ driver.Tx }

func (*PostgreSQLTx) Commit

func (tx *PostgreSQLTx) Commit() error

func (*PostgreSQLTx) Rollback

func (tx *PostgreSQLTx) Rollback() error

type SQLiteConn

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

func (*SQLiteConn) Begin

func (c *SQLiteConn) Begin() (driver.Tx, error)

func (*SQLiteConn) BeginTx

func (c *SQLiteConn) BeginTx(ctx context.Context, opts driver.TxOptions) (tx driver.Tx, err error)

func (*SQLiteConn) Close

func (c *SQLiteConn) Close() error

func (*SQLiteConn) Exec

func (c *SQLiteConn) Exec(query string, args []driver.Value) (driver.Result, error)

func (*SQLiteConn) ExecContext

func (c *SQLiteConn) ExecContext(ctx context.Context, query string, args []driver.NamedValue) (result driver.Result, err error)

func (*SQLiteConn) Prepare

func (c *SQLiteConn) Prepare(query string) (driver.Stmt, error)

func (*SQLiteConn) PrepareContext

func (c *SQLiteConn) PrepareContext(ctx context.Context, query string) (st driver.Stmt, err error)

func (*SQLiteConn) Query

func (c *SQLiteConn) Query(query string, args []driver.Value) (driver.Rows, error)

func (*SQLiteConn) QueryContext

func (c *SQLiteConn) QueryContext(ctx context.Context, query string, args []driver.NamedValue) (rows driver.Rows, err error)

type SQLiteDriver

type SQLiteDriver struct{}

SQLiteDriver is our own wrapper around the sqlite.Driver{} type in order to wrap further SQL driver types with our own functionality, e.g. hooks, retries and err processing.

func (*SQLiteDriver) Open

func (d *SQLiteDriver) Open(name string) (driver.Conn, error)

type SQLiteStmt

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

func (*SQLiteStmt) Exec

func (stmt *SQLiteStmt) Exec(args []driver.Value) (driver.Result, error)

func (*SQLiteStmt) ExecContext

func (stmt *SQLiteStmt) ExecContext(ctx context.Context, args []driver.NamedValue) (res driver.Result, err error)

func (*SQLiteStmt) Query

func (stmt *SQLiteStmt) Query(args []driver.Value) (driver.Rows, error)

func (*SQLiteStmt) QueryContext

func (stmt *SQLiteStmt) QueryContext(ctx context.Context, args []driver.NamedValue) (rows driver.Rows, err error)

type SQLiteTx

type SQLiteTx struct {
	context.Context
	driver.Tx
}

func (*SQLiteTx) Commit

func (tx *SQLiteTx) Commit() (err error)

func (*SQLiteTx) Rollback

func (tx *SQLiteTx) Rollback() (err error)