client

type A2AAgentCard struct {
	Name         string `json:"name"`
	Description  string `json:"description"`
	URL          string `json:"url"`
	Capabilities struct {
		Streaming         bool `json:"streaming"`
		PushNotifications bool `json:"pushNotifications"`
	} `json:"capabilities"`
	Skills []struct {
		ID          string `json:"id"`
		Name        string `json:"name"`
		Description string `json:"description,omitempty"`
	} `json:"skills,omitempty"`
}

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

type A2AMessage struct {
	Role  string `json:"role"`
	Parts []struct {
		Text string `json:"text,omitempty"`
	} `json:"parts"`
}

type A2ATask struct {
	ID     string `json:"id"`
	Status struct {
		State string `json:"state"`
	} `json:"status"`
	Messages []A2AMessage `json:"messages,omitempty"`
}

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

type Anomaly struct {
	ID         string                 `json:"id"`
	Type       string                 `json:"type"`
	EntityA    string                 `json:"entity_a"`
	EntityB    string                 `json:"entity_b,omitempty"`
	Confidence float64                `json:"confidence"`
	Status     string                 `json:"status"`
	Evidence   map[string]interface{} `json:"evidence,omitempty"`
	DetectedAt string                 `json:"detected_at,omitempty"`
}

type AnomalyCounts struct {
	ByType   map[string]int `json:"by_type"`
	ByStatus map[string]int `json:"by_status"`
	Total    int            `json:"total"`
}

type Category struct {
	Name    string             `json:"name"`
	Metrics map[string]float64 `json:"metrics"`
}

type ComponentInfo struct {
	Name      string `json:"name"`
	Component string `json:"component"` // Component factory name (e.g., "udp", "graph-processor")
	Type      string `json:"type"`      // Component category (input/processor/output/storage/gateway)
	Enabled   bool   `json:"enabled"`
	State     string `json:"state"`
	Healthy   bool   `json:"healthy"`
	LastError string `json:"last_error,omitempty"`
}

type ComponentStatus struct {
	Component       string `json:"component"`
	Stage           string `json:"stage"`
	CycleID         string `json:"cycle_id,omitempty"`
	CycleStartedAt  string `json:"cycle_started_at,omitempty"`
	StageStartedAt  string `json:"stage_started_at"`
	LastCompletedAt string `json:"last_completed_at,omitempty"`
	LastResult      string `json:"last_result,omitempty"` // "success" or "error"
	LastError       string `json:"last_error,omitempty"`
}

type ContextEntry struct {
	EntityID  string `json:"entity_id"`
	Predicate string `json:"predicate"`
}

type DirectoryRegistration struct {
	AgentID       string         `json:"agent_id"`
	OASFRecord    map[string]any `json:"oasf_record"`
	RegisteredAt  string         `json:"registered_at"`
	LastHeartbeat string         `json:"last_heartbeat"`
	TTL           string         `json:"ttl"`
}

type DisconnectedNode struct {
	ComponentName string   `json:"component_name"`
	Issue         string   `json:"issue"`
	Suggestions   []string `json:"suggestions,omitempty"`
}

type EntityStabilizationResult struct {
	FinalCount   int
	WaitDuration time.Duration
	Stabilized   bool
	TimedOut     bool
	UsedSSE      bool
}

type EntityState struct {
	ID         string         `json:"id"`
	Type       string         `json:"type"`
	Properties map[string]any `json:"properties"`
	Triples    []Triple       `json:"triples,omitempty"`
	Version    int            `json:"version"`
	UpdatedAt  string         `json:"updated_at,omitempty"`
}

type FlowExpectation struct {
	InputSubject     string        // Expected input subject pattern (e.g., "input.udp")
	ProcessingStages []string      // Expected processing stages (e.g., ["process.rule", "process.graph"])
	MinMessages      int           // Minimum number of messages expected
	MaxLatencyMs     int           // Maximum acceptable p99 latency in ms
	Timeout          time.Duration // How long to wait for flow completion
}

type FlowInfo struct {
	ID           string `json:"id"`
	Name         string `json:"name"`
	RuntimeState string `json:"runtime_state"`
}

