driver

Documentation

Index

• type Generic
  • func (dwWrap *Generic) Load(ctx context.Context, query string, args []interface{}) (records []eventsource.Record, err error)
  • func (dwWrap *Generic) NewTransaction(ctx context.Context, query string, records ...eventsource.Record) (eventsource.StoreTransaction, error)
• type PGX
  • func (pgx *PGX) Load(ctx context.Context, query string, args []interface{}) (records []eventsource.Record, err error)
  • func (pgx *PGX) NewTransaction(ctx context.Context, query string, records ...eventsource.Record) (eventsource.StoreTransaction, error)
• type PgxPool

Types

type Generic

type Generic struct {
	DB *sql.DB
}

func (*Generic) Load

func (dwWrap *Generic) Load(ctx context.Context, query string, args []interface{}) (records []eventsource.Record, err error)

func (*Generic) NewTransaction

func (dwWrap *Generic) NewTransaction(ctx context.Context, query string, records ...eventsource.Record) (eventsource.StoreTransaction, error)

type PGX

type PGX struct {
	DB                  PgxPool
	NotificationChannel *string
}

func (*PGX) Load

func (pgx *PGX) Load(ctx context.Context, query string, args []interface{}) (records []eventsource.Record, err error)

func (*PGX) NewTransaction

func (pgx *PGX) NewTransaction(ctx context.Context, query string, records ...eventsource.Record) (eventsource.StoreTransaction, error)

type PgxPool

type PgxPool interface {
	Begin(context.Context) (pgx.Tx, error)
	Query(context.Context, string, ...interface{}) (pgx.Rows, error)
}