capability

type Agent struct {
	ID                   string         `json:"id"`
	Kind                 AgentKind      `json:"kind"`
	Version              string         `json:"version"`
	Status               AgentStatus    `json:"status"`
	Transport            TransportType  `json:"transport"`
	HeartbeatIntervalSec int            `json:"heartbeat_interval_sec"`
	Endpoint             *AgentEndpoint `json:"endpoint,omitempty"`
	Metadata             map[string]any `json:"metadata,omitempty"`
	Capabilities         []Capability   `json:"capabilities,omitempty"`
}

type AgentDescriptorBody struct {
	Agent Agent `json:"agent"`
}

type AgentEndpoint struct {
	Host string `json:"host,omitempty"`
	Port int    `json:"port,omitempty"`
}

type AgentKind string

type AgentOfflineBody struct {
	AgentID string `json:"agent_id"`
	Reason  string `json:"reason,omitempty"`
}

type AgentStatus string

type Bus interface {
	Publish(topic string, payload []byte, qos byte) error
	Subscribe(topic string, qos byte, handler func(topic string, payload []byte)) error
	IsConnected() bool
}

type Capability struct {
	ID           string             `json:"id"`
	AgentID      string             `json:"agent_id"`
	Description  string             `json:"description"`
	Category     CapabilityCategory `json:"category"`
	InputSchema  map[string]any     `json:"input_schema,omitempty"`
	OutputSchema map[string]any     `json:"output_schema,omitempty"`
	TimeoutSec   int                `json:"timeout_sec"`
	Permission   Permission         `json:"permission"`
	Metadata     map[string]any     `json:"metadata,omitempty"`
}

type CapabilityCategory string

type CapabilityDescriptorBody struct {
	Capabilities []Capability `json:"capabilities"`
}

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

type DiscoveryQuery struct {
	QueryType    string `json:"query_type"` // agent | capability | all
	AgentID      string `json:"agent_id,omitempty"`
	CapabilityID string `json:"capability_id,omitempty"`
	Category     string `json:"category,omitempty"`
	Keyword      string `json:"keyword,omitempty"`
}

type DiscoveryResponseBody struct {
	Agent        *Agent       `json:"agent,omitempty"`
	Capabilities []Capability `json:"capabilities,omitempty"`
}

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

type ErrorCounter struct {
	Code  string `json:"code"`
	Count int64  `json:"count"`
}

type Event struct {
	EventID       string         `json:"event_id"`
	EventType     string         `json:"event_type"`
	AgentID       string         `json:"agent_id"`
	DeviceID      string         `json:"device_id,omitempty"`
	PointID       string         `json:"point_id,omitempty"`
	Value         any            `json:"value,omitempty"`
	PreviousValue any            `json:"previous_value,omitempty"`
	Timestamp     int64          `json:"timestamp"`
	Severity      EventSeverity  `json:"severity"`
	Metadata      map[string]any `json:"metadata,omitempty"`
}

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

type EventSeverity string

type Handler func(ctx context.Context, req InvokeRequest, cap Capability) (any, error)

type HeartbeatBody struct {
	AgentID   string      `json:"agent_id"`
	Status    AgentStatus `json:"status"`
	Timestamp int64       `json:"timestamp"`
	Sequence  int64       `json:"sequence"`
}

type InvokeMetrics struct {
	TotalInvokes  int64 `json:"total_invokes"`
	SuccessCount  int64 `json:"success_count"`
	FailedCount   int64 `json:"failed_count"`
	TimeoutCount  int64 `json:"timeout_count"`
	RejectedCount int64 `json:"rejected_count"`

	// 延迟统计（毫秒）| Latency statistics in milliseconds
	TotalLatencyMs int64 `json:"total_latency_ms"`
	MinLatencyMs   int64 `json:"min_latency_ms"`
	MaxLatencyMs   int64 `json:"max_latency_ms"`
}