type FlowResult struct {
	Valid        bool                    `json:"valid"`
	Messages     int                     `json:"messages"`
	AvgLatency   time.Duration           `json:"avg_latency"`
	P99Latency   time.Duration           `json:"p99_latency,omitempty"`
	StageMetrics map[string]StageMetrics `json:"stage_metrics,omitempty"`
	Errors       []string                `json:"errors,omitempty"`
	Warnings     []string                `json:"warnings,omitempty"`
}

type FlowSnapshot struct {
	Timestamp       time.Time        `json:"timestamp"`
	MetricsBaseline *MetricsBaseline `json:"metrics_baseline"`
	MessageCount    int              `json:"message_count"`
	LastMessageID   string           `json:"last_message_id,omitempty"`
}

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

type FlowValidation struct {
	Timestamp           string                   `json:"timestamp"`
	ValidationStatus    string                   `json:"validation_status"`
	ConnectedComponents [][]string               `json:"connected_components"`
	ConnectedEdges      []map[string]interface{} `json:"connected_edges"`
	DisconnectedNodes   []DisconnectedNode       `json:"disconnected_nodes"`
	OrphanedPorts       []OrphanedPort           `json:"orphaned_ports"`
	StreamWarnings      []StreamWarning          `json:"stream_warnings"`
	Summary             FlowValidationSummary    `json:"summary"`
}

type FlowValidationSummary struct {
	TotalComponents       int  `json:"total_components"`
	TotalConnections      int  `json:"total_connections"`
	ComponentGroups       int  `json:"component_groups"`
	OrphanedPortCount     int  `json:"orphaned_port_count"`
	DisconnectedNodeCount int  `json:"disconnected_node_count"`
	StreamWarningCount    int  `json:"stream_warning_count"`
	HasStreamIssues       bool `json:"has_stream_issues"`
}

type FlowsResponse struct {
	Flows []FlowInfo `json:"flows"`
}

type IncomingEntry struct {
	Predicate    string `json:"predicate"`
	FromEntityID string `json:"from_entity_id"`
}

type KCoreMetadata struct {
	MaxCore     int         `json:"max_core"`
	EntityCount int         `json:"entity_count"`
	ComputedAt  string      `json:"computed_at"`
	CoreBuckets map[int]int `json:"core_buckets"` // core number -> count of entities
}

type KVChangeEvent struct {
	Bucket    string          `json:"bucket"`
	Key       string          `json:"key"`
	Operation string          `json:"operation"` // "create", "update", "delete"
	Value     json.RawMessage `json:"value,omitempty"`
	Revision  uint64          `json:"revision"`
	Timestamp time.Time       `json:"timestamp"`
}

type KVEntry struct {
	Key      string    `json:"key"`
	Value    any       `json:"value"`
	Revision uint64    `json:"revision"`
	Created  time.Time `json:"created"`
}

type KVQueryResult struct {
	Bucket  string    `json:"bucket"`
	Pattern string    `json:"pattern"`
	Count   int       `json:"count"`
	Entries []KVEntry `json:"entries"`
}

type KVWatchCondition func(events []KVChangeEvent) (satisfied bool, err error)

type KVWatchOpts struct {
	Timeout time.Duration // Max wait time (default 60s)
	Pattern string        // Key pattern filter (default "*")
}

type LoggerStats struct {
	TotalMessages     int64     `json:"total_messages"`
	ValidMessages     int64     `json:"valid_messages"`
	InvalidMessages   int64     `json:"invalid_messages"`
	StartTime         time.Time `json:"start_time"`
	LastMessageTime   time.Time `json:"last_message_time"`
	UptimeSeconds     float64   `json:"uptime_seconds"`
	MonitoredSubjects []string  `json:"monitored_subjects"`
	MaxEntries        int       `json:"max_entries"`
}

type MessageEntry struct {
	Sequence    uint64          `json:"sequence"`
	Timestamp   time.Time       `json:"timestamp"`
	Subject     string          `json:"subject"`
	MessageType string          `json:"message_type,omitempty"`
	MessageID   string          `json:"message_id,omitempty"`
	TraceID     string          `json:"trace_id,omitempty"`
	SpanID      string          `json:"span_id,omitempty"`
	Summary     string          `json:"summary"`
	RawData     json.RawMessage `json:"raw_data,omitempty"`
	Metadata    map[string]any  `json:"metadata,omitempty"`
}

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

