postgres

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

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

type Execable interface {
	ExecEx(ctx context.Context, sql string, options *pgx.QueryExOptions, arguments ...interface{}) (commandTag pgx.CommandTag, err error)
}

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

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

type Queryable interface {
	QueryEx(ctx context.Context, sql string, options *pgx.QueryExOptions, args ...interface{}) (rows *pgx.Rows, err error)
	QueryRowEx(ctx context.Context, sql string, options *pgx.QueryExOptions, args ...interface{}) *pgx.Row
}

type ReadableQueryResult interface {
	Scan(dest ...interface{}) (err error)
}

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

type Transactionable interface {
	BeginEx(ctx context.Context, txOptions *pgx.TxOptions) (*pgx.Tx, error)
}