queues

Documentation

Index

• type ListQueuePropertyOpts
• type Property
• type PropertyResp
  • func ExtractProperties(r pagination.Page) ([]PropertyResp, error)
  • func ListQueueProperty(c *golangsdk.ServiceClient, opts ListQueuePropertyOpts) ([]PropertyResp, error)
• type QueuePropertyPage
• type QueuePropertyResp
  • func DeleteQueueProperties(c *golangsdk.ServiceClient, queueName string, opts []string) (*QueuePropertyResp, error)
  • func UpdateQueueProperty(c *golangsdk.ServiceClient, queueName string, opts Property) (*QueuePropertyResp, error)

Types

type ListQueuePropertyOpts

type ListQueuePropertyOpts struct {
	// The queue name.
	QueueName string `json:"-" required:"true"`
	// The offset number.
	Offset int `q:"offset"`
	// Number of records to be queried.
	Limit int `q:"limit"`
}

ListQueuePropertyOpts is the structure that used to query the list of the queue properties.

type Property

type Property struct {
	// Maximum number of Spark drivers can be started on this queue.
	MaxInstance int `json:"computeEngine.maxInstance,omitempty"`
	// Maximum number of tasks can be concurrently executed by a Spark driver.
	MaxConcurrent int `json:"job.maxConcurrent,omitempty"`
	// Maximum number of Spark drivers can be pre-started on this queue.
	MaxPrefetchInstance *int `json:"computeEngine.maxPrefetchInstance,omitempty"`
	// The cidr of the queue.
	Cidr string `json:"network.cidrInVpc,omitempty"`
}

Property is the structure that used to update the property of the queue.

type PropertyResp

type PropertyResp struct {
	// The valid values are as follows:
	// + computeEngine.maxInstances: Maximum number of Spark drivers can be started on this queue.
	// + computeEngine.maxPrefetchInstan: Maximum number of Spark drivers can be pre-started on this queue.
	// + job.maxConcurrent: Maximum number of tasks can be concurrently executed by a Spark driver.
	// + multipleSc.support: Whether multiple spark drivers can be configured.
	Key   string `json:"key"`
	Value string `json:"value"`
}

PropertyResp is the structure that represents property detail of the queue.

func ExtractProperties

func ExtractProperties(r pagination.Page) ([]PropertyResp, error)

ExtractProperties is a method to extract the list of properties.

func ListQueueProperty

func ListQueueProperty(c *golangsdk.ServiceClient, opts ListQueuePropertyOpts) ([]PropertyResp, error)

ListQueueProperty is the method that used to query list of the queue properties using given parameters.

type QueuePropertyPage

type QueuePropertyPage struct {
	pagination.OffsetPageBase
}

QueuePropertyPage is a single page maximum result representing a query by offset page.

type QueuePropertyResp

type QueuePropertyResp struct {
	// Whether the request is successfully executed. Value true indicates that the request is successfully executed.
	IsSuccess bool `json:"is_success"`
	// System prompt. If execution succeeds, the parameter setting may be left blank.
	Message string `json:"message"`
}

QueuePropertyResp is the structure that represents response of UpdateQueueProperty or DeleteQueueProperties method.

func DeleteQueueProperties

func DeleteQueueProperties(c *golangsdk.ServiceClient, queueName string, opts []string) (*QueuePropertyResp, error)

DeleteQueueProperties is the method that used to delete properties of the queue.

func UpdateQueueProperty

func UpdateQueueProperty(c *golangsdk.ServiceClient, queueName string, opts Property) (*QueuePropertyResp, error)

UpdateQueueProperty is the method that used to update property of the queue using given parameters.