type InvokeMetricsSnapshot struct {
	TotalInvokes  int64          `json:"total_invokes"`
	SuccessCount  int64          `json:"success_count"`
	FailedCount   int64          `json:"failed_count"`
	TimeoutCount  int64          `json:"timeout_count"`
	RejectedCount int64          `json:"rejected_count"`
	SuccessRate   float64        `json:"success_rate"`
	AvgLatencyMs  float64        `json:"avg_latency_ms"`
	P50LatencyMs  int64          `json:"p50_latency_ms"`
	P99LatencyMs  int64          `json:"p99_latency_ms"`
	MinLatencyMs  int64          `json:"min_latency_ms"`
	MaxLatencyMs  int64          `json:"max_latency_ms"`
	TopErrors     []ErrorCounter `json:"top_errors,omitempty"`
}

type InvokeOptions struct {
	TimeoutSec int    `json:"timeout_sec,omitempty"`
	Priority   string `json:"priority,omitempty"`
	Retry      int    `json:"retry,omitempty"`
	Async      bool   `json:"async,omitempty"`
}

type InvokeRequest struct {
	InvokeID   string         `json:"invoke_id"`
	Target     string         `json:"target"`
	Capability string         `json:"capability"`
	Arguments  map[string]any `json:"arguments,omitempty"`
	Options    InvokeOptions  `json:"options,omitempty"`
}

type InvokeResponse struct {
	InvokeID  string       `json:"invoke_id"`
	Status    InvokeStatus `json:"status"`
	Result    InvokeResult `json:"result"`
	LatencyMs int64        `json:"latency_ms,omitempty"`
}

type InvokeResult struct {
	Success   bool           `json:"success"`
	Values    any            `json:"values,omitempty"`
	Timestamp int64          `json:"timestamp,omitempty"`
	Error     string         `json:"error,omitempty"`
	ErrorCode string         `json:"error_code,omitempty"`
	Metadata  map[string]any `json:"metadata,omitempty"`
}

type InvokeStatus string

type InvokeStatusQuery struct {
	InvokeID string `json:"invoke_id"`
}

type Mapper interface {
	MapAndExecute(ctx context.Context, req InvokeRequest, cap Capability) (any, error)
}

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

type Message struct {
	Header MessageHeader `json:"header"`
	Body   any           `json:"body"`
}

type MessageHeader struct {
	MessageID     string `json:"message_id"`
	Timestamp     int64  `json:"timestamp"`
	Source        string `json:"source"`
	Destination   string `json:"destination,omitempty"`
	MessageType   string `json:"message_type"`
	Version       string `json:"version"`
	CorrelationID string `json:"correlation_id,omitempty"`
	RequestID     string `json:"request_id,omitempty"`
}

type NoopBus struct{}

type Permission string

type PublishedMessage struct {
	Topic   string
	Payload []byte
	QoS     byte
}

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

type RegistrySnapshot struct {
	AgentID           string   `json:"agent_id"`
	LastSeen          int64    `json:"last_seen"`
	CapabilitiesCount int      `json:"capabilities_count"`
	Capabilities      []string `json:"capabilities"`
	Status            string   `json:"status"`
	Version           string   `json:"version"`
}

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

type RuntimeConfig struct {
	AgentID              string
	AgentVersion         string
	Transport            TransportType
	HeartbeatIntervalSec int
	Protocols            []string // driver protocols to auto-register; empty = KnownDriverProtocols
	Metadata             map[string]any
	Endpoint             *AgentEndpoint
	// Unified generates 7 consolidated capabilities instead of 63 protocol-specific ones.
	// Used by MCP Runtime to reduce LLM tool count. Northbound EAN Runtime uses false (default).
	Unified bool
}

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

type ShadowPointView struct {
	Value         any
	PreviousValue any
	Quality       string
	TimestampMs   int64
}

type TransportType string

type V1Compat struct{}