queue

package
v0.14.6 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 23, 2023 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Index

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"`
}

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
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL