queue

Documentation

Index

• func DeleteQueue(ctx *logger.RequestContext, queueName string) error
• func InitDefaultQueue() error
• func IsLastQueuePk(ctx *logger.RequestContext, pk int64) bool
• type CreateQueueRequest
• type CreateQueueResponse
  • func CreateQueue(ctx *logger.RequestContext, request *CreateQueueRequest) (CreateQueueResponse, error)
• type GetQueueResponse
  • func GetQueueByName(ctx *logger.RequestContext, queueName string) (GetQueueResponse, error)
• type ListQueueRequest
• type ListQueueResponse
  • func ListQueue(ctx *logger.RequestContext, marker string, maxKeys int, name string) (ListQueueResponse, error)
• type UpdateQueueRequest
• type UpdateQueueResponse
  • func UpdateQueue(ctx *logger.RequestContext, request *UpdateQueueRequest) (UpdateQueueResponse, error)

Functions

func DeleteQueue

func DeleteQueue(ctx *logger.RequestContext, queueName string) error

func InitDefaultQueue

func InitDefaultQueue() error

InitDefaultQueue init default queue for single cluster environment

func IsLastQueuePk

func IsLastQueuePk(ctx *logger.RequestContext, pk int64) bool

Types

type CreateQueueRequest

type CreateQueueRequest struct {
	Name         string              `json:"name"`
	Namespace    string              `json:"namespace"`
	ClusterName  string              `json:"clusterName"`
	QuotaType    string              `json:"quotaType"`
	MaxResources schema.ResourceInfo `json:"maxResources"`
	MinResources schema.ResourceInfo `json:"minResources"`
	Location     map[string]string   `json:"location"`
	// 任务调度策略
	SchedulingPolicy []string `json:"schedulingPolicy,omitempty"`
	Status           string   `json:"-"`
}

type CreateQueueResponse

type CreateQueueResponse struct {
	QueueName string `json:"name"`
}

func CreateQueue

func CreateQueue(ctx *logger.RequestContext, request *CreateQueueRequest) (CreateQueueResponse, error)

type GetQueueResponse

type GetQueueResponse struct {
	model.Queue
}

func GetQueueByName

func GetQueueByName(ctx *logger.RequestContext, queueName string) (GetQueueResponse, error)

type ListQueueRequest

type ListQueueRequest struct {
	Marker    string
	MaxKeys   int
	QueueName string
}

type ListQueueResponse

type ListQueueResponse struct {
	common.MarkerInfo
	QueueList []model.Queue `json:"queueList"`
}

func ListQueue

func ListQueue(ctx *logger.RequestContext, marker string, maxKeys int, name string) (ListQueueResponse, error)

type UpdateQueueRequest

type UpdateQueueRequest struct {
	Name         string              `json:"-"`
	Namespace    string              `json:"-"`
	ClusterName  string              `json:"-"`
	QuotaType    string              `json:"-"`
	MaxResources schema.ResourceInfo `json:"maxResources,omitempty"`
	MinResources schema.ResourceInfo `json:"minResources,omitempty"`
	Location     map[string]string   `json:"location,omitempty"`
	// 任务调度策略
	SchedulingPolicy []string `json:"schedulingPolicy,omitempty"`
	Status           string   `json:"-"`
}

type UpdateQueueResponse

type UpdateQueueResponse struct {
	model.Queue
}

func UpdateQueue

func UpdateQueue(ctx *logger.RequestContext, request *UpdateQueueRequest) (UpdateQueueResponse, error)