swarm

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

type DetectionResult struct {
	Active    bool   `json:"active"`
	IsManager bool   `json:"is_manager"`
	ClusterID string `json:"cluster_id,omitempty"`
}

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

type EventCallback func(eventType string, data interface{})

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

type InfoProvider interface {
	Info(ctx context.Context) (system.Info, error)
}

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

type NetworkAttachment struct {
	NetworkID   string `json:"network_id"`
	NetworkName string `json:"network_name"`
	Scope       string `json:"scope"` // "swarm", "local"
}

type NetworkResolver func(ctx context.Context, networkID string) (name, scope string, err error)

type NodeAlertCallback func(evt alert.Event)

type NodeReconciler interface {
	ReplaceNodesForAgent(ctx context.Context, agentID string, nodes []*SwarmNode) error
}

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

type NodeStore interface {
	UpsertNode(ctx context.Context, node *SwarmNode) error
	ListNodes(ctx context.Context, agentID string) ([]*SwarmNode, error)
	GetNodeByNodeID(ctx context.Context, nodeID string) (*SwarmNode, error)
	UpdateNodeStatus(ctx context.Context, nodeID, status, availability string) error
	UpdateNodeTaskCount(ctx context.Context, nodeID string, count int) error
}

type PortConfig struct {
	Protocol      string `json:"protocol"`       // "tcp", "udp", "sctp"
	TargetPort    uint32 `json:"target_port"`    // container port
	PublishedPort uint32 `json:"published_port"` // host/ingress port
	PublishMode   string `json:"publish_mode"`   // "ingress" or "host"
}

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

type ServiceClient interface {
	ServiceList(ctx context.Context) ([]swarm.Service, error)
	ServiceInspect(ctx context.Context, serviceID string) (swarm.Service, error)
	TaskList(ctx context.Context) ([]swarm.Task, error)
	NodeList(ctx context.Context) ([]swarm.Node, error)
}

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

type ServiceTaskStore interface {
	ReplaceServicesForAgent(ctx context.Context, agentID string, services []SwarmService) error
	ReplaceTasksForAgent(ctx context.Context, agentID string, tasks []SwarmTask) error
}

type SwarmCluster struct {
	ID           string    `json:"cluster_id"`
	CreatedAt    time.Time `json:"created_at"`
	ManagerCount int       `json:"manager_count"`
	WorkerCount  int       `json:"worker_count"`
	IsManager    bool      `json:"is_manager"`
}

type SwarmNode struct {
	ID                 string    `json:"id"`
	AgentID            string    `json:"agent_id"`
	NodeID             string    `json:"node_id"`
	Hostname           string    `json:"hostname"`
	Role               string    `json:"role"`         // "manager" or "worker"
	Status             string    `json:"status"`       // "ready", "down", "disconnected", "unknown"
	Availability       string    `json:"availability"` // "active", "pause", "drain"
	EngineVersion      string    `json:"engine_version,omitempty"`
	Address            string    `json:"address,omitempty"`
	TaskCount          int       `json:"task_count"`
	FirstSeenAt        time.Time `json:"first_seen_at"`
	LastSeenAt         time.Time `json:"last_seen_at"`
	LastStatusChangeAt time.Time `json:"last_status_change_at"`
}

type SwarmService struct {
	ServiceID       string              `json:"service_id"`
	AgentID         string              `json:"agent_id,omitempty"`
	Name            string              `json:"name"`
	Image           string              `json:"image"`
	Mode            string              `json:"mode"` // "replicated" or "global"
	DesiredReplicas int                 `json:"desired_replicas"`
	RunningReplicas int                 `json:"running_replicas"`
	Labels          map[string]string   `json:"labels,omitempty"`
	StackName       string              `json:"stack_name,omitempty"`
	Networks        []NetworkAttachment `json:"networks,omitempty"`
	Ports           []PortConfig        `json:"ports,omitempty"`
	UpdateStatus    *UpdateStatus       `json:"update_status,omitempty"`
	CreatedAt       time.Time           `json:"created_at"`
}

type SwarmTask struct {
	TaskID       string    `json:"task_id"`
	AgentID      string    `json:"agent_id,omitempty"`
	ServiceID    string    `json:"service_id"`
	NodeID       string    `json:"node_id"`
	Slot         int       `json:"slot"`
	State        string    `json:"state"`
	DesiredState string    `json:"desired_state"`
	ContainerID  string    `json:"container_id"`
	Error        string    `json:"error,omitempty"`
	ExitCode     *int      `json:"exit_code,omitempty"`
	Timestamp    time.Time `json:"timestamp"`
	NodeHostname string    `json:"node_hostname,omitempty"`
}

type TaskPlacement struct {
	ServiceID   string                 `json:"service_id"`
	ServiceName string                 `json:"service_name"`
	ByNode      map[string][]SwarmTask `json:"by_node"` // keyed by node ID
}

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

type TopologySnapshot struct {
	Services []SwarmService
	Tasks    []SwarmTask
	Nodes    []SwarmNode
}

type UpdateProgress struct {
	ServiceID    string     `json:"service_id"`
	ServiceName  string     `json:"service_name"`
	State        string     `json:"state"`
	OldImage     string     `json:"old_image"`
	NewImage     string     `json:"new_image"`
	TasksUpdated int        `json:"tasks_updated"`
	TasksTotal   int        `json:"tasks_total"`
	Message      string     `json:"message"`
	StartedAt    *time.Time `json:"started_at,omitempty"`
	CompletedAt  *time.Time `json:"completed_at,omitempty"`
}

type UpdateStatus struct {
	State       string     `json:"state"` // "updating", "paused", "completed", "rollback_started", "rollback_completed", "rollback_paused"
	StartedAt   *time.Time `json:"started_at,omitempty"`
	CompletedAt *time.Time `json:"completed_at,omitempty"`
	Message     string     `json:"message,omitempty"`
}

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