scheduler

type AgentClient interface {
	Deploy(ctx context.Context, nodeID string, deployment *models.Deployment) error
	Stop(ctx context.Context, nodeID string, deploymentID string) error
}

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

type CommandSender interface {
	SendCommand(ctx context.Context, nodeID string, cmd *pb.DeploymentCommand) error
}

type ContainerManager interface {
	// StartContainer starts a new container with the given name and deployment config.
	StartContainer(ctx context.Context, nodeID, containerName string, deployment *models.Deployment) error
	// StopContainer stops a container by name.
	StopContainer(ctx context.Context, nodeID, containerName string) error
	// CheckHealth checks if a container is healthy.
	CheckHealth(ctx context.Context, nodeID, containerName string, healthCheck *models.HealthCheckConfig) (bool, error)
}

type EnvMergerInterface interface {
	MergeForDeployment(ctx context.Context, appID, serviceName string, serviceEnvVars map[string]string) (map[string]string, error)
}

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

type GRPCAgentClientConfig struct {
	// CommandTimeout is the deadline for command acknowledgment (default: 10s)
	CommandTimeout time.Duration
	// MaxRetries is the maximum number of retry attempts (default: 3)
	MaxRetries int
}

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

type NodeHealthInfo struct {
	ID            string
	Healthy       bool
	LastHeartbeat time.Time
}

type ResourceAvailability struct {
	CPUAvailable    float64
	MemoryAvailable int64
}

type ResourceRequirements struct {
	CPU    float64 // CPU cores required
	Memory int64   // Memory in bytes required
}

type RollbackResult struct {
	NewDeployment    *models.Deployment `json:"new_deployment"`
	SourceDeployment *models.Deployment `json:"source_deployment"`
	Success          bool               `json:"success"`
	Message          string             `json:"message,omitempty"`
}

type RoutingConfig struct {
	ServiceName   string `json:"service_name"`
	ContainerName string `json:"container_name"`
	Port          int    `json:"port"`
	Domain        string `json:"domain,omitempty"`
}

type RoutingUpdater interface {
	// UpdateRouting updates the routing configuration to point to the new container.
	// It returns the old container name that was previously routed to.
	UpdateRouting(ctx context.Context, serviceName, newContainerName string, port int) (oldContainerName string, err error)
}

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

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

type ZeroDowntimeDeployerConfig struct {
	// HealthTimeout is the maximum time to wait for health checks to pass.
	HealthTimeout time.Duration
	// HealthInterval is the interval between health check attempts.
	HealthInterval time.Duration
}