capturelog

type Dependencies struct {
	DB *database.DB
	// Schema holds the table; it must be a valid identifier.
	Schema string
	// Clock supplies retention cutoffs. Capture times come from the producer.
	Clock  clock.Clock
	Logger *slog.Logger
}

type Engine interface {
	Pruner
	Run(ctx context.Context, roles Roles) error
	Close(ctx context.Context) error
	Done() <-chan struct{}
	Check(ctx context.Context)
	Flush(ctx context.Context)
	PrunePass(ctx context.Context) bool
	Read(ctx context.Context, fn func(context.Context, *database.Tx) error) error
	Transaction(ctx context.Context, readOnly bool, fn func(*database.Tx) error) error
	Lock(ctx context.Context, tx *database.Tx) (bool, error)
}

type Limits struct {
	Retention time.Duration
	MaxRows   int
}

type Log[S, M any] struct {
	// contains filtered or unexported fields
}

type PruneCommand struct {
	// contains filtered or unexported fields
}

type Pruner interface {
	Label() string
	Now() (temporal.DateTime, error)
	Cutoff() (temporal.DateTime, error)
	Estimate(ctx context.Context, cutoff temporal.DateTime, capped bool) (int64, error)
	Prune(ctx context.Context, cutoff temporal.DateTime, capped bool, batch, maxBatches int) (int64, bool, error)
}

type Redact[S, M any] func(snapshot S, droppedBefore uint64) (M, error)

type Roles struct {
	// Write drains the recorder. The table is checked on the first record.
	Write bool
	// Retain prunes on a timer; its first pass also checks the table.
	Retain bool
}

type Table[M any] struct {
	// Name is the table name used by the availability check.
	Name string
	// Label names the rows in logs and command output, e.g. "webhook capture".
	Label string
	// Lock is the advisory-lock namespace retention holds per schema.
	Lock  string
	Query func() orm.Query[M]
	ID    orm.Key[M, model.ID[M]]
	At    orm.Time[M, temporal.DateTime]
	// Partition, when set, applies the row cap per distinct value of this
	// column instead of to the whole table.
	Partition *orm.Text[M, string]
	Insert    func(context.Context, *database.Tx, []M) error
	// Size estimates a row's payload for write batching.
	Size func(M) int
}