queue

package
v1.0.3 Latest Latest
Warning

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

 Go to latest Published: Mar 17, 2026 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_queue_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type CreateQueueRequest 

type CreateQueueRequest struct {
	RegionId    string               `protobuf:"bytes,1,opt,name=regionId,proto3" header:"regionId" json:"regionId,omitempty"`
	ClusterId   string               `protobuf:"bytes,2,opt,name=clusterId,proto3" form:"clusterId" json:"clusterId,omitempty"`
	Name        string               `protobuf:"bytes,3,opt,name=name,proto3" form:"name" json:"name,omitempty"`
	Priority    int32                `protobuf:"varint,4,opt,name=priority,proto3" form:"priority" json:"priority,omitempty"`
	Capability  []*QueueCapability   `protobuf:"bytes,5,rep,name=capability,proto3" form:"capability" json:"capability,omitempty"`
	Annotations []*common.Annotation `protobuf:"bytes,6,rep,name=annotations,proto3" form:"annotations" json:"annotations,omitempty"`
	Labels      []*common.Label      `protobuf:"bytes,7,rep,name=labels,proto3" form:"labels" json:"labels,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateQueueRequest) Descriptor deprecated 

func (*CreateQueueRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreateQueueRequest.ProtoReflect.Descriptor instead.

func (*CreateQueueRequest) GetAnnotations 

func (x *CreateQueueRequest) GetAnnotations() []*common.Annotation

func (*CreateQueueRequest) GetCapability 

func (x *CreateQueueRequest) GetCapability() []*QueueCapability

func (*CreateQueueRequest) GetClusterId 

func (x *CreateQueueRequest) GetClusterId() string

func (*CreateQueueRequest) GetLabels 

func (x *CreateQueueRequest) GetLabels() []*common.Label

func (*CreateQueueRequest) GetName 

func (x *CreateQueueRequest) GetName() string

func (*CreateQueueRequest) GetPriority 

func (x *CreateQueueRequest) GetPriority() int32

func (*CreateQueueRequest) GetRegionId 

func (x *CreateQueueRequest) GetRegionId() string

func (*CreateQueueRequest) ProtoMessage 

func (*CreateQueueRequest) ProtoMessage()

func (*CreateQueueRequest) ProtoReflect 

func (x *CreateQueueRequest) ProtoReflect() protoreflect.Message

func (*CreateQueueRequest) Reset 

func (x *CreateQueueRequest) Reset()

func (*CreateQueueRequest) String 

func (x *CreateQueueRequest) String() string

type CreateQueueResponse 

type CreateQueueResponse struct {
	RequestId string `protobuf:"bytes,1,opt,name=requestId,proto3" form:"requestId" json:"requestId,omitempty" query:"requestId"`
	QueueId   string `protobuf:"bytes,2,opt,name=queueId,proto3" form:"queueId" json:"queueId,omitempty" query:"queueId"`
	// contains filtered or unexported fields
}

func (*CreateQueueResponse) Descriptor deprecated 

func (*CreateQueueResponse) Descriptor() ([]byte, []int)

Deprecated: Use CreateQueueResponse.ProtoReflect.Descriptor instead.

func (*CreateQueueResponse) GetQueueId 

func (x *CreateQueueResponse) GetQueueId() string

func (*CreateQueueResponse) GetRequestId 

func (x *CreateQueueResponse) GetRequestId() string

func (*CreateQueueResponse) ProtoMessage 

func (*CreateQueueResponse) ProtoMessage()

func (*CreateQueueResponse) ProtoReflect 

func (x *CreateQueueResponse) ProtoReflect() protoreflect.Message

func (*CreateQueueResponse) Reset 

func (x *CreateQueueResponse) Reset()

func (*CreateQueueResponse) String 

func (x *CreateQueueResponse) String() string

type DeleteQueueRequest 

type DeleteQueueRequest struct {
	RegionId string `protobuf:"bytes,1,opt,name=regionId,proto3" header:"regionId" json:"regionId,omitempty"`
	QueueId  string `protobuf:"bytes,2,opt,name=queueId,proto3" json:"queueId,omitempty" path:"queueId"`
	// contains filtered or unexported fields
}

func (*DeleteQueueRequest) Descriptor deprecated 

func (*DeleteQueueRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteQueueRequest.ProtoReflect.Descriptor instead.

func (*DeleteQueueRequest) GetQueueId 

func (x *DeleteQueueRequest) GetQueueId() string

func (*DeleteQueueRequest) GetRegionId 

func (x *DeleteQueueRequest) GetRegionId() string

func (*DeleteQueueRequest) ProtoMessage 

func (*DeleteQueueRequest) ProtoMessage()

func (*DeleteQueueRequest) ProtoReflect 

func (x *DeleteQueueRequest) ProtoReflect() protoreflect.Message

func (*DeleteQueueRequest) Reset 

func (x *DeleteQueueRequest) Reset()

func (*DeleteQueueRequest) String 

func (x *DeleteQueueRequest) String() string

type DeleteQueueResponse 

type DeleteQueueResponse struct {
	RequestId string `protobuf:"bytes,1,opt,name=requestId,proto3" form:"requestId" json:"requestId,omitempty" query:"requestId"`
	QueueId   string `protobuf:"bytes,2,opt,name=queueId,proto3" form:"queueId" json:"queueId,omitempty" query:"queueId"`
	// contains filtered or unexported fields
}

func (*DeleteQueueResponse) Descriptor deprecated 

func (*DeleteQueueResponse) Descriptor() ([]byte, []int)

Deprecated: Use DeleteQueueResponse.ProtoReflect.Descriptor instead.

func (*DeleteQueueResponse) GetQueueId 

func (x *DeleteQueueResponse) GetQueueId() string

func (*DeleteQueueResponse) GetRequestId 

func (x *DeleteQueueResponse) GetRequestId() string

func (*DeleteQueueResponse) ProtoMessage 

func (*DeleteQueueResponse) ProtoMessage()

func (*DeleteQueueResponse) ProtoReflect 

func (x *DeleteQueueResponse) ProtoReflect() protoreflect.Message

func (*DeleteQueueResponse) Reset 

func (x *DeleteQueueResponse) Reset()

func (*DeleteQueueResponse) String 

func (x *DeleteQueueResponse) String() string

type GetQueueRequest 

type GetQueueRequest struct {
	RegionId string `protobuf:"bytes,1,opt,name=regionId,proto3" header:"regionId" json:"regionId,omitempty"`
	QueueId  string `protobuf:"bytes,2,opt,name=queueId,proto3" json:"queueId,omitempty" path:"queueId"`
	// contains filtered or unexported fields
}

func (*GetQueueRequest) Descriptor deprecated 

func (*GetQueueRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetQueueRequest.ProtoReflect.Descriptor instead.

func (*GetQueueRequest) GetQueueId 

func (x *GetQueueRequest) GetQueueId() string

func (*GetQueueRequest) GetRegionId 

func (x *GetQueueRequest) GetRegionId() string

func (*GetQueueRequest) ProtoMessage 

func (*GetQueueRequest) ProtoMessage()

func (*GetQueueRequest) ProtoReflect 

func (x *GetQueueRequest) ProtoReflect() protoreflect.Message

func (*GetQueueRequest) Reset 

func (x *GetQueueRequest) Reset()

func (*GetQueueRequest) String 

func (x *GetQueueRequest) String() string

type GetQueueResponse 

type GetQueueResponse struct {
	RequestId string     `protobuf:"bytes,1,opt,name=requestId,proto3" form:"requestId" json:"requestId,omitempty" query:"requestId"`
	Record    *QueueItem `protobuf:"bytes,2,opt,name=record,proto3" form:"record" json:"record,omitempty" query:"record"`
	// contains filtered or unexported fields
}

func (*GetQueueResponse) Descriptor deprecated 

func (*GetQueueResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetQueueResponse.ProtoReflect.Descriptor instead.

func (*GetQueueResponse) GetRecord 

func (x *GetQueueResponse) GetRecord() *QueueItem

func (*GetQueueResponse) GetRequestId 

func (x *GetQueueResponse) GetRequestId() string

func (*GetQueueResponse) ProtoMessage 

func (*GetQueueResponse) ProtoMessage()

func (*GetQueueResponse) ProtoReflect 

func (x *GetQueueResponse) ProtoReflect() protoreflect.Message

func (*GetQueueResponse) Reset 

func (x *GetQueueResponse) Reset()

func (*GetQueueResponse) String 

func (x *GetQueueResponse) String() string

type ListQueueRequest 

type ListQueueRequest struct {
	RegionId  string `protobuf:"bytes,1,opt,name=regionId,proto3" header:"regionId" json:"regionId,omitempty"`
	ClusterId string `protobuf:"bytes,2,opt,name=clusterId,proto3" json:"clusterId,omitempty" query:"clusterId"`
	Name      string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty" query:"name"`
	Status    string `protobuf:"bytes,4,opt,name=status,proto3" json:"status,omitempty" query:"status"`
	SortBy    string `protobuf:"bytes,5,opt,name=sortBy,proto3" json:"sortBy,omitempty" query:"sortBy"`
	Order     string `protobuf:"bytes,6,opt,name=order,proto3" json:"order,omitempty" query:"order"`
	PageNum   int32  `protobuf:"varint,7,opt,name=pageNum,proto3" json:"pageNum,omitempty" query:"pageNum" vd:"$ > 0"`
	PageSize  int32  `protobuf:"varint,8,opt,name=pageSize,proto3" json:"pageSize,omitempty" query:"pageSize" vd:"$ > 0 && $ <= 10000"`
	// contains filtered or unexported fields
}