type MessageTrace struct {
	MessageID string         // Original message ID
	Entries   []MessageEntry // All log entries related to this message
	Flow      []string       // Subject flow path: ["input.udp", "process.rule", "process.graph"]
	Duration  time.Duration  // Time from first to last entry
}

type Metric struct {
	Name   string            `json:"name"`
	Labels map[string]string `json:"labels,omitempty"`
	Value  float64           `json:"value"`
}

type MetricsBaseline struct {
	Timestamp time.Time          `json:"timestamp"`
	Metrics   map[string]float64 `json:"metrics"`
}

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

type MetricsDiff struct {
	BaselineTime time.Time          `json:"baseline_time"`
	CurrentTime  time.Time          `json:"current_time"`
	Duration     time.Duration      `json:"duration"`
	Deltas       map[string]float64 `json:"deltas"`       // current - baseline
	RatePerSec   map[string]float64 `json:"rate_per_sec"` // delta / duration.Seconds()
}

type MetricsReport struct {
	Timestamp    time.Time           `json:"timestamp"`
	Duration     time.Duration       `json:"duration_ns"`
	DurationText string              `json:"duration"`
	Counters     map[string]float64  `json:"counters"`
	Gauges       map[string]float64  `json:"gauges"`
	Histograms   map[string]float64  `json:"histograms,omitempty"`
	Categories   map[string]Category `json:"categories"`
}

type MetricsSnapshot struct {
	Timestamp time.Time         `json:"timestamp"`
	Metrics   map[string]Metric `json:"metrics"`
	Raw       string            `json:"raw,omitempty"`
}

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

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

type OASFRecord struct {
	Name          string         `json:"name"`
	Version       string         `json:"version"`
	SchemaVersion string         `json:"schema_version"`
	Authors       []string       `json:"authors"`
	CreatedAt     string         `json:"created_at"`
	Description   string         `json:"description"`
	Skills        []OASFSkill    `json:"skills"`
	Domains       []OASFDomain   `json:"domains,omitempty"`
	Extensions    map[string]any `json:"extensions,omitempty"`
}

type OASFSkill struct {
	ID          string   `json:"id"`
	Name        string   `json:"name"`
	Description string   `json:"description,omitempty"`
	Confidence  float64  `json:"confidence,omitempty"`
	Permissions []string `json:"permissions,omitempty"`
}

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

type OrphanedPort struct {
	ComponentName string `json:"component_name"`
	PortName      string `json:"port_name"`
	Direction     string `json:"direction"`
	ConnectionID  string `json:"connection_id"`
	Pattern       string `json:"pattern"`
	Issue         string `json:"issue"`
	Required      bool   `json:"required"`
}

type OutgoingEntry struct {
	Predicate  string `json:"predicate"`
	ToEntityID string `json:"to_entity_id"`
}

type PivotMetadata struct {
	Pivots      []string `json:"pivots"`
	EntityCount int      `json:"entity_count"`
	ComputedAt  string   `json:"computed_at"`
}

type PlatformHealth struct {
	Healthy bool   `json:"healthy"`
	Status  string `json:"status"`
	Message string `json:"message,omitempty"`
}

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

type RuleMetrics struct {
	// Rule evaluation metrics
	Evaluations float64 `json:"evaluations"` // Total rule evaluations
	Firings     float64 `json:"firings"`     // Rules that fired (conditions met)

	// Action metrics
	ActionsDispatched float64 `json:"actions_dispatched"` // Total actions dispatched

	// Execution lifecycle metrics (legacy — kept for backwards compat, always 0)
	ExecutionsCreated   float64 `json:"executions_created"`
	ExecutionsCompleted float64 `json:"executions_completed"`
	ExecutionsFailed    float64 `json:"executions_failed"`

	// Callback metrics (legacy — kept for backwards compat, always 0)
	CallbacksReceived float64 `json:"callbacks_received"`
}

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

