diagnostics

type AuditSink interface {
	RecordDiagnosticsQuery(context.Context, QueryAudit) error
}

type BatchSink interface {
	Ship(context.Context, []Event) error
}

type BatchSinkFunc func(context.Context, []Event) error

type ComponentSpec struct {
	Name        string `json:"name"`
	Description string `json:"description,omitempty"`
}

type Event struct {
	ID           string    `json:"id"`
	Timestamp    time.Time `json:"timestamp"`
	Level        string    `json:"level"`
	Component    string    `json:"component,omitempty"`
	Message      string    `json:"message,omitempty"`
	Operation    string    `json:"operation,omitempty"`
	Job          string    `json:"job,omitempty"`
	Step         string    `json:"step,omitempty"`
	Status       string    `json:"status,omitempty"`
	Attempt      int       `json:"attempt,omitempty"`
	ErrorCode    string    `json:"error_code,omitempty"`
	ErrorSummary string    `json:"error_summary,omitempty"`
	// DurationMS is the elapsed time of the operation/step this event
	// describes, in milliseconds. Zero means "not reported" — most events
	// have no associated duration. See #355.
	DurationMS int64  `json:"duration_ms,omitempty"`
	Pool       string `json:"pool,omitempty"`
	Agent      string `json:"agent,omitempty"`
	Resource   string `json:"resource,omitempty"`
	Provider   string `json:"provider,omitempty"`
	Request    string `json:"request,omitempty"`
}

type Export struct {
	SchemaVersion int             `json:"schema_version"`
	GeneratedAt   time.Time       `json:"generated_at"`
	Sanitized     bool            `json:"sanitized"`
	Components    []ComponentSpec `json:"components"`
	Events        []Event         `json:"events"`
}

type ExportOptions struct {
	GeneratedAt time.Time
	Components  []ComponentSpec
}

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

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

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

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

type Page struct {
	Events     []Event `json:"events"`
	NextCursor string  `json:"next_cursor,omitempty"`
}

type Query struct {
	Since     time.Time
	Level     string
	Component string
	Pool      string
	Agent     string
	Resource  string
	Provider  string
	Job       string
	Status    string
	Limit     int
	Cursor    string
}

type QueryAudit struct {
	Actor       string
	Since       string
	Level       string
	Component   string
	Job         string
	Status      string
	Pool        string
	Agent       string
	Resource    string
	Provider    string
	Limit       int
	ResultCount int
}

type ResourceCleanupAudit struct {
	Actor          string `json:"actor"`
	Mode           string `json:"mode"`
	Force          bool   `json:"force"`
	State          string `json:"state"`
	Unreferenced   bool   `json:"unreferenced"`
	OlderThan      string `json:"older_than,omitempty"`
	CandidateCount int    `json:"candidate_count"`
	CleanedCount   int    `json:"cleaned_count"`
	SkippedCount   int    `json:"skipped_count"`
	ErrorCount     int    `json:"error_count"`
}

type ResourceCleanupAuditSink interface {
	RecordResourceCleanup(context.Context, ResourceCleanupAudit) error
}

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

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

type ShipperOptions struct {
	MaxBatch int
	MaxQueue int
}

type Store interface {
	Append(context.Context, Event) error
	Query(context.Context, Query) (Page, error)
}