servicehealth

type AssessmentRequest struct {
	OrgID       string
	WindowStart time.Time
	WindowEnd   time.Time
	Evidence    []core.SignalEvidence
	Inputs      []core.HealthAssessmentInput
	Services    []ServiceSnapshot
}

type Capability = core.HealthCapability

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

type CollectorOptions struct {
	Manager           *Manager
	Store             storage.Provider
	Services          func() []ServiceMetadata
	Patterns          func() []PatternMetadata
	SourceIDs         []string
	Providers         []core.HealthProvider
	ProviderSourceIDs []string
	Assessor          HealthAssessor
	EnrichmentAccess  EnrichmentAccess
	Now               func() time.Time
}

type CoverageSummary struct {
	TotalServices    int  `json:"total_services"`
	ObservedServices int  `json:"observed_services"`
	Partial          bool `json:"partial"`
}

type DomainSnapshot struct {
	Name          string `json:"name"`
	Severity      string `json:"severity"`
	ServiceCount  int    `json:"service_count"`
	ObservedCount int    `json:"observed_count"`
	AffectedCount int    `json:"affected_count"`
}

type EnrichmentAccess func(context.Context, string) error

type HealthAssessor interface {
	Assess(context.Context, AssessmentRequest) ([]core.HealthAssessment, error)
}

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

type OrganizationLister func(context.Context) ([]string, error)

type PatternMetadata struct {
	OrgID    string
	Service  string
	LastSeen time.Time
}

type Runtime struct {
	Manager *Manager
	Job     scheduler.Job
}

type RuntimeOptions struct {
	Manager           *Manager
	Store             storage.Provider
	Services          func() []ServiceMetadata
	Patterns          func() []PatternMetadata
	SourceIDs         []string
	Providers         []core.HealthProvider
	ProviderSourceIDs []string
	Assessor          HealthAssessor
	EnrichmentAccess  EnrichmentAccess
	Projection        SnapshotProjection
	Now               func() time.Time
}

type ServiceMetadata struct {
	OrgID  string
	Name   string
	Domain string
	Kind   string
}

type ServiceSnapshot struct {
	OrgID           string                              `json:"org_id"`
	Service         string                              `json:"service"`
	Domain          string                              `json:"domain"`
	Kind            string                              `json:"kind"`
	Severity        string                              `json:"severity"`
	BaseSeverity    string                              `json:"base_severity,omitempty"`
	AssessmentBasis string                              `json:"assessment_basis"`
	Logs            WindowAggregate                     `json:"logs"`
	Availability    map[string]core.MeasureAvailability `json:"availability"`
	ActiveIncidents *int                                `json:"active_incidents"`
	Evidence        []core.SignalEvidence               `json:"evidence,omitempty"`
	Assessment      *core.HealthAssessment              `json:"assessment,omitempty"`
}

type Settings struct {
	IntervalSeconds int    `json:"interval_seconds"`
	WindowSeconds   int    `json:"window_seconds"`
	Revision        uint64 `json:"revision"`
	Diagnostic      string `json:"diagnostic,omitempty"`
}

type SnapshotEnvelope struct {
	SnapshotID       string            `json:"snapshot_id"`
	GeneratedAt      time.Time         `json:"generated_at"`
	LatestAttempt    time.Time         `json:"latest_attempt"`
	LatestSuccess    time.Time         `json:"latest_success,omitempty"`
	NextCollectionAt time.Time         `json:"next_collection_at"`
	SettingsRevision uint64            `json:"settings_revision"`
	WindowSeconds    int               `json:"window_seconds"`
	Services         []ServiceSnapshot `json:"services"`
	Domains          []DomainSnapshot  `json:"domains"`
	Facets           map[string]int    `json:"facets"`
	Coverage         CoverageSummary   `json:"coverage"`
	Capabilities     []Capability      `json:"capabilities"`
	PendingSettings  *Settings         `json:"pending_settings,omitempty"`
}

type SnapshotProjection func(context.Context, string, SnapshotEnvelope) (SnapshotEnvelope, error)

type SourceStatus struct {
	SourceID      string    `json:"source_id"`
	LatestAttempt time.Time `json:"latest_attempt"`
	LatestSuccess time.Time `json:"latest_success,omitempty"`
	ErrorClass    string    `json:"error_class,omitempty"`
}

type ValidationError struct {
	Fields map[string]string `json:"fields"`
}

type WindowAggregate struct {
	Service           string           `json:"service"`
	SourceID          string           `json:"source_id"`
	MatchedLogs       int64            `json:"matched_logs"`
	UniquePatterns    int              `json:"unique_patterns"`
	NewPatterns       int              `json:"new_patterns"`
	UnknownPatterns   int              `json:"unknown_patterns"`
	SpikingPatterns   int              `json:"spiking_patterns"`
	SeverityCounts    map[string]int64 `json:"severity_counts"`
	LatestObservation time.Time        `json:"latest_observation,omitempty"`
	Estimated         bool             `json:"estimated"`
	Truncated         bool             `json:"truncated,omitempty"`
	PartialReason     string           `json:"partial_reason,omitempty"`
}