endpoints

Documentation

Index

• Constants
• type HTTPEndpoints
  • func NewHTTPEndpoints(volume volume.Volume, servicegroup servicegroup.ServiceGroup, ...) *HTTPEndpoints
  • func (h *HTTPEndpoints) CapacityInfo(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error)
  • func (h *HTTPEndpoints) ClusterCreate(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error)
  • func (h *HTTPEndpoints) ClusterHook(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error)
  • func (h *HTTPEndpoints) ClusterInfo(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error)
  • func (h *HTTPEndpoints) ComponentInfo(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error)
  • func (h *HTTPEndpoints) DeleteJobs(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error)
  • func (h *HTTPEndpoints) InstanceInfo(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error)
  • func (h *HTTPEndpoints) JobConcurrent(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error)
  • func (h *HTTPEndpoints) JobCreate(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error)
  • func (h *HTTPEndpoints) JobDelete(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error)
  • func (h *HTTPEndpoints) JobInspect(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error)
  • func (h *HTTPEndpoints) JobList(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error)
  • func (h *HTTPEndpoints) JobPipeline(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error)
  • func (h *HTTPEndpoints) JobStart(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error)
  • func (h *HTTPEndpoints) JobStop(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error)
  • func (h *HTTPEndpoints) JobVolumeCreate(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error)
  • func (h *HTTPEndpoints) LabelList(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error)
  • func (h *HTTPEndpoints) PodInfo(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error)
  • func (h *HTTPEndpoints) ResourceInfo(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error)
  • func (h *HTTPEndpoints) Routes() []httpserver.Endpoint
  • func (h *HTTPEndpoints) ServiceGroupCancel(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error)
  • func (h *HTTPEndpoints) ServiceGroupConfigUpdate(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error)
  • func (h *HTTPEndpoints) ServiceGroupCreate(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error)
  • func (h *HTTPEndpoints) ServiceGroupDelete(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error)
  • func (h *HTTPEndpoints) ServiceGroupInfo(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error)
  • func (h *HTTPEndpoints) ServiceGroupKillPod(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error)
  • func (h *HTTPEndpoints) ServiceGroupPrecheck(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error)
  • func (h *HTTPEndpoints) ServiceGroupRestart(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error)
  • func (h *HTTPEndpoints) ServiceGroupUpdate(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error)
  • func (h *HTTPEndpoints) ServiceInfo(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error)
  • func (h *HTTPEndpoints) ServiceScaling(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error)
  • func (h *HTTPEndpoints) SetNodeLabels(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error)
  • func (h *HTTPEndpoints) Terminal(w http.ResponseWriter, r *http.Request)
  • func (h *HTTPEndpoints) VolumeCreate(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error)
  • func (h *HTTPEndpoints) VolumeDelete(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error)
  • func (h *HTTPEndpoints) VolumeInfo(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error)

Constants

const (
	ENABLE_SPECIFIED_K8S_NAMESPACE = "ENABLE_SPECIFIED_K8S_NAMESPACE"
	RetainNamespace                = "RETAIN_NAMESPACE"
)

Types

type HTTPEndpoints

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

func NewHTTPEndpoints

func NewHTTPEndpoints(
	volume volume.Volume,
	servicegroup servicegroup.ServiceGroup,
	cluster cluster.Cluster,
	job job.Job,
	labelManager labelmanager.LabelManager,
	instanceinfo instanceinfo.InstanceInfo,
	clusterinfo clusterinfo.ClusterInfo,
	componentinfo instanceinfo.ComponentInfo,
	resourceinfo resourceinfo.ResourceInfo,
	cap cap.Cap) *HTTPEndpoints

func (*HTTPEndpoints) CapacityInfo

func (h *HTTPEndpoints) CapacityInfo(ctx context.Context, r *http.Request, vars map[string]string) (
	httpserver.Responser, error)

func (*HTTPEndpoints) ClusterCreate

func (h *HTTPEndpoints) ClusterCreate(ctx context.Context, r *http.Request, vars map[string]string) (
	httpserver.Responser, error)

func (*HTTPEndpoints) ClusterHook

func (h *HTTPEndpoints) ClusterHook(ctx context.Context, r *http.Request, vars map[string]string) (
	httpserver.Responser, error)

func (*HTTPEndpoints) ClusterInfo

func (h *HTTPEndpoints) ClusterInfo(ctx context.Context, r *http.Request, vars map[string]string) (
	httpserver.Responser, error)

ClusterInfo 获取集群信息

func (*HTTPEndpoints) ComponentInfo

func (h *HTTPEndpoints) ComponentInfo(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error)

func (*HTTPEndpoints) DeleteJobs

func (h *HTTPEndpoints) DeleteJobs(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error)

batch Delete Jobs will set retainNamespace is false so that the namespace will be deleted when the job count is zero

func (*HTTPEndpoints) InstanceInfo

func (h *HTTPEndpoints) InstanceInfo(ctx context.Context, r *http.Request, vars map[string]string) (
	httpserver.Responser, error)

func (*HTTPEndpoints) JobConcurrent

func (h *HTTPEndpoints) JobConcurrent(ctx context.Context, r *http.Request, vars map[string]string) (
	httpserver.Responser, error)

func (*HTTPEndpoints) JobCreate

func (h *HTTPEndpoints) JobCreate(ctx context.Context, r *http.Request, vars map[string]string) (
	httpserver.Responser, error)

func (*HTTPEndpoints) JobDelete

func (h *HTTPEndpoints) JobDelete(ctx context.Context, r *http.Request, vars map[string]string) (
	httpserver.Responser, error)

