Documentation
¶
Index ¶
- type CreatePodRequest
- type CreateServiceRequest
- type CreateTaskRequest
- type RegisterNodeRequest
- type Server
- func (s *Server) CreatePod(c echo.Context) error
- func (s *Server) CreateService(c echo.Context) error
- func (s *Server) CreateTask(c echo.Context) error
- func (s *Server) DeletePod(c echo.Context) error
- func (s *Server) DeleteService(c echo.Context) error
- func (s *Server) GetEndpoints(c echo.Context) error
- func (s *Server) GetPod(c echo.Context) error
- func (s *Server) GetPodLogs(c echo.Context) error
- func (s *Server) GetService(c echo.Context) error
- func (s *Server) GetTask(c echo.Context) error
- func (s *Server) GetTaskLogs(c echo.Context) error
- func (s *Server) ListNodes(c echo.Context) error
- func (s *Server) ListPods(c echo.Context) error
- func (s *Server) ListServices(c echo.Context) error
- func (s *Server) ListTasks(c echo.Context) error
- func (s *Server) NodeDeregister(c echo.Context) error
- func (s *Server) NodeHeartbeat(c echo.Context) error
- func (s *Server) Prune(c echo.Context) error
- func (s *Server) RegisterNode(c echo.Context) error
- func (s *Server) RegisterRoutes(e *echo.Echo)
- func (s *Server) StartNodeExpirationChecker(ctx context.Context)
- func (s *Server) StreamPodLogs(c echo.Context) error
- func (s *Server) StreamTaskLogs(c echo.Context) error
- func (s *Server) UpdatePodStatus(c echo.Context) error
- func (s *Server) UpdateService(c echo.Context) error
- func (s *Server) UpdateTaskStatus(c echo.Context) error
- type UpdatePodStatusRequest
- type UpdateServiceRequest
- type UpdateTaskStatusRequest
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CreatePodRequest ¶
type CreatePodRequest struct {
Name string `json:"name" validate:"required"`
Namespace string `json:"namespace,omitempty"`
Labels map[string]string `json:"labels,omitempty"`
Annotations map[string]string `json:"annotations,omitempty"`
Containers []types.Container `json:"containers" validate:"required,min=1"`
RestartPolicy types.RestartPolicy `json:"restartPolicy,omitempty"`
}
type CreateServiceRequest ¶
type CreateServiceRequest struct {
Name string `json:"name" validate:"required"`
Namespace string `json:"namespace"`
Type types.ServiceType `json:"type"`
Selector map[string]string `json:"selector" validate:"required"`
Ports []types.ServicePort `json:"ports" validate:"required"`
Labels map[string]string `json:"labels"`
Annotations map[string]string `json:"annotations"`
SessionAffinity string `json:"sessionAffinity"`
}
type CreateTaskRequest ¶
type CreateTaskRequest struct {
Name string `json:"name" validate:"required"`
Image string `json:"image" validate:"required"`
Env map[string]string `json:"env"`
LivenessProbe *types.HealthCheck `json:"livenessProbe,omitempty"`
ReadinessProbe *types.HealthCheck `json:"readinessProbe,omitempty"`
RestartPolicy types.RestartPolicy `json:"restartPolicy,omitempty"`
Ports []types.ContainerPort `json:"ports,omitempty"`
}
type RegisterNodeRequest ¶
type Server ¶
type Server struct {
// contains filtered or unexported fields
}
func NewServer ¶
func NewServer( store state.StateStore, sched scheduler.Scheduler, endpointController *services.EndpointController, ) *Server
func (*Server) RegisterRoutes ¶
func (*Server) StartNodeExpirationChecker ¶
type UpdatePodStatusRequest ¶
type UpdateServiceRequest ¶
type UpdateTaskStatusRequest ¶
type UpdateTaskStatusRequest struct {
Status types.TaskStatus `json:"status" validate:"required"`
ContainerID string `json:"containerId"`
Error string `json:"error"`
HealthStatus types.HealthStatus `json:"healthStatus,omitempty"`
}
Click to show internal directories.
Click to hide internal directories.