server

type CreateWorkerRequest struct {
	ID          string            `json:"id"`
	Name        string            `json:"name"`
	Labels      map[string]string `json:"labels"`
	Annotations map[string]string `json:"annotations"`
	EnvType     string            `json:"env_type"`
	Image       string            `json:"image"`
	Command     []string          `json:"command"`
	Args        []string          `json:"args"`
	Env         map[string]string `json:"env"`
	WorkingDir  string            `json:"working_dir"`
}

type GetWorkerInfoRequest struct {
	WorkerID string `json:"worker_id" binding:"required"`
}

type ListWorkersResponse struct {
	Workers []WorkerInfo `json:"workers"`
	Total   int          `json:"total"`
}

type ShutdownWorkerRequest struct {
	WorkerID string `json:"worker_id" binding:"required"`
}

type WorkerConnection struct {
	ID         string
	Conn       *websocket.Conn
	Send       chan *wsproto.WSMessage
	Status     string
	Registered time.Time
	LastSeen   time.Time
	// contains filtered or unexported fields
}

type WorkerInfo struct {
	ID         string    `json:"id"`
	Status     string    `json:"status"`
	Registered time.Time `json:"registered"`
	LastSeen   time.Time `json:"last_seen"`
}

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