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)
	CopyFromTextFn   func(ctx context.Context, tableName string, columnNames []string, srcRows [][]any) (int64, error)
	CopyToWriterFn   func(ctx context.Context, w io.Writer, sql string) (int64, error)
	CopyFromReaderFn func(ctx context.Context, r io.Reader, sql string) (int64, error)
	// contains filtered or unexported fields
}