type SSEEvent struct {
	Event string          // Event type (e.g., "connected", "kv_change", "error")
	ID    string          // Event ID for reconnection
	Data  json.RawMessage // Event payload
}

type StageMetrics struct {
	Stage        string             `json:"stage"`
	MessagesIn   int                `json:"messages_in"`
	MessagesOut  int                `json:"messages_out"`
	Errors       int                `json:"errors"`
	AvgLatency   time.Duration      `json:"avg_latency"`
	MetricDeltas map[string]float64 `json:"metric_deltas,omitempty"`
}

type StatusStreamEnvelope struct {
	Type      string          `json:"type"`
	ID        string          `json:"id"`
	Timestamp int64           `json:"timestamp"`
	FlowID    string          `json:"flow_id"`
	Payload   json.RawMessage `json:"payload,omitempty"`
}

type StepResult struct {
	StepName  string          `json:"step_name"`
	Status    string          `json:"status"`
	Output    json.RawMessage `json:"output,omitempty"`
	Error     string          `json:"error,omitempty"`
	Iteration int             `json:"iteration"`
}

type StreamWarning struct {
	Severity       string   `json:"severity"`
	SubscriberComp string   `json:"subscriber_component"`
	SubscriberPort string   `json:"subscriber_port"`
	Subjects       []string `json:"subjects"`
	PublisherComps []string `json:"publisher_components"`
	Issue          string   `json:"issue"`
}

type StructuralIndexInfo struct {
	BucketExists bool           `json:"bucket_exists"`
	KeyCount     int            `json:"key_count"`
	KCore        *KCoreMetadata `json:"kcore,omitempty"`
	Pivot        *PivotMetadata `json:"pivot,omitempty"`
	SampleKeys   []string       `json:"sample_keys,omitempty"`
}

type SubscribeAck struct {
	Type       string   `json:"type"`       // Always "subscribe_ack"
	Subscribed []string `json:"subscribed"` // Message types now subscribed
	LogLevel   string   `json:"log_level"`  // Current log level filter
	Sources    []string `json:"sources"`    // Current source filters
}

type SubscribeCommand struct {
	Command      string   `json:"command"`
	MessageTypes []string `json:"message_types,omitempty"`
	LogLevel     string   `json:"log_level,omitempty"`
	Sources      []string `json:"sources,omitempty"`
}

type TraceResponse struct {
	TraceID string         `json:"trace_id"`
	Count   int            `json:"count"`
	Entries []MessageEntry `json:"entries"`
}

type Triple struct {
	Subject   string `json:"subject"`
	Predicate string `json:"predicate"`
	Object    any    `json:"object"`
}

type VirtualEdgeCounts struct {
	Total       int            // Total virtual edges found
	ByBand      map[string]int // Counts by similarity band (high, medium, related)
	AutoApplied int            // Edges that were auto-applied
}

type WaitOpts struct {
	Timeout      time.Duration // Max wait time (default 30s)
	PollInterval time.Duration // Check frequency (default 100ms)
	Comparator   string        // ">=", "==", ">", "<", "<=" (default ">=")
}

type WatchStatusStreamCondition func(envelopes []StatusStreamEnvelope) (satisfied bool, err error)

type WatchStatusStreamOpts struct {
	Timeout       time.Duration
	MessageTypes  []string      // Filter: flow_status, component_health, component_metrics, log_entry
	LogLevel      string        // Minimum: DEBUG, INFO, WARN, ERROR
	DrainDuration time.Duration // Continue collecting after condition met to capture burst
}

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

type WorkflowExecution struct {
	ID           string                 `json:"id"`
	WorkflowID   string                 `json:"workflow_id"`
	WorkflowName string                 `json:"workflow_name"`
	State        string                 `json:"state"`
	CurrentStep  int                    `json:"current_step"`
	CurrentName  string                 `json:"current_name"`
	Iteration    int                    `json:"iteration"`
	StepResults  map[string]StepResult  `json:"step_results,omitempty"`
	Error        string                 `json:"error,omitempty"`
	Trigger      map[string]interface{} `json:"trigger,omitempty"`
	CreatedAt    string                 `json:"created_at"`
	UpdatedAt    string                 `json:"updated_at"`
}