container

type AlertSeverity string

type Container struct {
	ID                   int64          `json:"id"`
	ExternalID           string         `json:"external_id"`
	Name                 string         `json:"name"`
	Image                string         `json:"image"`
	State                ContainerState `json:"state"`
	HealthStatus         *HealthStatus  `json:"health_status"`
	HasHealthCheck       bool           `json:"has_health_check"`
	OrchestrationGroup   string         `json:"orchestration_group,omitempty"`
	OrchestrationUnit    string         `json:"orchestration_unit,omitempty"`
	CustomGroup          string         `json:"custom_group,omitempty"`
	IsIgnored            bool           `json:"is_ignored"`
	AlertSeverity        AlertSeverity  `json:"alert_severity"`
	RestartThreshold     int            `json:"restart_threshold"`
	AlertChannels        string         `json:"alert_channels,omitempty"`
	Archived             bool           `json:"archived"`
	FirstSeenAt          time.Time      `json:"first_seen_at"`
	LastStateChangeAt    time.Time      `json:"last_state_change_at"`
	ArchivedAt           *time.Time     `json:"archived_at,omitempty"`
	RuntimeType          string         `json:"runtime_type"`
	ErrorDetail          string         `json:"error_detail,omitempty"`
	ControllerKind       string         `json:"controller_kind,omitempty"`
	Namespace            string         `json:"namespace,omitempty"`
	PodCount             int            `json:"pod_count"`
	ReadyCount           int            `json:"ready_count"`
	ComposeWorkingDir    string         `json:"compose_working_dir,omitempty"`
	SwarmServiceID       string         `json:"swarm_service_id,omitempty"`
	SwarmServiceName     string         `json:"swarm_service_name,omitempty"`
	SwarmServiceMode     string         `json:"swarm_service_mode,omitempty"`
	SwarmNodeID          string         `json:"swarm_node_id,omitempty"`
	SwarmTaskSlot        int            `json:"swarm_task_slot,omitempty"`
	SwarmDesiredReplicas int            `json:"swarm_desired_replicas,omitempty"`
}

type ContainerEvent struct {
	Action       string
	ExternalID   string
	Name         string
	ExitCode     string
	HealthStatus string
	ErrorDetail  string
	Timestamp    time.Time
	Labels       map[string]string
}

type ContainerGroup struct {
	Name       string       `json:"name"`
	Source     string       `json:"source"` // "compose", "label", "default"
	Containers []*Container `json:"containers"`
}

type ContainerState string

type ContainerStore interface {
	// Container CRUD
	InsertContainer(ctx context.Context, c *Container) (int64, error)
	UpdateContainer(ctx context.Context, c *Container) error
	GetContainerByExternalID(ctx context.Context, externalID string) (*Container, error)
	GetContainerByID(ctx context.Context, id int64) (*Container, error)
	ListContainers(ctx context.Context, opts ListContainersOpts) ([]*Container, error)
	ArchiveContainer(ctx context.Context, externalID string, archivedAt time.Time) error
	DeleteContainerByID(ctx context.Context, id int64) error

	// State transitions
	InsertTransition(ctx context.Context, t *StateTransition) (int64, error)
	ListTransitionsByContainer(ctx context.Context, containerID int64, opts ListTransitionsOpts) ([]*StateTransition, int, error)
	CountRestartsSince(ctx context.Context, containerID int64, since time.Time) (int, error)

	// Uptime
	GetTransitionsInWindow(ctx context.Context, containerID int64, from time.Time, to time.Time) ([]*StateTransition, error)

	// Retention
	DeleteTransitionsBefore(ctx context.Context, before time.Time, batchSize int) (int64, error)
	DeleteArchivedContainersBefore(ctx context.Context, before time.Time) (int64, error)
}

type Deps struct {
	Store          ContainerStore    // required
	Logger         *slog.Logger      // required
	EventCallback  EventCallback     // optional — nil-safe
	LogFetcher     LogFetcher        // optional — nil-safe
	RestartChecker RestartChecker    // optional — nil-safe
	Discoverer     RuntimeDiscoverer // optional — nil-safe
}

type EventCallback func(eventType string, data interface{})

type HealthStatus string

type ListContainersOpts struct {
	IncludeArchived bool
	IncludeIgnored  bool
	GroupFilter     string
	StateFilter     string
}

type ListTransitionsOpts struct {
	Since  *time.Time
	Until  *time.Time
	Limit  int
	Offset int
}

type LogFetcher interface {
	FetchLogSnippet(ctx context.Context, externalID string) (string, error)
}

type RestartChecker interface {
	Check(ctx context.Context, c *Container) (interface{}, error)
}

type RuntimeDiscoverer interface {
	DiscoverAll(ctx context.Context) ([]*Container, error)
}

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

type StateTransition struct {
	ID             int64          `json:"id"`
	ContainerID    int64          `json:"container_id"`
	PreviousState  ContainerState `json:"previous_state"`
	NewState       ContainerState `json:"new_state"`
	PreviousHealth *HealthStatus  `json:"previous_health,omitempty"`
	NewHealth      *HealthStatus  `json:"new_health,omitempty"`
	ExitCode       *int           `json:"exit_code,omitempty"`
	LogSnippet     string         `json:"log_snippet,omitempty"`
	Timestamp      time.Time      `json:"timestamp"`
}

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

type UptimeResult struct {
	Hours24 *float64 `json:"24h"`
	Days7   *float64 `json:"7d,omitempty"`
	Days30  *float64 `json:"30d,omitempty"`
	Days90  *float64 `json:"90d,omitempty"`
}