mocks

type Mapper struct {
	TypeForOIDFn func(oid uint32) (string, error)
}

type Querier struct {
	QueryRowFn            func(ctx context.Context, dest []any, query string, args ...any) error
	QueryFn               func(ctx context.Context, i uint, 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
	CopyFromFn            func(ctx context.Context, tableName string, columnNames []string, srcRows [][]any) (int64, error)
	PingFn                func(context.Context) error
	CloseFn               func(context.Context) error
	// contains filtered or unexported fields
}

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
}

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

type Tx struct {
	QueryRowFn func(ctx context.Context, dest []any, query string, args ...any) error
	QueryFn    func(ctx context.Context, query string, args ...any) (postgres.Rows, error)
	ExecFn     func(ctx context.Context, i uint, query string, args ...any) (postgres.CommandTag, error)
	CopyFromFn func(ctx context.Context, tableName string, columnNames []string, srcRows [][]any) (int64, error)
	// contains filtered or unexported fields
}