mocks

Documentation

Index

• type Querier
  • func (m *Querier) Close(ctx context.Context) error
  • func (m *Querier) Exec(ctx context.Context, query string, args ...any) (postgres.CommandTag, error)
  • func (m *Querier) ExecInTx(ctx context.Context, fn func(tx postgres.Tx) error) error
  • func (m *Querier) ExecInTxWithOptions(ctx context.Context, fn func(tx postgres.Tx) error, opts postgres.TxOptions) error
  • func (m *Querier) Query(ctx context.Context, query string, args ...any) (postgres.Rows, error)
  • func (m *Querier) QueryRow(ctx context.Context, query string, args ...any) postgres.Row
• type ReplicationConn
  • func (m *ReplicationConn) Close(ctx context.Context) error
  • func (m *ReplicationConn) IdentifySystem(ctx context.Context) (postgres.IdentifySystemResult, error)
  • func (m *ReplicationConn) ReceiveMessage(ctx context.Context) (*postgres.ReplicationMessage, error)
  • func (m *ReplicationConn) SendStandbyStatusUpdate(ctx context.Context, lsn uint64) error
  • func (m *ReplicationConn) StartReplication(ctx context.Context, cfg postgres.ReplicationConfig) error
• type Row
  • func (m *Row) Scan(args ...any) error
• type Rows
  • func (m *Rows) Close()
  • func (m *Rows) CommandTag() pgconn.CommandTag
  • func (m *Rows) Conn() *pgx.Conn
  • func (m *Rows) Err() error
  • func (m *Rows) FieldDescriptions() []pgconn.FieldDescription
  • func (m *Rows) Next() bool
  • func (m *Rows) RawValues() [][]byte
  • func (m *Rows) Scan(dest ...any) error
  • func (m *Rows) Values() ([]any, error)
• type Tx
  • func (m *Tx) Exec(ctx context.Context, query string, args ...any) (postgres.CommandTag, error)
  • func (m *Tx) Query(ctx context.Context, query string, args ...any) (postgres.Rows, error)
  • func (m *Tx) QueryRow(ctx context.Context, query string, args ...any) postgres.Row

Types

type Querier

type Querier struct {
	QueryRowFn            func(ctx context.Context, query string, args ...any) postgres.Row
	QueryFn               func(ctx context.Context, query string, args ...any) (postgres.Rows, error)
	ExecFn                func(context.Context, uint, string, ...any) (postgres.CommandTag, error)
	ExecInTxFn            func(context.Context, func(tx postgres.Tx) error) error
	ExecInTxWithOptionsFn func(context.Context, uint, func(tx postgres.Tx) error, postgres.TxOptions) error
	CloseFn               func(context.Context) error
	// contains filtered or unexported fields
}

func (*Querier) Close

func (m *Querier) Close(ctx context.Context) error

func (*Querier) Exec

func (m *Querier) Exec(ctx context.Context, query string, args ...any) (postgres.CommandTag, error)

func (*Querier) ExecInTx

func (m *Querier) ExecInTx(ctx context.Context, fn func(tx postgres.Tx) error) error

func (*Querier) ExecInTxWithOptions

func (m *Querier) ExecInTxWithOptions(ctx context.Context, fn func(tx postgres.Tx) error, opts postgres.TxOptions) error

func (*Querier) Query

func (m *Querier) Query(ctx context.Context, query string, args ...any) (postgres.Rows, error)

func (*Querier) QueryRow

func (m *Querier) QueryRow(ctx context.Context, query string, args ...any) postgres.Row

type ReplicationConn

type ReplicationConn struct {
	IdentifySystemFn          func(ctx context.Context) (postgres.IdentifySystemResult, error)
	StartReplicationFn        func(ctx context.Context, cfg postgres.ReplicationConfig) error
	SendStandbyStatusUpdateFn func(ctx context.Context, lsn uint64) error
	ReceiveMessageFn          func(ctx context.Context) (*postgres.ReplicationMessage, error)
	CloseFn                   func(ctx context.Context) error
}

func (*ReplicationConn) Close

func (m *ReplicationConn) Close(ctx context.Context) error

func (*ReplicationConn) IdentifySystem

func (m *ReplicationConn) IdentifySystem(ctx context.Context) (postgres.IdentifySystemResult, error)

func (*ReplicationConn) ReceiveMessage

func (m *ReplicationConn) ReceiveMessage(ctx context.Context) (*postgres.ReplicationMessage, error)

func (*ReplicationConn) SendStandbyStatusUpdate

func (m *ReplicationConn) SendStandbyStatusUpdate(ctx context.Context, lsn uint64) error

func (*ReplicationConn) StartReplication

func (m *ReplicationConn) StartReplication(ctx context.Context, cfg postgres.ReplicationConfig) error

type Row

type Row struct {
	ScanFn func(args ...any) error
}

func (*Row) Scan

func (m *Row) Scan(args ...any) error

type Rows

type Rows struct {
	CloseFn             func()
	ErrFn               func() error
	FieldDescriptionsFn func() []pgconn.FieldDescription
	NextFn              func(i uint) bool
	ScanFn              func(dest ...any) error
	ValuesFn            func() ([]any, error)
	RawValuesFn         func() [][]byte
	// contains filtered or unexported fields
}

func (*Rows) Close

func (m *Rows) Close()

func (*Rows) CommandTag

func (m *Rows) CommandTag() pgconn.CommandTag

func (*Rows) Conn

func (m *Rows) Conn() *pgx.Conn

func (*Rows) Err

func (m *Rows) Err() error

func (*Rows) FieldDescriptions

func (m *Rows) FieldDescriptions() []pgconn.FieldDescription

func (*Rows) Next

func (m *Rows) Next() bool

func (*Rows) RawValues

func (m *Rows) RawValues() [][]byte

func (*Rows) Scan

func (m *Rows) Scan(dest ...any) error

func (*Rows) Values

func (m *Rows) Values() ([]any, error)

type Tx

type Tx struct {
	QueryRowFn func(ctx context.Context, query string, args ...any) postgres.Row
	QueryFn    func(ctx context.Context, query string, args ...any) (postgres.Rows, error)
	ExecFn     func(ctx context.Context, query string, args ...any) (postgres.CommandTag, error)
}

func (*Tx) Exec

func (m *Tx) Exec(ctx context.Context, query string, args ...any) (postgres.CommandTag, error)

func (*Tx) Query

func (m *Tx) Query(ctx context.Context, query string, args ...any) (postgres.Rows, error)

func (*Tx) QueryRow

func (m *Tx) QueryRow(ctx context.Context, query string, args ...any) postgres.Row