Versions in this module Expand all Collapse all v0 v0.2.0 Oct 13, 2026 Changes in this version + const FormatJSONCompactEachRow + func EncodeCompactRow(orderedCols []discovery.Column, record map[string]any) (json.RawMessage, error) + type ClaimConfig struct + Every time.Duration + Handover time.Duration + MaxHeld int + SlotExpiry time.Duration + UnownedEvery time.Duration type EventMessage + Columns []string + Format string + Row json.RawMessage + type Queue interface + func ClaimShards(q Queue, c coord.Coordinator, cfg ClaimConfig) (Queue, error) v0.1.0 Aug 19, 2026 Changes in this version + const BufferConsumerName + func StartIngestWorker(ctx context.Context, nc *nats.Conn, cache cache.Cache, ...) (func(context.Context) error, error) + type EventMessage struct + Data map[string]any + ReceivedTimestamp string + Scope string + TableName string + type IngestWorker struct + type Sweeper struct + func NewSweeper(js jetstream.JetStream, gapWindow time.Duration, logger *slog.Logger) *Sweeper + func (s *Sweeper) Start(ctx context.Context)
Go to main page