sql

Documentation

Index

• type Actuator
  • func NewActuator(client Client) Actuator
  • func (a Actuator) State(ctx context.Context) (actuator.State, error)
• type Client
• type Config
• type ConfigTransactionFactory
• type LoggerClient
  • func NewLoggerClient(logger logging.Logger, db Client) LoggerClient
  • func (l LoggerClient) BeginTx(ctx context.Context, opts *sql.TxOptions) (*sql.Tx, error)
  • func (l LoggerClient) Driver() driver.Driver
  • func (l LoggerClient) ExecContext(ctx context.Context, query string, args ...interface{}) (sql.Result, error)
  • func (l LoggerClient) PingContext(ctx context.Context) error
  • func (l LoggerClient) PrepareContext(ctx context.Context, query string) (*sql.Stmt, error)
  • func (l LoggerClient) QueryContext(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)
  • func (l LoggerClient) QueryRowContext(ctx context.Context, query string, args ...interface{}) *sql.Row
• type Transaction
  • func (t Transaction) Commit(_ context.Context) error
  • func (t Transaction) Rollback(_ context.Context) error
• type TransactionContextFactory
  • func NewTransactionContextFactory(client Client, cfg ConfigTransactionFactory) TransactionContextFactory
  • func (t TransactionContextFactory) NewContext(parent context.Context) (context.Context, error)
• type TransactionalClient
  • func NewTransactionalClient(factory TransactionContextFactory, logger logging.Logger, next Client) TransactionalClient
  • func (t TransactionalClient) BeginTx(ctx context.Context, opts *sql.TxOptions) (*sql.Tx, error)
  • func (t TransactionalClient) Driver() driver.Driver
  • func (t TransactionalClient) ExecContext(ctx context.Context, query string, args ...interface{}) (sql.Result, error)
  • func (t TransactionalClient) PingContext(ctx context.Context) error
  • func (t TransactionalClient) PrepareContext(ctx context.Context, query string) (*sql.Stmt, error)
  • func (t TransactionalClient) QueryContext(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)
  • func (t TransactionalClient) QueryRowContext(ctx context.Context, query string, args ...interface{}) *sql.Row

Types

type Actuator

type Actuator struct {
	Client Client
}

func NewActuator

func NewActuator(client Client) Actuator

func (Actuator) State

func (a Actuator) State(ctx context.Context) (actuator.State, error)

type Client

type Client interface {
	PingContext(ctx context.Context) error
	ExecContext(ctx context.Context, query string, args ...interface{}) (sql.Result, error)
	PrepareContext(ctx context.Context, query string) (*sql.Stmt, error)
	QueryContext(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)
	QueryRowContext(ctx context.Context, query string, args ...interface{}) *sql.Row
	BeginTx(ctx context.Context, opts *sql.TxOptions) (*sql.Tx, error)
	Driver() driver.Driver
}

type Config

type Config struct {
	ConnectionString    string `env:"SQL_CONNECTION_STRING,unset"`
	IsLoggingStatements bool   `env:"SQL_ENABLE_LOGGING" envDefault:"false"`
}

type ConfigTransactionFactory

type ConfigTransactionFactory struct {
	IsolationLevel int  `env:"SQL_ISOLATION_LEVEL" envDefault:"0"`
	ReadOnly       bool `env:"SQL_READ_ONLY" envDefault:"false"`
}

type LoggerClient

type LoggerClient struct {
	Logger logging.Logger
	Next   Client
}

func NewLoggerClient

func NewLoggerClient(logger logging.Logger, db Client) LoggerClient

func (LoggerClient) BeginTx

func (l LoggerClient) BeginTx(ctx context.Context, opts *sql.TxOptions) (*sql.Tx, error)

func (LoggerClient) Driver

func (l LoggerClient) Driver() driver.Driver

func (LoggerClient) ExecContext

func (l LoggerClient) ExecContext(ctx context.Context, query string, args ...interface{}) (sql.Result, error)

func (LoggerClient) PingContext

func (l LoggerClient) PingContext(ctx context.Context) error

func (LoggerClient) PrepareContext

func (l LoggerClient) PrepareContext(ctx context.Context, query string) (*sql.Stmt, error)

func (LoggerClient) QueryContext

func (l LoggerClient) QueryContext(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)

func (LoggerClient) QueryRowContext

func (l LoggerClient) QueryRowContext(ctx context.Context, query string, args ...interface{}) *sql.Row

type Transaction

type Transaction struct {
	Tx *sql.Tx
}

func (Transaction) Commit

func (t Transaction) Commit(_ context.Context) error

func (Transaction) Rollback

func (t Transaction) Rollback(_ context.Context) error

type TransactionContextFactory

type TransactionContextFactory struct {
	Client Client
	Config ConfigTransactionFactory
}

func NewTransactionContextFactory

func NewTransactionContextFactory(client Client, cfg ConfigTransactionFactory) TransactionContextFactory

func (TransactionContextFactory) NewContext

func (t TransactionContextFactory) NewContext(parent context.Context) (context.Context, error)

type TransactionalClient

type TransactionalClient struct {
	TransactionContextFactory TransactionContextFactory
	Logger                    logging.Logger
	Next                      Client
}

func NewTransactionalClient

func NewTransactionalClient(factory TransactionContextFactory, logger logging.Logger, next Client) TransactionalClient

func (TransactionalClient) BeginTx

func (t TransactionalClient) BeginTx(ctx context.Context, opts *sql.TxOptions) (*sql.Tx, error)

func (TransactionalClient) Driver

func (t TransactionalClient) Driver() driver.Driver

func (TransactionalClient) ExecContext

func (t TransactionalClient) ExecContext(ctx context.Context, query string, args ...interface{}) (sql.Result, error)

func (TransactionalClient) PingContext

func (t TransactionalClient) PingContext(ctx context.Context) error

func (TransactionalClient) PrepareContext

func (t TransactionalClient) PrepareContext(ctx context.Context, query string) (*sql.Stmt, error)

func (TransactionalClient) QueryContext

func (t TransactionalClient) QueryContext(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)

func (TransactionalClient) QueryRowContext

func (t TransactionalClient) QueryRowContext(ctx context.Context, query string, args ...interface{}) *sql.Row