dbtx

Documentation

Index

• func BeginTx(ctx context.Context) (context.Context, *sql.Tx, error)
• func ContextWithExecutor(ctx context.Context, db boil.ContextExecutor) context.Context
• func ExecutorFromContext(ctx context.Context) boil.ContextExecutor
• type DBInjector
  • func NewInjector(db *sql.DB) *DBInjector
  • func (i *DBInjector) StreamServerInterceptor() grpc.StreamServerInterceptor
  • func (i *DBInjector) UnaryServerInterceptor() grpc.UnaryServerInterceptor

Functions

func BeginTx

func BeginTx(ctx context.Context) (context.Context, *sql.Tx, error)

BeginTx begins a transaction from the DB stored in ctx, or errors if either there is no DB, or a transaction is already in progress.

func ContextWithExecutor

func ContextWithExecutor(ctx context.Context, db boil.ContextExecutor) context.Context

ContextWithExecutor injects a ContextExecutor into a context.

func ExecutorFromContext

func ExecutorFromContext(ctx context.Context) boil.ContextExecutor

ExecutorFromContext retrieves the ContextExecutor from a context. If there is none set, nil is returned - boil will panic if that happens, but since this is a programming error (a failure to set a ContextExecutor on a BackgroundContext), it is a reasonable tradeoff given the frequency with which ExecutorFromContext is used.

Types

type DBInjector

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

DBInjector provides context injectors

func NewInjector

func NewInjector(db *sql.DB) *DBInjector

func (*DBInjector) StreamServerInterceptor

func (i *DBInjector) StreamServerInterceptor() grpc.StreamServerInterceptor

func (*DBInjector) UnaryServerInterceptor

func (i *DBInjector) UnaryServerInterceptor() grpc.UnaryServerInterceptor