mysql

Documentation

Index

• Variables
• type ConnectionOptions
• type MySQL
  • func New(options Options) (*MySQL, error)
  • func (db *MySQL) Close() error
  • func (db *MySQL) Connect() error
  • func (db *MySQL) Connection() *sqlx.DB
  • func (db *MySQL) EventTx(ctx context.Context, etxFn db.EventTxFn) (eventId *events.EventID, err error)
  • func (db *MySQL) EventsTx(ctx context.Context, etxFn db.EventsTxFn) (eventIds []events.EventID, err error)
  • func (db *MySQL) Migrate(ctx context.Context, options *db.MigrationOptions) (*db.MigrationResult, error)
  • func (db *MySQL) Tx(ctx context.Context, txFn db.TxFn) (err error)
• type Options

Variables

var (
	ErrNoDSN      = errors.New("no dsn provided")
	ErrNoMigrator = errors.New("no migrator provided")
)

var DefaultConnectionOptions = ConnectionOptions{
	MaxOpenCons:     100,
	MaxIdleCons:     10,
	ConnMaxLifetime: 1 * time.Minute,
	ConnMaxIdleTime: 30 * time.Second,
}

var (
	ErrNoOutboxConfigured = errors.New("no event outbox configured")
)

Types

type ConnectionOptions

type ConnectionOptions struct {
	MaxOpenCons     int
	MaxIdleCons     int
	ConnMaxLifetime time.Duration
	ConnMaxIdleTime time.Duration
}

type MySQL

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

func New

func New(options Options) (*MySQL, error)

func (*MySQL) Close

func (db *MySQL) Close() error

func (*MySQL) Connect

func (db *MySQL) Connect() error

func (*MySQL) Connection

func (db *MySQL) Connection() *sqlx.DB

func (*MySQL) EventTx

func (db *MySQL) EventTx(ctx context.Context, etxFn db.EventTxFn) (eventId *events.EventID, err error)

EventTx is a convenience method for emitting a single event in a single transaction.

func (*MySQL) EventsTx

func (db *MySQL) EventsTx(ctx context.Context, etxFn db.EventsTxFn) (eventIds []events.EventID, err error)

EventsTx is a convenience method for emitting multiple events in a single transaction.

func (*MySQL) Migrate

func (db *MySQL) Migrate(ctx context.Context, options *db.MigrationOptions) (*db.MigrationResult, error)

func (*MySQL) Tx

func (db *MySQL) Tx(ctx context.Context, txFn db.TxFn) (err error)

type Options

type Options struct {
	DSN               string
	OutboxOptions     *outbox.Options
	Logger            *zap.Logger
	Migrator          db.Migrator
	ConnectionOptions *ConnectionOptions
}