Retracted: Withdrawn; the module proxy serves these against commits that no longer exist here.
Documentation
¶
Index ¶
- type YugabyteSource
- func (y *YugabyteSource) Ack(ctx context.Context, msg hermod.Message) error
- func (y *YugabyteSource) Close() error
- func (y *YugabyteSource) DiscoverDatabases(ctx context.Context) ([]string, error)
- func (y *YugabyteSource) DiscoverTables(ctx context.Context) ([]string, error)
- func (y *YugabyteSource) GetState() map[string]string
- func (y *YugabyteSource) Ping(ctx context.Context) error
- func (y *YugabyteSource) Read(ctx context.Context) (hermod.Message, error)
- func (y *YugabyteSource) Sample(ctx context.Context, table string) (hermod.Message, error)
- func (y *YugabyteSource) SetLogger(logger hermod.Logger)
- func (y *YugabyteSource) SetState(state map[string]string)
- func (y *YugabyteSource) Snapshot(ctx context.Context, tables ...string) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type YugabyteSource ¶
type YugabyteSource struct {
// contains filtered or unexported fields
}
YugabyteSource implements the hermod.Source interface for YugabyteDB. Since YugabyteDB is PostgreSQL-compatible, it uses pgx.
func NewYugabyteSource ¶
func (*YugabyteSource) Ack ¶
Ack moves the persisted cursor to the acknowledged row. It must not move on read: GetState is the engine's persistence contract, so a cursor advanced when a row is handed out is already past rows still in flight, and a crash before the sinks wrote them erases them from the resume.
func (*YugabyteSource) Close ¶
func (y *YugabyteSource) Close() error
func (*YugabyteSource) DiscoverDatabases ¶
func (y *YugabyteSource) DiscoverDatabases(ctx context.Context) ([]string, error)
func (*YugabyteSource) DiscoverTables ¶
func (y *YugabyteSource) DiscoverTables(ctx context.Context) ([]string, error)
func (*YugabyteSource) GetState ¶
func (y *YugabyteSource) GetState() map[string]string
func (*YugabyteSource) SetLogger ¶
func (y *YugabyteSource) SetLogger(logger hermod.Logger)
func (*YugabyteSource) SetState ¶
func (y *YugabyteSource) SetState(state map[string]string)
Source Files
Click to show internal directories.
Click to hide internal directories.