observability

type AuditEvent struct {
	EventID           string         `json:"event_id,omitempty"`
	Type              string         `json:"type"`
	PluginID          string         `json:"plugin_id"`
	PluginInstanceID  string         `json:"plugin_instance_id,omitempty"`
	SurfaceID         string         `json:"surface_id,omitempty"`
	SurfaceInstanceID string         `json:"surface_instance_id,omitempty"`
	RequestID         string         `json:"request_id,omitempty"`
	Actor             string         `json:"actor,omitempty"`
	OccurredAt        time.Time      `json:"occurred_at,omitempty"`
	Details           map[string]any `json:"details,omitempty"`
}

type AuditLister interface {
	ListPluginAudit(ctx context.Context, req ListAuditRequest) ([]AuditEvent, error)
}

type AuditSink interface {
	AppendPluginAudit(ctx context.Context, event AuditEvent) error
}

type DiagnosticEvent struct {
	EventID           string         `json:"event_id,omitempty"`
	Type              string         `json:"type"`
	Severity          string         `json:"severity"`
	Message           string         `json:"message"`
	PluginID          string         `json:"plugin_id,omitempty"`
	PluginInstanceID  string         `json:"plugin_instance_id,omitempty"`
	SurfaceID         string         `json:"surface_id,omitempty"`
	SurfaceInstanceID string         `json:"surface_instance_id,omitempty"`
	ActiveFingerprint string         `json:"active_fingerprint,omitempty"`
	RequestID         string         `json:"request_id,omitempty"`
	OccurredAt        time.Time      `json:"occurred_at,omitempty"`
	Details           map[string]any `json:"details,omitempty"`
}

type DiagnosticLister interface {
	ListPluginDiagnostics(ctx context.Context, req ListDiagnosticRequest) ([]DiagnosticEvent, error)
}

type DiagnosticsSink interface {
	AppendPluginDiagnostic(ctx context.Context, event DiagnosticEvent) error
}

type ListAuditRequest struct {
	PluginID         string `json:"plugin_id,omitempty"`
	PluginInstanceID string `json:"plugin_instance_id,omitempty"`
	Type             string `json:"type,omitempty"`
	Limit            int    `json:"limit,omitempty"`
}

type ListDiagnosticRequest struct {
	PluginID          string `json:"plugin_id,omitempty"`
	PluginInstanceID  string `json:"plugin_instance_id,omitempty"`
	SurfaceInstanceID string `json:"surface_instance_id,omitempty"`
	Type              string `json:"type,omitempty"`
	Severity          string `json:"severity,omitempty"`
	Limit             int    `json:"limit,omitempty"`
}

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

type MemoryStoreOptions struct {
	Now                 func() time.Time
	MaxAuditEvents      int
	MaxDiagnosticEvents int
}

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