mcp

type AgentLister interface {
	List(ctx context.Context, statusFilter string) ([]*agent.Agent, error)
}

type K8sReader interface {
	ListNamespaces(ctx context.Context, agentID string) ([]string, error)
	ListWorkloads(ctx context.Context, agentID string, namespaces []string) ([]kubernetes.K8sWorkloadGroup, error)
	ListPods(ctx context.Context, agentID string, namespaces []string, filters kubernetes.PodFilters) ([]kubernetes.K8sPod, error)
	ListNodes(ctx context.Context, agentID string) ([]kubernetes.K8sNode, error)
}

type LogFetcher interface {
	FetchLogs(ctx context.Context, externalID string, lines int, timestamps bool) ([]string, error)
}

type Services struct {
	Containers    *container.Service
	Endpoints     *endpoint.Service
	Heartbeats    *heartbeat.Service
	Certificates  *certificate.Service
	Resources     *resource.Service
	Alerts        alert.AlertStore
	Channels      alert.ChannelStore
	Triggers      alert.TriggerStore
	Escalator     alert.Escalator
	Updates       *update.Service
	Incidents     status.IncidentStore
	Maintenance   status.MaintenanceStore
	Runtime       runtime.Runtime
	LogFetcher    LogFetcher
	EscalationSvc *escalation.Service
	Agents        AgentLister
	Sessions      SessionChecker

	// Security & supply-chain (read-only MCP surface).
	SecuritySvc *security.Service
	Scorer      *security.Scorer
	UpdateStore update.UpdateStore

	// Orchestrators (read-only MCP surface).
	Kubernetes     K8sReader
	SwarmCluster   func() *swarm.SwarmCluster
	SwarmDiscovery func() *swarm.ServiceDiscovery
	SwarmTopology  SwarmTopologyReader
	SwarmNodes     SwarmNodeReader

	Version string
	Logger  *slog.Logger
}

type SessionChecker interface {
	IsConnected(agentID string) bool
}

type SwarmNodeReader interface {
	ListNodes(ctx context.Context, agentID string) ([]*swarm.SwarmNode, error)
}

type SwarmTopologyReader interface {
	ListServices(ctx context.Context, agentID string) ([]*swarm.SwarmService, error)
	ListTasks(ctx context.Context, agentID, serviceID string) ([]*swarm.SwarmTask, error)
}