swodb

Documentation

Index

• type ChangeLog
• type ConnectionInfoRow
• type DBTX
• type DatabaseInfoRow
• type EnumSwitchoverState
  • func (e *EnumSwitchoverState) Scan(src interface{}) error
• type ForeignKeyRefsRow
• type NullEnumSwitchoverState
  • func (ns *NullEnumSwitchoverState) Scan(value interface{}) error
  • func (ns NullEnumSwitchoverState) Value() (driver.Value, error)
• type PgStatActivity
• type Queries
  • func New(db DBTX) *Queries
  • func (q *Queries) ActiveTxCount(ctx context.Context, xactStart time.Time) (int64, error)
  • func (q *Queries) ConnectionInfo(ctx context.Context) ([]ConnectionInfoRow, error)
  • func (q *Queries) DatabaseInfo(ctx context.Context) (DatabaseInfoRow, error)
  • func (q *Queries) DisableChangeLogTriggers(ctx context.Context) error
  • func (q *Queries) EnableChangeLogTriggers(ctx context.Context) error
  • func (q *Queries) ForeignKeyRefs(ctx context.Context) ([]ForeignKeyRefsRow, error)
  • func (q *Queries) LastLogID(ctx context.Context) (int64, error)
  • func (q *Queries) LogEvents(ctx context.Context, id int64) ([]SwitchoverLog, error)
  • func (q *Queries) Now(ctx context.Context) (time.Time, error)
  • func (q *Queries) SequenceNames(ctx context.Context) ([]string, error)
  • func (q *Queries) TableColumns(ctx context.Context) ([]TableColumnsRow, error)
  • func (q *Queries) WithTx(tx pgx.Tx) *Queries
• type SwitchoverLog
• type SwitchoverState
• type TableColumnsRow

Types

type ChangeLog

type ChangeLog struct {
	ID        int64
	TableName string
	RowID     string
}

type ConnectionInfoRow

type ConnectionInfoRow struct {
	Name  sql.NullString
	Count int64
}

type DBTX

type DBTX interface {
	Exec(context.Context, string, ...interface{}) (pgconn.CommandTag, error)
	Query(context.Context, string, ...interface{}) (pgx.Rows, error)
	QueryRow(context.Context, string, ...interface{}) pgx.Row
}

type DatabaseInfoRow

type DatabaseInfoRow struct {
	ID      uuid.UUID
	Version string
}

type EnumSwitchoverState

type EnumSwitchoverState string

const (
	EnumSwitchoverStateIdle       EnumSwitchoverState = "idle"
	EnumSwitchoverStateInProgress EnumSwitchoverState = "in_progress"
	EnumSwitchoverStateUseNextDb  EnumSwitchoverState = "use_next_db"
)

func (*EnumSwitchoverState) Scan

func (e *EnumSwitchoverState) Scan(src interface{}) error

type ForeignKeyRefsRow

type ForeignKeyRefsRow struct {
	SrcRelname string
	DstRelname string
}

type NullEnumSwitchoverState

type NullEnumSwitchoverState struct {
	EnumSwitchoverState EnumSwitchoverState
	Valid               bool // Valid is true if EnumSwitchoverState is not NULL
}

func (*NullEnumSwitchoverState) Scan

func (ns *NullEnumSwitchoverState) Scan(value interface{}) error

Scan implements the Scanner interface.

func (NullEnumSwitchoverState) Value

func (ns NullEnumSwitchoverState) Value() (driver.Value, error)

Value implements the driver Valuer interface.

type PgStatActivity

type PgStatActivity struct {
	State           sql.NullString
	XactStart       time.Time
	ApplicationName sql.NullString
}

type Queries

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

func New

func New(db DBTX) *Queries

func (*Queries) ActiveTxCount

func (q *Queries) ActiveTxCount(ctx context.Context, xactStart time.Time) (int64, error)

func (*Queries) ConnectionInfo

func (q *Queries) ConnectionInfo(ctx context.Context) ([]ConnectionInfoRow, error)

func (*Queries) DatabaseInfo

func (q *Queries) DatabaseInfo(ctx context.Context) (DatabaseInfoRow, error)

func (*Queries) DisableChangeLogTriggers

func (q *Queries) DisableChangeLogTriggers(ctx context.Context) error

func (*Queries) EnableChangeLogTriggers

func (q *Queries) EnableChangeLogTriggers(ctx context.Context) error

func (*Queries) ForeignKeyRefs

func (q *Queries) ForeignKeyRefs(ctx context.Context) ([]ForeignKeyRefsRow, error)

func (*Queries) LastLogID

func (q *Queries) LastLogID(ctx context.Context) (int64, error)

func (*Queries) LogEvents

func (q *Queries) LogEvents(ctx context.Context, id int64) ([]SwitchoverLog, error)

func (*Queries) Now

func (q *Queries) Now(ctx context.Context) (time.Time, error)

func (*Queries) SequenceNames

func (q *Queries) SequenceNames(ctx context.Context) ([]string, error)

func (*Queries) TableColumns

func (q *Queries) TableColumns(ctx context.Context) ([]TableColumnsRow, error)

func (*Queries) WithTx

func (q *Queries) WithTx(tx pgx.Tx) *Queries

type SwitchoverLog

type SwitchoverLog struct {
	ID        int64
	Timestamp time.Time
	Data      pgtype.JSONB
}

type SwitchoverState

type SwitchoverState struct {
	Ok           bool
	CurrentState EnumSwitchoverState
	DbID         uuid.UUID
}

type TableColumnsRow

type TableColumnsRow struct {
	ColTableName       string
	ColColumnName      string
	ColDataType        string
	ColOrdinalPosition int32
}