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) 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) 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) 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) 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) LabelList(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) 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) SetNodeLabels(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error)
  • func (h *HTTPEndpoints) Terminal(ctx context.Context, w http.ResponseWriter, r *http.Request, ...) error

Constants

const (
	RetainNamespace = "RETAIN_NAMESPACE"
)

Types

type HTTPEndpoints

type HTTPEndpoints struct {
	ServiceGroupImpl servicegroup.ServiceGroup

	Job job.Job

	ClusterinfoImpl clusterinfo.ClusterInfo

	Cap cap.Cap
	// 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,
	clusterSvc clusterpb.ClusterServiceServer) *HTTPEndpoints

func (*HTTPEndpoints) CapacityInfo

func (h *HTTPEndpoints) CapacityInfo(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) 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) 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) 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) LabelList

func (h *HTTPEndpoints) LabelList(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) 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) 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(ctx context.Context, w http.ResponseWriter, r *http.Request, vars map[string]string) error