server

type CreateWorkerRequest struct {
	ID             string            `json:"id"`
	OrgID          uint              `json:"org_id"`
	WorkerID       uint              `json:"worker_id"`
	Name           string            `json:"name"`
	Labels         map[string]string `json:"labels"`
	Annotations    map[string]string `json:"annotations"`
	ServerAddr     string            `json:"server_addr"`
	BootstrapToken string            `json:"bootstrap_token"`
	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
}