eventlog

Sep 14, 2026

Changes in this version

+ var ErrAckConflict = errors.New("consumer cursor changed; read a fresh batch")

+ var ErrCursorExpired = errors.New("event cursor precedes retention boundary")

+ func Append(ctx context.Context, tx *sql.Tx, eventKey, topic string, payload []byte) (int64, error)

+ type Batch struct

+ Events []Event

+ From int64

+ To int64

+ func (b *Batch) Ack(ctx context.Context) error

+ type ConsumerStats struct

+ Expired bool

+ Lag int64

+ Latest int64

+ Position int64

+ RetainedAfter int64

+ type Event struct

+ CreatedAt time.Time

+ Key string

+ Payload []byte

+ Sequence int64

+ Topic string

+ type Log struct

+ func Open(ctx context.Context, db *sql.DB) (*Log, error)

+ func (l *Log) Prune(ctx context.Context, through int64) error

+ func (l *Log) Publish(ctx context.Context, key, topic string, payload []byte) (int64, error)

+ func (l *Log) Read(ctx context.Context, consumer string, limit int) (*Batch, error)

+ func (l *Log) RegisterConsumer(ctx context.Context, name string, after int64) error

+ func (l *Log) Stats(ctx context.Context, consumer string) (ConsumerStats, error)