logstore

type AppSummary struct {
	App      string           `json:"app"`
	Services []ServiceSummary `json:"services"`
}

type Cursor struct {
	At   time.Time
	File string // path relative to root
	Seq  int64  // byte offset of the line's start in File: ordered like the lines, stable under appends, seekable
}

type Event struct {
	At        time.Time `json:"at"`
	App       string    `json:"app"`
	Service   string    `json:"service"`
	Container string    `json:"container"`
	Kind      string    `json:"kind"`
	ExitCode  string    `json:"exit_code,omitempty"`
	FromImage string    `json:"from_image,omitempty"`
	ToImage   string    `json:"to_image,omitempty"`
	By        string    `json:"by"` // "operation" | "docker"
	Detail    string    `json:"detail,omitempty"`
}

type EventQuery struct {
	Apps  []string
	Kinds []string
	Since time.Time // zero = no bound
	Until time.Time // zero = no bound
	Limit int       // ≤ 1000, default 500
}

type FileInfo struct {
	Path string
	Day  time.Time // UTC midnight parsed from the name; zero for a file the layout does not know
	Size int64
}

type Filter struct {
	Apps, Services []string
	Stream         string // "", "o", "e"
	Level          string // "", "info", "warn", "error" (minimum level)
	Q              string
	Regex          bool
}

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

type Line struct {
	At        time.Time `json:"at"`
	App       string    `json:"app"`
	Service   string    `json:"service"`
	Container string    `json:"container"` // 12 hex chars
	Stream    string    `json:"stream"`    // "o" or "e"
	Text      string    `json:"text"`
	Cursor    string    `json:"cursor,omitempty"` // set by Read only: where the line is, to pass as since or before
}

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

type Message struct {
	T       string `json:"t"` // "line" | "event" | "lag"
	Line    *Line  `json:"line,omitempty"`
	Event   *Event `json:"event,omitempty"`
	Dropped int    `json:"dropped,omitempty"`
}

type Page struct {
	Lines  []Line  `json:"lines"`
	Events []Event `json:"events"`
	Next   string  `json:"next,omitempty"` // "" when exhausted
}

type Query struct {
	Filter
	Since  time.Time // with After: lower bound of the window; otherwise zero
	Until  time.Time
	Before *Cursor // backwards (newest→oldest) strictly before; nil = from the end
	After  *Cursor // forwards (oldest→newest) strictly after; nil = backwards mode
	Limit  int     // clamped to [1,1000], default 500
}

type ServiceSummary struct {
	Service   string    `json:"service"`
	Container string    `json:"container"`
	Running   bool      `json:"running"` // set by the caller (service layer)
	FirstAt   time.Time `json:"first_at"`
	LastAt    time.Time `json:"last_at"`
	SizeBytes int64     `json:"size_bytes"`
}

type Store struct {
	Root string
	// OnError, if set before use, receives every writer's flush error (nil = ignored).
	OnError func(error)
	// contains filtered or unexported fields
}

type Writer struct {

	// OnError, if set before use, receives every flush error (nil = ignored). The failed buffer is dropped.
	OnError func(error)
	// contains filtered or unexported fields
}