clickhouse

func (*ClickHouseSource) Ack ¶

func (c *ClickHouseSource) Ack(ctx context.Context, msg hermod.Message) error

Ack moves the position a restart resumes from.

It used to do nothing, while Read advanced the watermark the moment a row was fetched — so the position the engine persisted was always at least one row ahead of what had been delivered, and a worker that died with a message in flight came back past it. The row was never handed out again and nothing reported a gap.

The same distinction the MongoDB and MySQL sources draw, for the same reason.

func (*ClickHouseSource) Close ¶

func (c *ClickHouseSource) Close() error

func (*ClickHouseSource) DiscoverColumns ¶

func (c *ClickHouseSource) DiscoverColumns(ctx context.Context, table string) ([]hermod.ColumnInfo, error)

func (*ClickHouseSource) DiscoverDatabases ¶

func (c *ClickHouseSource) DiscoverDatabases(ctx context.Context) ([]string, error)

func (*ClickHouseSource) DiscoverTables ¶

func (c *ClickHouseSource) DiscoverTables(ctx context.Context) ([]string, error)

func (*ClickHouseSource) GetState ¶

func (c *ClickHouseSource) GetState() map[string]string

func (*ClickHouseSource) Ping ¶

func (c *ClickHouseSource) Ping(ctx context.Context) error

func (*ClickHouseSource) Read ¶

func (c *ClickHouseSource) Read(ctx context.Context) (hermod.Message, error)

func (*ClickHouseSource) Sample ¶

func (c *ClickHouseSource) Sample(ctx context.Context, table string) (hermod.Message, error)

func (*ClickHouseSource) SetLogger ¶

func (c *ClickHouseSource) SetLogger(logger hermod.Logger)

func (*ClickHouseSource) SetState ¶

func (c *ClickHouseSource) SetState(state map[string]string)

func (*ClickHouseSource) Snapshot ¶

func (c *ClickHouseSource) Snapshot(ctx context.Context, tables ...string) error