logstore

type Entry struct {
	Time   time.Time
	Stderr bool
	Line   string
}

type Options struct {
	Root            string // <data-dir>/logs
	Clock           clock.Clock
	MaxSegmentBytes int64         // 0 = default 8MB
	MaxSegmentAge   time.Duration // 0 = default 1h
	RetentionBytes  int64         // per-stream compressed cap; 0 = unlimited
	RetentionAge    time.Duration // 0 = unlimited
}

type Query struct {
	Streams []StreamID
	Since   time.Time
	Until   time.Time // zero = now
	Limit   int       // 0 = default 1000
}

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

type Store interface {
	// Append adds entries to a stream (creating it on first write). Entries
	// must be in non-decreasing time order per call.
	Append(stream StreamID, entries []Entry) error
	// Query returns matching entries in time order.
	Query(ctx context.Context, q Query) ([]Entry, error)
	// Follow returns history matching q, then keeps streaming live entries
	// until ctx is canceled. The channel is closed on ctx cancellation.
	Follow(ctx context.Context, q Query) (<-chan Entry, error)
	// DeleteStream drops a stream's segments (retention, app deletion).
	DeleteStream(stream StreamID) error
	Close() error
}

type StreamID string