func (*ListQueueRequest) Descriptor deprecated 

func (*ListQueueRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListQueueRequest.ProtoReflect.Descriptor instead.

func (*ListQueueRequest) GetClusterId 

func (x *ListQueueRequest) GetClusterId() string

func (*ListQueueRequest) GetName 

func (x *ListQueueRequest) GetName() string

func (*ListQueueRequest) GetOrder 

func (x *ListQueueRequest) GetOrder() string

func (*ListQueueRequest) GetPageNum 

func (x *ListQueueRequest) GetPageNum() int32

func (*ListQueueRequest) GetPageSize 

func (x *ListQueueRequest) GetPageSize() int32

func (*ListQueueRequest) GetRegionId 

func (x *ListQueueRequest) GetRegionId() string

func (*ListQueueRequest) GetSortBy 

func (x *ListQueueRequest) GetSortBy() string

func (*ListQueueRequest) GetStatus 

func (x *ListQueueRequest) GetStatus() string

func (*ListQueueRequest) ProtoMessage 

func (*ListQueueRequest) ProtoMessage()

func (*ListQueueRequest) ProtoReflect 

func (x *ListQueueRequest) ProtoReflect() protoreflect.Message

func (*ListQueueRequest) Reset 

func (x *ListQueueRequest) Reset()

func (*ListQueueRequest) String 

func (x *ListQueueRequest) String() string

type ListQueueResponse 

type ListQueueResponse struct {
	RequestId  string       `protobuf:"bytes,1,opt,name=requestId,proto3" form:"requestId" json:"requestId,omitempty" query:"requestId"`
	Records    []*QueueItem `protobuf:"bytes,2,rep,name=records,proto3" form:"records" json:"records,omitempty" query:"records"`
	TotalCount int32        `protobuf:"varint,3,opt,name=totalCount,proto3" form:"totalCount" json:"totalCount,omitempty" query:"totalCount"`
	// contains filtered or unexported fields
}

func (*ListQueueResponse) Descriptor deprecated 

func (*ListQueueResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListQueueResponse.ProtoReflect.Descriptor instead.

func (*ListQueueResponse) GetRecords 

func (x *ListQueueResponse) GetRecords() []*QueueItem

func (*ListQueueResponse) GetRequestId 

func (x *ListQueueResponse) GetRequestId() string

func (*ListQueueResponse) GetTotalCount 

func (x *ListQueueResponse) GetTotalCount() int32

func (*ListQueueResponse) ProtoMessage 

func (*ListQueueResponse) ProtoMessage()

func (*ListQueueResponse) ProtoReflect 

func (x *ListQueueResponse) ProtoReflect() protoreflect.Message

func (*ListQueueResponse) Reset 

func (x *ListQueueResponse) Reset()

func (*ListQueueResponse) String 

func (x *ListQueueResponse) String() string

type QueueCapability 

type QueueCapability struct {
	ResourceName string `protobuf:"bytes,1,opt,name=resourceName,proto3" form:"resourceName" json:"resourceName,omitempty" query:"resourceName"`
	Quantity     string `protobuf:"bytes,2,opt,name=quantity,proto3" form:"quantity" json:"quantity,omitempty" query:"quantity"`
	// contains filtered or unexported fields
}

func (*QueueCapability) Descriptor deprecated 

func (*QueueCapability) Descriptor() ([]byte, []int)

Deprecated: Use QueueCapability.ProtoReflect.Descriptor instead.

func (*QueueCapability) GetQuantity 

func (x *QueueCapability) GetQuantity() string

func (*QueueCapability) GetResourceName 

func (x *QueueCapability) GetResourceName() string

func (*QueueCapability) ProtoMessage 

func (*QueueCapability) ProtoMessage()

func (*QueueCapability) ProtoReflect 

func (x *QueueCapability) ProtoReflect() protoreflect.Message

func (*QueueCapability) Reset 

func (x *QueueCapability) Reset()

func (*QueueCapability) String 

func (x *QueueCapability) String() string

type QueueItem 

type QueueItem struct {
	QueueId     string               `protobuf:"bytes,1,opt,name=queueId,proto3" form:"queueId" json:"queueId,omitempty" query:"queueId"`
	Name        string               `protobuf:"bytes,2,opt,name=name,proto3" form:"name" json:"name,omitempty" query:"name"`
	Status      string               `protobuf:"bytes,3,opt,name=status,proto3" form:"status" json:"status,omitempty" query:"status"`
	Priority    int32                `protobuf:"varint,4,opt,name=priority,proto3" form:"priority" json:"priority" query:"priority"`
	Capability  []*QueueCapability   `protobuf:"bytes,5,rep,name=capability,proto3" form:"capability" json:"capability,omitempty" query:"capability"`
	Annotations []*common.Annotation `protobuf:"bytes,6,rep,name=annotations,proto3" form:"annotations" json:"annotations,omitempty"`
	Labels      []*common.Label      `protobuf:"bytes,7,rep,name=labels,proto3" form:"labels" json:"labels,omitempty"`
	CreatedAt   string               `protobuf:"bytes,8,opt,name=createdAt,proto3" form:"createdAt" json:"createdAt,omitempty" query:"createdAt"`
	UpdatedAt   string               `protobuf:"bytes,9,opt,name=updatedAt,proto3" form:"updatedAt" json:"updatedAt,omitempty" query:"updatedAt"`
	// contains filtered or unexported fields
}

func (*QueueItem) Descriptor deprecated 

func (*QueueItem) Descriptor() ([]byte, []int)

Deprecated: Use QueueItem.ProtoReflect.Descriptor instead.

func (*QueueItem) GetAnnotations 

func (x *QueueItem) GetAnnotations() []*common.Annotation

func (*QueueItem) GetCapability 

func (x *QueueItem) GetCapability() []*QueueCapability

func (*QueueItem) GetCreatedAt 

func (x *QueueItem) GetCreatedAt() string

func (*QueueItem) GetLabels 

func (x *QueueItem) GetLabels() []*common.Label

func (*QueueItem) GetName 

func (x *QueueItem) GetName() string

func (*QueueItem) GetPriority 

func (x *QueueItem) GetPriority() int32

func (*QueueItem) GetQueueId 

func (x *QueueItem) GetQueueId() string

func (*QueueItem) GetStatus 

func (x *QueueItem) GetStatus() string

func (*QueueItem) GetUpdatedAt 

func (x *QueueItem) GetUpdatedAt() string

func (*QueueItem) ProtoMessage 

func (*QueueItem) ProtoMessage()

func (*QueueItem) ProtoReflect 

func (x *QueueItem) ProtoReflect() protoreflect.Message

func (*QueueItem) Reset 

func (x *QueueItem) Reset()

func (*QueueItem) String 

func (x *QueueItem) String() string

type UpdateQueueRequest 

type UpdateQueueRequest struct {
	RegionId    string               `protobuf:"bytes,1,opt,name=regionId,proto3" header:"regionId" json:"regionId,omitempty"`
	QueueId     string               `protobuf:"bytes,2,opt,name=queueId,proto3" json:"queueId,omitempty" path:"queueId"`
	Priority    int32                `protobuf:"varint,3,opt,name=priority,proto3" form:"priority" json:"priority,omitempty"`
	Capability  []*QueueCapability   `protobuf:"bytes,4,rep,name=capability,proto3" form:"capability" json:"capability,omitempty"`
	Annotations []*common.Annotation `protobuf:"bytes,5,rep,name=annotations,proto3" form:"annotations" json:"annotations,omitempty"`
	Labels      []*common.Label      `protobuf:"bytes,6,rep,name=labels,proto3" form:"labels" json:"labels,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateQueueRequest) Descriptor deprecated 

func (*UpdateQueueRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateQueueRequest.ProtoReflect.Descriptor instead.

func (*UpdateQueueRequest) GetAnnotations 

func (x *UpdateQueueRequest) GetAnnotations() []*common.Annotation

func (*UpdateQueueRequest) GetCapability 

func (x *UpdateQueueRequest) GetCapability() []*QueueCapability

func (*UpdateQueueRequest) GetLabels 

func (x *UpdateQueueRequest) GetLabels() []*common.Label

func (*UpdateQueueRequest) GetPriority 

func (x *UpdateQueueRequest) GetPriority() int32

func (*UpdateQueueRequest) GetQueueId 

func (x *UpdateQueueRequest) GetQueueId() string

func (*UpdateQueueRequest) GetRegionId 

func (x *UpdateQueueRequest) GetRegionId() string

func (*UpdateQueueRequest) ProtoMessage 

func (*UpdateQueueRequest) ProtoMessage()

func (*UpdateQueueRequest) ProtoReflect 

func (x *UpdateQueueRequest) ProtoReflect() protoreflect.Message

func (*UpdateQueueRequest) Reset 

func (x *UpdateQueueRequest) Reset()

func (*UpdateQueueRequest) String 

func (x *UpdateQueueRequest) String() string

type UpdateQueueResponse 

type UpdateQueueResponse struct {
	RequestId string `protobuf:"bytes,1,opt,name=requestId,proto3" form:"requestId" json:"requestId,omitempty" query:"requestId"`
	QueueId   string `protobuf:"bytes,2,opt,name=queueId,proto3" form:"queueId" json:"queueId,omitempty" query:"queueId"`
	// contains filtered or unexported fields
}

func (*UpdateQueueResponse) Descriptor deprecated 

func (*UpdateQueueResponse) Descriptor() ([]byte, []int)

Deprecated: Use UpdateQueueResponse.ProtoReflect.Descriptor instead.

func (*UpdateQueueResponse) GetQueueId 

func (x *UpdateQueueResponse) GetQueueId() string

func (*UpdateQueueResponse) GetRequestId 

func (x *UpdateQueueResponse) GetRequestId() string

func (*UpdateQueueResponse) ProtoMessage 

func (*UpdateQueueResponse) ProtoMessage()

func (*UpdateQueueResponse) ProtoReflect 

func (x *UpdateQueueResponse) ProtoReflect() protoreflect.Message

func (*UpdateQueueResponse) Reset 

func (x *UpdateQueueResponse) Reset()

func (*UpdateQueueResponse) String 

func (x *UpdateQueueResponse) String() string

type UpdateQueueStatusRequest 

type UpdateQueueStatusRequest struct {
	QueueId string `protobuf:"bytes,1,opt,name=queueId,proto3" json:"queueId,omitempty" path:"queueId"`
	Status  string `protobuf:"bytes,2,opt,name=status,proto3" form:"status" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateQueueStatusRequest) Descriptor deprecated 

func (*UpdateQueueStatusRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateQueueStatusRequest.ProtoReflect.Descriptor instead.

func (*UpdateQueueStatusRequest) GetQueueId 

func (x *UpdateQueueStatusRequest) GetQueueId() string

func (*UpdateQueueStatusRequest) GetStatus 

func (x *UpdateQueueStatusRequest) GetStatus() string

func (*UpdateQueueStatusRequest) ProtoMessage 

func (*UpdateQueueStatusRequest) ProtoMessage()

func (*UpdateQueueStatusRequest) ProtoReflect 

func (x *UpdateQueueStatusRequest) ProtoReflect() protoreflect.Message

func (*UpdateQueueStatusRequest) Reset 

func (x *UpdateQueueStatusRequest) Reset()

func (*UpdateQueueStatusRequest) String 

func (x *UpdateQueueStatusRequest) String() string

type UpdateQueueStatusResponse 

type UpdateQueueStatusResponse struct {
	RequestId string `protobuf:"bytes,1,opt,name=requestId,proto3" form:"requestId" json:"requestId,omitempty" query:"requestId"`
	QueueId   string `protobuf:"bytes,2,opt,name=queueId,proto3" form:"queueId" json:"queueId,omitempty" query:"queueId"`
	// contains filtered or unexported fields
}

func (*UpdateQueueStatusResponse) Descriptor deprecated 

func (*UpdateQueueStatusResponse) Descriptor() ([]byte, []int)

Deprecated: Use UpdateQueueStatusResponse.ProtoReflect.Descriptor instead.

func (*UpdateQueueStatusResponse) GetQueueId 

func (x *UpdateQueueStatusResponse) GetQueueId() string

func (*UpdateQueueStatusResponse) GetRequestId 

func (x *UpdateQueueStatusResponse) GetRequestId() string

func (*UpdateQueueStatusResponse) ProtoMessage 

func (*UpdateQueueStatusResponse) ProtoMessage()

func (*UpdateQueueStatusResponse) ProtoReflect 

func (x *UpdateQueueStatusResponse) ProtoReflect() protoreflect.Message

func (*UpdateQueueStatusResponse) Reset 

func (x *UpdateQueueStatusResponse) Reset()

func (*UpdateQueueStatusResponse) String 

func (x *UpdateQueueStatusResponse) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.