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
- type GetQueueResponse
- type ListQueueRequest
- type ListQueueResponse
- type UpdateQueueRequest
- type UpdateQueueResponse
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func DeleteQueue ¶
func DeleteQueue(ctx *logger.RequestContext, queueName string) error
func InitDefaultQueue ¶ added in v0.14.3
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 ¶
func GetQueueByName ¶
func GetQueueByName(ctx *logger.RequestContext, queueName string) (GetQueueResponse, error)
type ListQueueRequest ¶
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 ¶
func UpdateQueue ¶
func UpdateQueue(ctx *logger.RequestContext, request *UpdateQueueRequest) (UpdateQueueResponse, error)
Click to show internal directories.
Click to hide internal directories.