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) 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

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, string, ...any) (postgres.CommandTag, error)
	CloseFn    func(context.Context) error
}

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) 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