func (*HTTPEndpoints) JobInspect

func (h *HTTPEndpoints) JobInspect(ctx context.Context, r *http.Request, vars map[string]string) (
	httpserver.Responser, error)

func (*HTTPEndpoints) JobList

func (h *HTTPEndpoints) JobList(ctx context.Context, r *http.Request, vars map[string]string) (
	httpserver.Responser, error)

func (*HTTPEndpoints) JobPipeline

func (h *HTTPEndpoints) JobPipeline(ctx context.Context, r *http.Request, vars map[string]string) (
	httpserver.Responser, error)

func (*HTTPEndpoints) JobStart

func (h *HTTPEndpoints) JobStart(ctx context.Context, r *http.Request, vars map[string]string) (
	httpserver.Responser, error)

func (*HTTPEndpoints) JobStop

func (h *HTTPEndpoints) JobStop(ctx context.Context, r *http.Request, vars map[string]string) (
	httpserver.Responser, error)

func (*HTTPEndpoints) JobVolumeCreate

func (h *HTTPEndpoints) JobVolumeCreate(ctx context.Context, r *http.Request, vars map[string]string) (
	httpserver.Responser, error)

func (*HTTPEndpoints) LabelList

func (h *HTTPEndpoints) LabelList(ctx context.Context, r *http.Request, vars map[string]string) (
	httpserver.Responser, error)

func (*HTTPEndpoints) PodInfo

func (h *HTTPEndpoints) PodInfo(ctx context.Context, r *http.Request, vars map[string]string) (
	httpserver.Responser, error)

func (*HTTPEndpoints) ResourceInfo

func (h *HTTPEndpoints) ResourceInfo(ctx context.Context, r *http.Request, vars map[string]string) (
	httpserver.Responser, error)

func (*HTTPEndpoints) Routes

func (h *HTTPEndpoints) Routes() []httpserver.Endpoint

Routes scheduler TODO: Currently there are only servicegroup and volume APIs,，

There is also job API that needs to be migrated

func (*HTTPEndpoints) ServiceGroupCancel

func (h *HTTPEndpoints) ServiceGroupCancel(ctx context.Context, r *http.Request, vars map[string]string) (
	httpserver.Responser, error)

func (*HTTPEndpoints) ServiceGroupConfigUpdate

func (h *HTTPEndpoints) ServiceGroupConfigUpdate(ctx context.Context, r *http.Request, vars map[string]string) (
	httpserver.Responser, error)

func (*HTTPEndpoints) ServiceGroupCreate

func (h *HTTPEndpoints) ServiceGroupCreate(ctx context.Context, r *http.Request, vars map[string]string) (
	httpserver.Responser, error)

func (*HTTPEndpoints) ServiceGroupDelete

func (h *HTTPEndpoints) ServiceGroupDelete(ctx context.Context, r *http.Request, vars map[string]string) (
	httpserver.Responser, error)

func (*HTTPEndpoints) ServiceGroupInfo

func (h *HTTPEndpoints) ServiceGroupInfo(ctx context.Context, r *http.Request, vars map[string]string) (
	httpserver.Responser, error)

func (*HTTPEndpoints) ServiceGroupKillPod

func (h *HTTPEndpoints) ServiceGroupKillPod(ctx context.Context, r *http.Request, vars map[string]string) (
	httpserver.Responser, error)

func (*HTTPEndpoints) ServiceGroupPrecheck

func (h *HTTPEndpoints) ServiceGroupPrecheck(ctx context.Context, r *http.Request, vars map[string]string) (
	httpserver.Responser, error)

func (*HTTPEndpoints) ServiceGroupRestart

func (h *HTTPEndpoints) ServiceGroupRestart(ctx context.Context, r *http.Request, vars map[string]string) (
	httpserver.Responser, error)

func (*HTTPEndpoints) ServiceGroupUpdate

func (h *HTTPEndpoints) ServiceGroupUpdate(ctx context.Context, r *http.Request, vars map[string]string) (
	httpserver.Responser, error)

func (*HTTPEndpoints) ServiceInfo

func (h *HTTPEndpoints) ServiceInfo(ctx context.Context, r *http.Request, vars map[string]string) (
	httpserver.Responser, error)

func (*HTTPEndpoints) ServiceScaling

func (h *HTTPEndpoints) ServiceScaling(ctx context.Context, r *http.Request, vars map[string]string) (
	httpserver.Responser, error)

func (*HTTPEndpoints) SetNodeLabels

func (h *HTTPEndpoints) SetNodeLabels(ctx context.Context, r *http.Request, vars map[string]string) (
	httpserver.Responser, error)

{"force":false,"tag":"any,workspace-dev,workspace-test,workspace-staging,workspace-prod,job,service-stateful,org-terminus","hosts":["10.168.0.100"]}

func (*HTTPEndpoints) Terminal

func (h *HTTPEndpoints) Terminal(w http.ResponseWriter, r *http.Request)

func (*HTTPEndpoints) VolumeCreate

func (h *HTTPEndpoints) VolumeCreate(ctx context.Context, r *http.Request, vars map[string]string) (
	httpserver.Responser, error)

func (*HTTPEndpoints) VolumeDelete

func (h *HTTPEndpoints) VolumeDelete(ctx context.Context, r *http.Request, vars map[string]string) (
	httpserver.Responser, error)

func (*HTTPEndpoints) VolumeInfo

func (h *HTTPEndpoints) VolumeInfo(ctx context.Context, r *http.Request, vars map[string]string) (
	httpserver.Responser, error)