scylladb

func (*ScyllaDBSource) Ack ¶

func (s *ScyllaDBSource) Ack(ctx context.Context, msg hermod.Message) error

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 (*ScyllaDBSource) Close ¶

func (s *ScyllaDBSource) Close() error

func (*ScyllaDBSource) DiscoverDatabases ¶

func (s *ScyllaDBSource) DiscoverDatabases(ctx context.Context) ([]string, error)

func (*ScyllaDBSource) DiscoverTables ¶

func (s *ScyllaDBSource) DiscoverTables(ctx context.Context) ([]string, error)

func (*ScyllaDBSource) GetState ¶

func (s *ScyllaDBSource) GetState() map[string]string

func (*ScyllaDBSource) Ping ¶

func (s *ScyllaDBSource) Ping(ctx context.Context) error

func (*ScyllaDBSource) Read ¶

func (s *ScyllaDBSource) Read(ctx context.Context) (hermod.Message, error)

func (*ScyllaDBSource) Sample ¶

func (s *ScyllaDBSource) Sample(ctx context.Context, table string) (hermod.Message, error)

func (*ScyllaDBSource) SetLogger ¶

func (s *ScyllaDBSource) SetLogger(logger hermod.Logger)

func (*ScyllaDBSource) SetState ¶

func (s *ScyllaDBSource) SetState(state map[string]string)

func (*ScyllaDBSource) Snapshot ¶

func (s *ScyllaDBSource) Snapshot(ctx context.Context, tables ...string) error