datastore

Documentation

Index

• func NewPostgresDatastore(ctx context.Context, logger logger.Logger, user, password, host string, ...) (*PostgresDatastore, CloseFunc)
• type CloseFunc
• type Datastore
• type PostgresDatastore
  • func (p *PostgresDatastore) BeginTx(ctx context.Context, opts *sql.TxOptions) (*sql.Tx, error)
  • func (p *PostgresDatastore) Exec(query string, args ...any) (sql.Result, error)
  • func (p *PostgresDatastore) ExecContext(ctx context.Context, query string, args ...any) (sql.Result, error)
  • func (p *PostgresDatastore) Prepare(query string) (*sql.Stmt, error)
  • func (p *PostgresDatastore) PrepareContext(ctx context.Context, query string) (*sql.Stmt, error)
  • func (p *PostgresDatastore) Query(query string, args ...any) (*sql.Rows, error)
  • func (p *PostgresDatastore) QueryContext(ctx context.Context, query string, args ...any) (*sql.Rows, error)
  • func (p *PostgresDatastore) QueryRow(query string, args ...any) *sql.Row
  • func (p *PostgresDatastore) QueryRowContext(ctx context.Context, query string, args ...any) *sql.Row

Functions

func NewPostgresDatastore

func NewPostgresDatastore(
	ctx context.Context,
	logger logger.Logger,
	user, password, host string,
	port int,
	name, sslMode string,
) (*PostgresDatastore, CloseFunc)

Types

type CloseFunc

type CloseFunc func() error

type Datastore

type Datastore interface {
	BeginTx(ctx context.Context, opts *sql.TxOptions) (*sql.Tx, error)
	Exec(query string, args ...any) (sql.Result, error)
	ExecContext(ctx context.Context, query string, args ...any) (sql.Result, error)
	Prepare(query string) (*sql.Stmt, error)
	PrepareContext(ctx context.Context, query string) (*sql.Stmt, error)
	Query(query string, args ...any) (*sql.Rows, error)
	QueryContext(ctx context.Context, query string, args ...any) (*sql.Rows, error)
	QueryRow(query string, args ...any) *sql.Row
	QueryRowContext(ctx context.Context, query string, args ...any) *sql.Row
}

type PostgresDatastore

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

func (*PostgresDatastore) BeginTx

func (p *PostgresDatastore) BeginTx(ctx context.Context, opts *sql.TxOptions) (*sql.Tx, error)

func (*PostgresDatastore) Exec

func (p *PostgresDatastore) Exec(query string, args ...any) (sql.Result, error)

func (*PostgresDatastore) ExecContext

func (p *PostgresDatastore) ExecContext(ctx context.Context, query string, args ...any) (sql.Result, error)

func (*PostgresDatastore) Prepare

func (p *PostgresDatastore) Prepare(query string) (*sql.Stmt, error)

func (*PostgresDatastore) PrepareContext

func (p *PostgresDatastore) PrepareContext(ctx context.Context, query string) (*sql.Stmt, error)

func (*PostgresDatastore) Query

func (p *PostgresDatastore) Query(query string, args ...any) (*sql.Rows, error)

func (*PostgresDatastore) QueryContext

func (p *PostgresDatastore) QueryContext(ctx context.Context, query string, args ...any) (*sql.Rows, error)

func (*PostgresDatastore) QueryRow

func (p *PostgresDatastore) QueryRow(query string, args ...any) *sql.Row

func (*PostgresDatastore) QueryRowContext

func (p *PostgresDatastore) QueryRowContext(ctx context.Context, query string, args ...any) *sql.Row