taskqueue

package
v2.0.6 Latest Latest
Warning

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

 Go to latest Published: Apr 8, 2024 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Default_TaskQueueRetryParameters_MinBackoffSec = float64(0.1)
	Default_TaskQueueRetryParameters_MaxBackoffSec = float64(3600)
	Default_TaskQueueRetryParameters_MaxDoublings  = int32(16)
)

Default values for TaskQueueRetryParameters fields.

View Source 
const (
	Default_TaskQueueAddRequest_Method = TaskQueueAddRequest_POST
	Default_TaskQueueAddRequest_Mode   = TaskQueueMode_PUSH
)

Default values for TaskQueueAddRequest fields.

View Source 
const (
	Default_TaskQueueFetchQueuesResponse_Queue_Paused      = bool(false)
	Default_TaskQueueFetchQueuesResponse_Queue_Mode        = TaskQueueMode_PUSH
	Default_TaskQueueFetchQueuesResponse_Queue_CreatorName = string("apphosting")
)

Default values for TaskQueueFetchQueuesResponse_Queue fields.

View Source 
const (
	Default_TaskQueueQueryTasksResponse_Task_RetryCount     = int32(0)
	Default_TaskQueueQueryTasksResponse_Task_ExecutionCount = int32(0)
)

Default values for TaskQueueQueryTasksResponse_Task fields.

View Source 
const (
	Default_TaskQueueFetchQueueStatsRequest_MaxNumTasks = int32(0)
)

Default values for TaskQueueFetchQueueStatsRequest fields.

View Source 
const (
	Default_TaskQueueQueryAndOwnTasksRequest_GroupByTag = bool(false)
)

Default values for TaskQueueQueryAndOwnTasksRequest fields.

View Source 
const (
	Default_TaskQueueQueryAndOwnTasksResponse_Task_RetryCount = int32(0)
)

Default values for TaskQueueQueryAndOwnTasksResponse_Task fields.

View Source 
const (
	Default_TaskQueueQueryTasksRequest_MaxRows = int32(1)
)

Default values for TaskQueueQueryTasksRequest fields.

View Source 
const (
	Default_TaskQueueUpdateQueueRequest_Mode = TaskQueueMode_PUSH
)

Default values for TaskQueueUpdateQueueRequest fields.

Variables

View Source 
var (
	TaskQueueServiceError_ErrorCode_name = map[int32]string{
		0:     "OK",
		1:     "UNKNOWN_QUEUE",
		2:     "TRANSIENT_ERROR",
		3:     "INTERNAL_ERROR",
		4:     "TASK_TOO_LARGE",
		5:     "INVALID_TASK_NAME",
		6:     "INVALID_QUEUE_NAME",
		7:     "INVALID_URL",
		8:     "INVALID_QUEUE_RATE",
		9:     "PERMISSION_DENIED",
		10:    "TASK_ALREADY_EXISTS",
		11:    "TOMBSTONED_TASK",
		12:    "INVALID_ETA",
		13:    "INVALID_REQUEST",
		14:    "UNKNOWN_TASK",
		15:    "TOMBSTONED_QUEUE",
		16:    "DUPLICATE_TASK_NAME",
		17:    "SKIPPED",
		18:    "TOO_MANY_TASKS",
		19:    "INVALID_PAYLOAD",
		20:    "INVALID_RETRY_PARAMETERS",
		21:    "INVALID_QUEUE_MODE",
		22:    "ACL_LOOKUP_ERROR",
		23:    "TRANSACTIONAL_REQUEST_TOO_LARGE",
		24:    "INCORRECT_CREATOR_NAME",
		25:    "TASK_LEASE_EXPIRED",
		26:    "QUEUE_PAUSED",
		27:    "INVALID_TAG",
		10000: "DATASTORE_ERROR",
	}
	TaskQueueServiceError_ErrorCode_value = map[string]int32{
		"OK":                              0,
		"UNKNOWN_QUEUE":                   1,
		"TRANSIENT_ERROR":                 2,
		"INTERNAL_ERROR":                  3,
		"TASK_TOO_LARGE":                  4,
		"INVALID_TASK_NAME":               5,
		"INVALID_QUEUE_NAME":              6,
		"INVALID_URL":                     7,
		"INVALID_QUEUE_RATE":              8,
		"PERMISSION_DENIED":               9,
		"TASK_ALREADY_EXISTS":             10,
		"TOMBSTONED_TASK":                 11,
		"INVALID_ETA":                     12,
		"INVALID_REQUEST":                 13,
		"UNKNOWN_TASK":                    14,
		"TOMBSTONED_QUEUE":                15,
		"DUPLICATE_TASK_NAME":             16,
		"SKIPPED":                         17,
		"TOO_MANY_TASKS":                  18,
		"INVALID_PAYLOAD":                 19,
		"INVALID_RETRY_PARAMETERS":        20,
		"INVALID_QUEUE_MODE":              21,
		"ACL_LOOKUP_ERROR":                22,
		"TRANSACTIONAL_REQUEST_TOO_LARGE": 23,
		"INCORRECT_CREATOR_NAME":          24,
		"TASK_LEASE_EXPIRED":              25,
		"QUEUE_PAUSED":                    26,
		"INVALID_TAG":                     27,
		"DATASTORE_ERROR":                 10000,
	}
)

Enum value maps for TaskQueueServiceError_ErrorCode.

View Source 
var (
	TaskQueueMode_Mode_name = map[int32]string{
		0: "PUSH",
		1: "PULL",
	}
	TaskQueueMode_Mode_value = map[string]int32{
		"PUSH": 0,
		"PULL": 1,
	}
)

Enum value maps for TaskQueueMode_Mode.

View Source 
var (
	TaskQueueAddRequest_RequestMethod_name = map[int32]string{
		1: "GET",
		2: "POST",
		3: "HEAD",
		4: "PUT",
		5: "DELETE",
	}
	TaskQueueAddRequest_RequestMethod_value = map[string]int32{
		"GET":    1,
		"POST":   2,
		"HEAD":   3,
		"PUT":    4,
		"DELETE": 5,
	}
)

Enum value maps for TaskQueueAddRequest_RequestMethod.

View Source 
var (
	TaskQueueQueryTasksResponse_Task_RequestMethod_name = map[int32]string{
		1: "GET",
		2: "POST",
		3: "HEAD",
		4: "PUT",
		5: "DELETE",
	}
	TaskQueueQueryTasksResponse_Task_RequestMethod_value = map[string]int32{
		"GET":    1,
		"POST":   2,
		"HEAD":   3,
		"PUT":    4,
		"DELETE": 5,
	}
)

Enum value maps for TaskQueueQueryTasksResponse_Task_RequestMethod.

View Source 
var File_internal_taskqueue_taskqueue_service_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type TaskPayload 

type TaskPayload struct {
	// contains filtered or unexported fields
}

func (*TaskPayload) Descriptor deprecated 

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

Deprecated: Use TaskPayload.ProtoReflect.Descriptor instead.

func (*TaskPayload) ProtoMessage 

func (*TaskPayload) ProtoMessage()

func (*TaskPayload) ProtoReflect added in v2.0.4 

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

func (*TaskPayload) Reset 

func (x *TaskPayload) Reset()

func (*TaskPayload) String 

func (x *TaskPayload) String() string

type TaskQueueAcl 

type TaskQueueAcl struct {
	UserEmail   [][]byte `protobuf:"bytes,1,rep,name=user_email,json=userEmail" json:"user_email,omitempty"`
	WriterEmail [][]byte `protobuf:"bytes,2,rep,name=writer_email,json=writerEmail" json:"writer_email,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskQueueAcl) Descriptor deprecated 

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

Deprecated: Use TaskQueueAcl.ProtoReflect.Descriptor instead.

func (*TaskQueueAcl) GetUserEmail 

func (x *TaskQueueAcl) GetUserEmail() [][]byte

func (*TaskQueueAcl) GetWriterEmail 

func (x *TaskQueueAcl) GetWriterEmail() [][]byte

func (*TaskQueueAcl) ProtoMessage 

func (*TaskQueueAcl) ProtoMessage()

func (*TaskQueueAcl) ProtoReflect added in v2.0.4 

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

func (*TaskQueueAcl) Reset 

func (x *TaskQueueAcl) Reset()

func (*TaskQueueAcl) String 

func (x *TaskQueueAcl) String() string

type TaskQueueAddRequest 

type TaskQueueAddRequest struct {
	QueueName       []byte                             `protobuf:"bytes,1,req,name=queue_name,json=queueName" json:"queue_name,omitempty"`
	TaskName        []byte                             `protobuf:"bytes,2,req,name=task_name,json=taskName" json:"task_name,omitempty"`
	EtaUsec         *int64                             `protobuf:"varint,3,req,name=eta_usec,json=etaUsec" json:"eta_usec,omitempty"`
	Method          *TaskQueueAddRequest_RequestMethod `protobuf:"varint,5,opt,name=method,enum=appengine.v2.TaskQueueAddRequest_RequestMethod,def=2" json:"method,omitempty"`
	Url             []byte                             `protobuf:"bytes,4,opt,name=url" json:"url,omitempty"`
	Header          []*TaskQueueAddRequest_Header      `protobuf:"group,6,rep,name=Header,json=header" json:"header,omitempty"`
	Body            []byte                             `protobuf:"bytes,9,opt,name=body" json:"body,omitempty"`
	Transaction     *datastore.Transaction             `protobuf:"bytes,10,opt,name=transaction" json:"transaction,omitempty"`
	AppId           []byte                             `protobuf:"bytes,11,opt,name=app_id,json=appId" json:"app_id,omitempty"`
	Crontimetable   *TaskQueueAddRequest_CronTimetable `protobuf:"group,12,opt,name=CronTimetable,json=crontimetable" json:"crontimetable,omitempty"`
	Description     []byte                             `protobuf:"bytes,15,opt,name=description" json:"description,omitempty"`
	Payload         *TaskPayload                       `protobuf:"bytes,16,opt,name=payload" json:"payload,omitempty"`
	RetryParameters *TaskQueueRetryParameters          `protobuf:"bytes,17,opt,name=retry_parameters,json=retryParameters" json:"retry_parameters,omitempty"`
	Mode            *TaskQueueMode_Mode                `protobuf:"varint,18,opt,name=mode,enum=appengine.v2.TaskQueueMode_Mode,def=0" json:"mode,omitempty"`
	Tag             []byte                             `protobuf:"bytes,19,opt,name=tag" json:"tag,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskQueueAddRequest) Descriptor deprecated 

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

Deprecated: Use TaskQueueAddRequest.ProtoReflect.Descriptor instead.

func (*TaskQueueAddRequest) GetAppId 

func (x *TaskQueueAddRequest) GetAppId() []byte

func (*TaskQueueAddRequest) GetBody 

func (x *TaskQueueAddRequest) GetBody() []byte

func (*TaskQueueAddRequest) GetCrontimetable 

func (x *TaskQueueAddRequest) GetCrontimetable() *TaskQueueAddRequest_CronTimetable

func (*TaskQueueAddRequest) GetDescription 

func (x *TaskQueueAddRequest) GetDescription() []byte

func (*TaskQueueAddRequest) GetEtaUsec 

func (x *TaskQueueAddRequest) GetEtaUsec() int64

func (*TaskQueueAddRequest) GetHeader 

func (x *TaskQueueAddRequest) GetHeader() []*TaskQueueAddRequest_Header

func (*TaskQueueAddRequest) GetMethod 

func (x *TaskQueueAddRequest) GetMethod() TaskQueueAddRequest_RequestMethod

func (*TaskQueueAddRequest) GetMode 

func (x *TaskQueueAddRequest) GetMode() TaskQueueMode_Mode

func (*TaskQueueAddRequest) GetPayload 

func (x *TaskQueueAddRequest) GetPayload() *TaskPayload

func (*TaskQueueAddRequest) GetQueueName 

func (x *TaskQueueAddRequest) GetQueueName() []byte

func (*TaskQueueAddRequest) GetRetryParameters 

func (x *TaskQueueAddRequest) GetRetryParameters() *TaskQueueRetryParameters

func (*TaskQueueAddRequest) GetTag 

func (x *TaskQueueAddRequest) GetTag() []byte

func (*TaskQueueAddRequest) GetTaskName 

func (x *TaskQueueAddRequest) GetTaskName() []byte

func (*TaskQueueAddRequest) GetTransaction 

func (x *TaskQueueAddRequest) GetTransaction() *datastore.Transaction

func (*TaskQueueAddRequest) GetUrl 

func (x *TaskQueueAddRequest) GetUrl() []byte

func (*TaskQueueAddRequest) ProtoMessage 

func (*TaskQueueAddRequest) ProtoMessage()

func (*TaskQueueAddRequest) ProtoReflect added in v2.0.4 

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

func (*TaskQueueAddRequest) Reset 

func (x *TaskQueueAddRequest) Reset()

func (*TaskQueueAddRequest) String 

func (x *TaskQueueAddRequest) String() string

type TaskQueueAddRequest_CronTimetable 

type TaskQueueAddRequest_CronTimetable struct {
	Schedule []byte `protobuf:"bytes,13,req,name=schedule" json:"schedule,omitempty"`
	Timezone []byte `protobuf:"bytes,14,req,name=timezone" json:"timezone,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskQueueAddRequest_CronTimetable) Descriptor deprecated 

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

Deprecated: Use TaskQueueAddRequest_CronTimetable.ProtoReflect.Descriptor instead.

func (*TaskQueueAddRequest_CronTimetable) GetSchedule 

func (x *TaskQueueAddRequest_CronTimetable) GetSchedule() []byte

func (*TaskQueueAddRequest_CronTimetable) GetTimezone 

func (x *TaskQueueAddRequest_CronTimetable) GetTimezone() []byte

func (*TaskQueueAddRequest_CronTimetable) ProtoMessage 

func (*TaskQueueAddRequest_CronTimetable) ProtoMessage()

func (*TaskQueueAddRequest_CronTimetable) ProtoReflect added in v2.0.4 

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

func (*TaskQueueAddRequest_CronTimetable) Reset 

func (x *TaskQueueAddRequest_CronTimetable) Reset()

func (*TaskQueueAddRequest_CronTimetable) String 

func (x *TaskQueueAddRequest_CronTimetable) String() string

type TaskQueueAddRequest_Header 

type TaskQueueAddRequest_Header struct {
	Key   []byte `protobuf:"bytes,7,req,name=key" json:"key,omitempty"`
	Value []byte `protobuf:"bytes,8,req,name=value" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskQueueAddRequest_Header) Descriptor deprecated 

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

Deprecated: Use TaskQueueAddRequest_Header.ProtoReflect.Descriptor instead.

func (*TaskQueueAddRequest_Header) GetKey 

func (x *TaskQueueAddRequest_Header) GetKey() []byte

func (*TaskQueueAddRequest_Header) GetValue 

func (x *TaskQueueAddRequest_Header) GetValue() []byte

func (*TaskQueueAddRequest_Header) ProtoMessage 

func (*TaskQueueAddRequest_Header) ProtoMessage()

func (*TaskQueueAddRequest_Header) ProtoReflect added in v2.0.4 

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

func (*TaskQueueAddRequest_Header) Reset 

func (x *TaskQueueAddRequest_Header) Reset()

func (*TaskQueueAddRequest_Header) String 

func (x *TaskQueueAddRequest_Header) String() string

type TaskQueueAddRequest_RequestMethod 

type TaskQueueAddRequest_RequestMethod int32
const (
	TaskQueueAddRequest_GET    TaskQueueAddRequest_RequestMethod = 1
	TaskQueueAddRequest_POST   TaskQueueAddRequest_RequestMethod = 2
	TaskQueueAddRequest_HEAD   TaskQueueAddRequest_RequestMethod = 3
	TaskQueueAddRequest_PUT    TaskQueueAddRequest_RequestMethod = 4
	TaskQueueAddRequest_DELETE TaskQueueAddRequest_RequestMethod = 5
)

func (TaskQueueAddRequest_RequestMethod) Descriptor added in v2.0.4 

func (TaskQueueAddRequest_RequestMethod) Descriptor() protoreflect.EnumDescriptor

func (TaskQueueAddRequest_RequestMethod) Enum 

func (x TaskQueueAddRequest_RequestMethod) Enum() *TaskQueueAddRequest_RequestMethod

func (TaskQueueAddRequest_RequestMethod) EnumDescriptor deprecated 

func (TaskQueueAddRequest_RequestMethod) EnumDescriptor() ([]byte, []int)

Deprecated: Use TaskQueueAddRequest_RequestMethod.Descriptor instead.

func (TaskQueueAddRequest_RequestMethod) Number added in v2.0.4 

func (x TaskQueueAddRequest_RequestMethod) Number() protoreflect.EnumNumber

func (TaskQueueAddRequest_RequestMethod) String 

func (x TaskQueueAddRequest_RequestMethod) String() string

func (TaskQueueAddRequest_RequestMethod) Type added in v2.0.4 

func (TaskQueueAddRequest_RequestMethod) Type() protoreflect.EnumType

func (*TaskQueueAddRequest_RequestMethod) UnmarshalJSON deprecated 

func (x *TaskQueueAddRequest_RequestMethod) UnmarshalJSON(b []byte) error

Deprecated: Do not use.

type TaskQueueAddResponse 

type TaskQueueAddResponse struct {
	ChosenTaskName []byte `protobuf:"bytes,1,opt,name=chosen_task_name,json=chosenTaskName" json:"chosen_task_name,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskQueueAddResponse) Descriptor deprecated 

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

Deprecated: Use TaskQueueAddResponse.ProtoReflect.Descriptor instead.

func (*TaskQueueAddResponse) GetChosenTaskName 

func (x *TaskQueueAddResponse) GetChosenTaskName() []byte

func (*TaskQueueAddResponse) ProtoMessage 

func (*TaskQueueAddResponse) ProtoMessage()

func (*TaskQueueAddResponse) ProtoReflect added in v2.0.4 

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

func (*TaskQueueAddResponse) Reset 

func (x *TaskQueueAddResponse) Reset()

func (*TaskQueueAddResponse) String 

func (x *TaskQueueAddResponse) String() string

type TaskQueueBulkAddRequest 

type TaskQueueBulkAddRequest struct {
	AddRequest []*TaskQueueAddRequest `protobuf:"bytes,1,rep,name=add_request,json=addRequest" json:"add_request,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskQueueBulkAddRequest) Descriptor deprecated 

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

Deprecated: Use TaskQueueBulkAddRequest.ProtoReflect.Descriptor instead.

func (*TaskQueueBulkAddRequest) GetAddRequest 

func (x *TaskQueueBulkAddRequest) GetAddRequest() []*TaskQueueAddRequest

func (*TaskQueueBulkAddRequest) ProtoMessage 

func (*TaskQueueBulkAddRequest) ProtoMessage()

func (*TaskQueueBulkAddRequest) ProtoReflect added in v2.0.4 

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

func (*TaskQueueBulkAddRequest) Reset 

func (x *TaskQueueBulkAddRequest) Reset()

func (*TaskQueueBulkAddRequest) String 

func (x *TaskQueueBulkAddRequest) String() string

type TaskQueueBulkAddResponse 

type TaskQueueBulkAddResponse struct {
	Taskresult []*TaskQueueBulkAddResponse_TaskResult `protobuf:"group,1,rep,name=TaskResult,json=taskresult" json:"taskresult,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskQueueBulkAddResponse) Descriptor deprecated 

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

Deprecated: Use TaskQueueBulkAddResponse.ProtoReflect.Descriptor instead.

func (*TaskQueueBulkAddResponse) GetTaskresult 

func (x *TaskQueueBulkAddResponse) GetTaskresult() []*TaskQueueBulkAddResponse_TaskResult

func (*TaskQueueBulkAddResponse) ProtoMessage 

func (*TaskQueueBulkAddResponse) ProtoMessage()

func (*TaskQueueBulkAddResponse) ProtoReflect added in v2.0.4 

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

func (*TaskQueueBulkAddResponse) Reset 

func (x *TaskQueueBulkAddResponse) Reset()

func (*TaskQueueBulkAddResponse) String 

func (x *TaskQueueBulkAddResponse) String() string

type TaskQueueBulkAddResponse_TaskResult 

type TaskQueueBulkAddResponse_TaskResult struct {
	Result         *TaskQueueServiceError_ErrorCode `protobuf:"varint,2,req,name=result,enum=appengine.v2.TaskQueueServiceError_ErrorCode" json:"result,omitempty"`
	ChosenTaskName []byte                           `protobuf:"bytes,3,opt,name=chosen_task_name,json=chosenTaskName" json:"chosen_task_name,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskQueueBulkAddResponse_TaskResult) Descriptor deprecated 

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

Deprecated: Use TaskQueueBulkAddResponse_TaskResult.ProtoReflect.Descriptor instead.

func (*TaskQueueBulkAddResponse_TaskResult) GetChosenTaskName 

func (x *TaskQueueBulkAddResponse_TaskResult) GetChosenTaskName() []byte

func (*TaskQueueBulkAddResponse_TaskResult) GetResult 

func (x *TaskQueueBulkAddResponse_TaskResult) GetResult() TaskQueueServiceError_ErrorCode

func (*TaskQueueBulkAddResponse_TaskResult) ProtoMessage 

func (*TaskQueueBulkAddResponse_TaskResult) ProtoMessage()

func (*TaskQueueBulkAddResponse_TaskResult) ProtoReflect added in v2.0.4 

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

func (*TaskQueueBulkAddResponse_TaskResult) Reset 

func (x *TaskQueueBulkAddResponse_TaskResult) Reset()

func (*TaskQueueBulkAddResponse_TaskResult) String 

func (x *TaskQueueBulkAddResponse_TaskResult) String() string

type TaskQueueDeleteGroupRequest 

type TaskQueueDeleteGroupRequest struct {
	AppId []byte `protobuf:"bytes,1,req,name=app_id,json=appId" json:"app_id,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskQueueDeleteGroupRequest) Descriptor deprecated 

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

Deprecated: Use TaskQueueDeleteGroupRequest.ProtoReflect.Descriptor instead.

func (*TaskQueueDeleteGroupRequest) GetAppId 

func (x *TaskQueueDeleteGroupRequest) GetAppId() []byte

func (*TaskQueueDeleteGroupRequest) ProtoMessage 

func (*TaskQueueDeleteGroupRequest) ProtoMessage()

func (*TaskQueueDeleteGroupRequest) ProtoReflect added in v2.0.4 

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

func (*TaskQueueDeleteGroupRequest) Reset 

func (x *TaskQueueDeleteGroupRequest) Reset()

func (*TaskQueueDeleteGroupRequest) String 

func (x *TaskQueueDeleteGroupRequest) String() string

type TaskQueueDeleteGroupResponse 

type TaskQueueDeleteGroupResponse struct {
	// contains filtered or unexported fields
}

func (*TaskQueueDeleteGroupResponse) Descriptor deprecated 

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

Deprecated: Use TaskQueueDeleteGroupResponse.ProtoReflect.Descriptor instead.

func (*TaskQueueDeleteGroupResponse) ProtoMessage 

func (*TaskQueueDeleteGroupResponse) ProtoMessage()

func (*TaskQueueDeleteGroupResponse) ProtoReflect added in v2.0.4 

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

func (*TaskQueueDeleteGroupResponse) Reset 

func (x *TaskQueueDeleteGroupResponse) Reset()

func (*TaskQueueDeleteGroupResponse) String 

func (x *TaskQueueDeleteGroupResponse) String() string

type TaskQueueDeleteQueueRequest 

type TaskQueueDeleteQueueRequest struct {
	AppId     []byte `protobuf:"bytes,1,req,name=app_id,json=appId" json:"app_id,omitempty"`
	QueueName []byte `protobuf:"bytes,2,req,name=queue_name,json=queueName" json:"queue_name,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskQueueDeleteQueueRequest) Descriptor deprecated 

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

Deprecated: Use TaskQueueDeleteQueueRequest.ProtoReflect.Descriptor instead.

func (*TaskQueueDeleteQueueRequest) GetAppId 

func (x *TaskQueueDeleteQueueRequest) GetAppId() []byte

func (*TaskQueueDeleteQueueRequest) GetQueueName 

func (x *TaskQueueDeleteQueueRequest) GetQueueName() []byte

func (*TaskQueueDeleteQueueRequest) ProtoMessage 

func (*TaskQueueDeleteQueueRequest) ProtoMessage()

func (*TaskQueueDeleteQueueRequest) ProtoReflect added in v2.0.4 

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

func (*TaskQueueDeleteQueueRequest) Reset 

func (x *TaskQueueDeleteQueueRequest) Reset()

func (*TaskQueueDeleteQueueRequest) String 

func (x *TaskQueueDeleteQueueRequest) String() string

type TaskQueueDeleteQueueResponse 

type TaskQueueDeleteQueueResponse struct {
	// contains filtered or unexported fields
}

func (*TaskQueueDeleteQueueResponse) Descriptor deprecated 

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

Deprecated: Use TaskQueueDeleteQueueResponse.ProtoReflect.Descriptor instead.

func (*TaskQueueDeleteQueueResponse) ProtoMessage 

func (*TaskQueueDeleteQueueResponse) ProtoMessage()

func (*TaskQueueDeleteQueueResponse) ProtoReflect added in v2.0.4 

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

func (*TaskQueueDeleteQueueResponse) Reset 

func (x *TaskQueueDeleteQueueResponse) Reset()

func (*TaskQueueDeleteQueueResponse) String 

func (x *TaskQueueDeleteQueueResponse) String() string

type TaskQueueDeleteRequest 

type TaskQueueDeleteRequest struct {
	QueueName []byte   `protobuf:"bytes,1,req,name=queue_name,json=queueName" json:"queue_name,omitempty"`
	TaskName  [][]byte `protobuf:"bytes,2,rep,name=task_name,json=taskName" json:"task_name,omitempty"`
	AppId     []byte   `protobuf:"bytes,3,opt,name=app_id,json=appId" json:"app_id,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskQueueDeleteRequest) Descriptor deprecated 

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

Deprecated: Use TaskQueueDeleteRequest.ProtoReflect.Descriptor instead.

func (*TaskQueueDeleteRequest) GetAppId 

func (x *TaskQueueDeleteRequest) GetAppId() []byte

func (*TaskQueueDeleteRequest) GetQueueName 

func (x *TaskQueueDeleteRequest) GetQueueName() []byte

func (*TaskQueueDeleteRequest) GetTaskName 

func (x *TaskQueueDeleteRequest) GetTaskName() [][]byte

func (*TaskQueueDeleteRequest) ProtoMessage 

func (*TaskQueueDeleteRequest) ProtoMessage()

func (*TaskQueueDeleteRequest) ProtoReflect added in v2.0.4 

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

func (*TaskQueueDeleteRequest) Reset 

func (x *TaskQueueDeleteRequest) Reset()

func (*TaskQueueDeleteRequest) String 

func (x *TaskQueueDeleteRequest) String() string

type TaskQueueDeleteResponse 

type TaskQueueDeleteResponse struct {
	Result []TaskQueueServiceError_ErrorCode `protobuf:"varint,3,rep,name=result,enum=appengine.v2.TaskQueueServiceError_ErrorCode" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskQueueDeleteResponse) Descriptor deprecated 

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

Deprecated: Use TaskQueueDeleteResponse.ProtoReflect.Descriptor instead.

func (*TaskQueueDeleteResponse) GetResult 

func (x *TaskQueueDeleteResponse) GetResult() []TaskQueueServiceError_ErrorCode

func (*TaskQueueDeleteResponse) ProtoMessage 

func (*TaskQueueDeleteResponse) ProtoMessage()

func (*TaskQueueDeleteResponse) ProtoReflect added in v2.0.4 

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

func (*TaskQueueDeleteResponse) Reset 

func (x *TaskQueueDeleteResponse) Reset()

func (*TaskQueueDeleteResponse) String 

func (x *TaskQueueDeleteResponse) String() string

type TaskQueueFetchQueueStatsRequest 

type TaskQueueFetchQueueStatsRequest struct {
	AppId       []byte   `protobuf:"bytes,1,opt,name=app_id,json=appId" json:"app_id,omitempty"`
	QueueName   [][]byte `protobuf:"bytes,2,rep,name=queue_name,json=queueName" json:"queue_name,omitempty"`
	MaxNumTasks *int32   `protobuf:"varint,3,opt,name=max_num_tasks,json=maxNumTasks,def=0" json:"max_num_tasks,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskQueueFetchQueueStatsRequest) Descriptor deprecated 

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

Deprecated: Use TaskQueueFetchQueueStatsRequest.ProtoReflect.Descriptor instead.

func (*TaskQueueFetchQueueStatsRequest) GetAppId 

func (x *TaskQueueFetchQueueStatsRequest) GetAppId() []byte

func (*TaskQueueFetchQueueStatsRequest) GetMaxNumTasks 

func (x *TaskQueueFetchQueueStatsRequest) GetMaxNumTasks() int32

func (*TaskQueueFetchQueueStatsRequest) GetQueueName 

func (x *TaskQueueFetchQueueStatsRequest) GetQueueName() [][]byte

func (*TaskQueueFetchQueueStatsRequest) ProtoMessage 

func (*TaskQueueFetchQueueStatsRequest) ProtoMessage()

func (*TaskQueueFetchQueueStatsRequest) ProtoReflect added in v2.0.4 

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

func (*TaskQueueFetchQueueStatsRequest) Reset 

func (x *TaskQueueFetchQueueStatsRequest) Reset()

func (*TaskQueueFetchQueueStatsRequest) String 

func (x *TaskQueueFetchQueueStatsRequest) String() string

type TaskQueueFetchQueueStatsResponse 

type TaskQueueFetchQueueStatsResponse struct {
	Queuestats []*TaskQueueFetchQueueStatsResponse_QueueStats `protobuf:"group,1,rep,name=QueueStats,json=queuestats" json:"queuestats,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskQueueFetchQueueStatsResponse) Descriptor deprecated 

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

Deprecated: Use TaskQueueFetchQueueStatsResponse.ProtoReflect.Descriptor instead.

func (*TaskQueueFetchQueueStatsResponse) GetQueuestats 

func (x *TaskQueueFetchQueueStatsResponse) GetQueuestats() []*TaskQueueFetchQueueStatsResponse_QueueStats

func (*TaskQueueFetchQueueStatsResponse) ProtoMessage 

func (*TaskQueueFetchQueueStatsResponse) ProtoMessage()

func (*TaskQueueFetchQueueStatsResponse) ProtoReflect added in v2.0.4 

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

func (*TaskQueueFetchQueueStatsResponse) Reset 

func (x *TaskQueueFetchQueueStatsResponse) Reset()

func (*TaskQueueFetchQueueStatsResponse) String 

func (x *TaskQueueFetchQueueStatsResponse) String() string

type TaskQueueFetchQueueStatsResponse_QueueStats 

type TaskQueueFetchQueueStatsResponse_QueueStats struct {
	NumTasks      *int32                     `protobuf:"varint,2,req,name=num_tasks,json=numTasks" json:"num_tasks,omitempty"`
	OldestEtaUsec *int64                     `protobuf:"varint,3,req,name=oldest_eta_usec,json=oldestEtaUsec" json:"oldest_eta_usec,omitempty"`
	ScannerInfo   *TaskQueueScannerQueueInfo `protobuf:"bytes,4,opt,name=scanner_info,json=scannerInfo" json:"scanner_info,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskQueueFetchQueueStatsResponse_QueueStats) Descriptor deprecated 

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

Deprecated: Use TaskQueueFetchQueueStatsResponse_QueueStats.ProtoReflect.Descriptor instead.

func (*TaskQueueFetchQueueStatsResponse_QueueStats) GetNumTasks 

func (x *TaskQueueFetchQueueStatsResponse_QueueStats) GetNumTasks() int32

func (*TaskQueueFetchQueueStatsResponse_QueueStats) GetOldestEtaUsec 

func (x *TaskQueueFetchQueueStatsResponse_QueueStats) GetOldestEtaUsec() int64

func (*TaskQueueFetchQueueStatsResponse_QueueStats) GetScannerInfo 

func (x *TaskQueueFetchQueueStatsResponse_QueueStats) GetScannerInfo() *TaskQueueScannerQueueInfo

func (*TaskQueueFetchQueueStatsResponse_QueueStats) ProtoMessage 

func (*TaskQueueFetchQueueStatsResponse_QueueStats) ProtoMessage()

func (*TaskQueueFetchQueueStatsResponse_QueueStats) ProtoReflect added in v2.0.4 

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

func (*TaskQueueFetchQueueStatsResponse_QueueStats) Reset 

func (x *TaskQueueFetchQueueStatsResponse_QueueStats) Reset()

func (*TaskQueueFetchQueueStatsResponse_QueueStats) String 

func (x *TaskQueueFetchQueueStatsResponse_QueueStats) String() string

type TaskQueueFetchQueuesRequest 

type TaskQueueFetchQueuesRequest struct {
	AppId   []byte `protobuf:"bytes,1,opt,name=app_id,json=appId" json:"app_id,omitempty"`
	MaxRows *int32 `protobuf:"varint,2,req,name=max_rows,json=maxRows" json:"max_rows,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskQueueFetchQueuesRequest) Descriptor deprecated 

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

Deprecated: Use TaskQueueFetchQueuesRequest.ProtoReflect.Descriptor instead.

func (*TaskQueueFetchQueuesRequest) GetAppId 

func (x *TaskQueueFetchQueuesRequest) GetAppId() []byte

func (*TaskQueueFetchQueuesRequest) GetMaxRows 

func (x *TaskQueueFetchQueuesRequest) GetMaxRows() int32

func (*TaskQueueFetchQueuesRequest) ProtoMessage 

func (*TaskQueueFetchQueuesRequest) ProtoMessage()

func (*TaskQueueFetchQueuesRequest) ProtoReflect added in v2.0.4 

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

func (*TaskQueueFetchQueuesRequest) Reset 

func (x *TaskQueueFetchQueuesRequest) Reset()

func (*TaskQueueFetchQueuesRequest) String 

func (x *TaskQueueFetchQueuesRequest) String() string

type TaskQueueFetchQueuesResponse 

type TaskQueueFetchQueuesResponse struct {
	Queue []*TaskQueueFetchQueuesResponse_Queue `protobuf:"group,1,rep,name=Queue,json=queue" json:"queue,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskQueueFetchQueuesResponse) Descriptor deprecated 

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

Deprecated: Use TaskQueueFetchQueuesResponse.ProtoReflect.Descriptor instead.

func (*TaskQueueFetchQueuesResponse) GetQueue 

func (x *TaskQueueFetchQueuesResponse) GetQueue() []*TaskQueueFetchQueuesResponse_Queue

func (*TaskQueueFetchQueuesResponse) ProtoMessage 

func (*TaskQueueFetchQueuesResponse) ProtoMessage()

func (*TaskQueueFetchQueuesResponse) ProtoReflect added in v2.0.4 

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

func (*TaskQueueFetchQueuesResponse) Reset 

func (x *TaskQueueFetchQueuesResponse) Reset()

func (*TaskQueueFetchQueuesResponse) String 

func (x *TaskQueueFetchQueuesResponse) String() string

type TaskQueueFetchQueuesResponse_Queue 

type TaskQueueFetchQueuesResponse_Queue struct {
	QueueName             []byte                    `protobuf:"bytes,2,req,name=queue_name,json=queueName" json:"queue_name,omitempty"`
	BucketRefillPerSecond *float64                  `protobuf:"fixed64,3,req,name=bucket_refill_per_second,json=bucketRefillPerSecond" json:"bucket_refill_per_second,omitempty"`
	BucketCapacity        *float64                  `protobuf:"fixed64,4,req,name=bucket_capacity,json=bucketCapacity" json:"bucket_capacity,omitempty"`
	UserSpecifiedRate     *string                   `protobuf:"bytes,5,opt,name=user_specified_rate,json=userSpecifiedRate" json:"user_specified_rate,omitempty"`
	Paused                *bool                     `protobuf:"varint,6,req,name=paused,def=0" json:"paused,omitempty"`
	RetryParameters       *TaskQueueRetryParameters `protobuf:"bytes,7,opt,name=retry_parameters,json=retryParameters" json:"retry_parameters,omitempty"`
	MaxConcurrentRequests *int32                    `protobuf:"varint,8,opt,name=max_concurrent_requests,json=maxConcurrentRequests" json:"max_concurrent_requests,omitempty"`
	Mode                  *TaskQueueMode_Mode       `protobuf:"varint,9,opt,name=mode,enum=appengine.v2.TaskQueueMode_Mode,def=0" json:"mode,omitempty"`
	Acl                   *TaskQueueAcl             `protobuf:"bytes,10,opt,name=acl" json:"acl,omitempty"`
	HeaderOverride        []*TaskQueueHttpHeader    `protobuf:"bytes,11,rep,name=header_override,json=headerOverride" json:"header_override,omitempty"`
	CreatorName           *string                   `protobuf:"bytes,12,opt,name=creator_name,json=creatorName,def=apphosting" json:"creator_name,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskQueueFetchQueuesResponse_Queue) Descriptor deprecated 

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

Deprecated: Use TaskQueueFetchQueuesResponse_Queue.ProtoReflect.Descriptor instead.

func (*TaskQueueFetchQueuesResponse_Queue) GetAcl 

func (x *TaskQueueFetchQueuesResponse_Queue) GetAcl() *TaskQueueAcl

func (*TaskQueueFetchQueuesResponse_Queue) GetBucketCapacity 

func (x *TaskQueueFetchQueuesResponse_Queue) GetBucketCapacity() float64

func (*TaskQueueFetchQueuesResponse_Queue) GetBucketRefillPerSecond 

func (x *TaskQueueFetchQueuesResponse_Queue) GetBucketRefillPerSecond() float64

func (*TaskQueueFetchQueuesResponse_Queue) GetCreatorName 

func (x *TaskQueueFetchQueuesResponse_Queue) GetCreatorName() string

func (*TaskQueueFetchQueuesResponse_Queue) GetHeaderOverride 

func (x *TaskQueueFetchQueuesResponse_Queue) GetHeaderOverride() []*TaskQueueHttpHeader

func (*TaskQueueFetchQueuesResponse_Queue) GetMaxConcurrentRequests 

func (x *TaskQueueFetchQueuesResponse_Queue) GetMaxConcurrentRequests() int32

func (*TaskQueueFetchQueuesResponse_Queue) GetMode 

func (x *TaskQueueFetchQueuesResponse_Queue) GetMode() TaskQueueMode_Mode

func (*TaskQueueFetchQueuesResponse_Queue) GetPaused 

func (x *TaskQueueFetchQueuesResponse_Queue) GetPaused() bool

func (*TaskQueueFetchQueuesResponse_Queue) GetQueueName 

func (x *TaskQueueFetchQueuesResponse_Queue) GetQueueName() []byte

func (*TaskQueueFetchQueuesResponse_Queue) GetRetryParameters 

func (x *TaskQueueFetchQueuesResponse_Queue) GetRetryParameters() *TaskQueueRetryParameters

func (*TaskQueueFetchQueuesResponse_Queue) GetUserSpecifiedRate 

func (x *TaskQueueFetchQueuesResponse_Queue) GetUserSpecifiedRate() string

func (*TaskQueueFetchQueuesResponse_Queue) ProtoMessage 

func (*TaskQueueFetchQueuesResponse_Queue) ProtoMessage()

func (*TaskQueueFetchQueuesResponse_Queue) ProtoReflect added in v2.0.4 

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

func (*TaskQueueFetchQueuesResponse_Queue) Reset 

func (x *TaskQueueFetchQueuesResponse_Queue) Reset()

func (*TaskQueueFetchQueuesResponse_Queue) String 

func (x *TaskQueueFetchQueuesResponse_Queue) String() string

type TaskQueueFetchTaskRequest 

type TaskQueueFetchTaskRequest struct {
	AppId     []byte `protobuf:"bytes,1,opt,name=app_id,json=appId" json:"app_id,omitempty"`
	QueueName []byte `protobuf:"bytes,2,req,name=queue_name,json=queueName" json:"queue_name,omitempty"`
	TaskName  []byte `protobuf:"bytes,3,req,name=task_name,json=taskName" json:"task_name,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskQueueFetchTaskRequest) Descriptor deprecated 

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

Deprecated: Use TaskQueueFetchTaskRequest.ProtoReflect.Descriptor instead.

func (*TaskQueueFetchTaskRequest) GetAppId 

func (x *TaskQueueFetchTaskRequest) GetAppId() []byte

func (*TaskQueueFetchTaskRequest) GetQueueName 

func (x *TaskQueueFetchTaskRequest) GetQueueName() []byte

func (*TaskQueueFetchTaskRequest) GetTaskName 

func (x *TaskQueueFetchTaskRequest) GetTaskName() []byte

func (*TaskQueueFetchTaskRequest) ProtoMessage 

func (*TaskQueueFetchTaskRequest) ProtoMessage()

func (*TaskQueueFetchTaskRequest) ProtoReflect added in v2.0.4 

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

func (*TaskQueueFetchTaskRequest) Reset 

func (x *TaskQueueFetchTaskRequest) Reset()

func (*TaskQueueFetchTaskRequest) String 

func (x *TaskQueueFetchTaskRequest) String() string

type TaskQueueFetchTaskResponse 

type TaskQueueFetchTaskResponse struct {
	Task *TaskQueueQueryTasksResponse `protobuf:"bytes,1,req,name=task" json:"task,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskQueueFetchTaskResponse) Descriptor deprecated 

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

Deprecated: Use TaskQueueFetchTaskResponse.ProtoReflect.Descriptor instead.

func (*TaskQueueFetchTaskResponse) GetTask 

func (x *TaskQueueFetchTaskResponse) GetTask() *TaskQueueQueryTasksResponse

func (*TaskQueueFetchTaskResponse) ProtoMessage 

func (*TaskQueueFetchTaskResponse) ProtoMessage()

func (*TaskQueueFetchTaskResponse) ProtoReflect added in v2.0.4 

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

func (*TaskQueueFetchTaskResponse) Reset 

func (x *TaskQueueFetchTaskResponse) Reset()

func (*TaskQueueFetchTaskResponse) String 

func (x *TaskQueueFetchTaskResponse) String() string

type TaskQueueForceRunRequest 

type TaskQueueForceRunRequest struct {
	AppId     []byte `protobuf:"bytes,1,opt,name=app_id,json=appId" json:"app_id,omitempty"`
	QueueName []byte `protobuf:"bytes,2,req,name=queue_name,json=queueName" json:"queue_name,omitempty"`
	TaskName  []byte `protobuf:"bytes,3,req,name=task_name,json=taskName" json:"task_name,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskQueueForceRunRequest) Descriptor deprecated 

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

Deprecated: Use TaskQueueForceRunRequest.ProtoReflect.Descriptor instead.

func (*TaskQueueForceRunRequest) GetAppId 

func (x *TaskQueueForceRunRequest) GetAppId() []byte

func (*TaskQueueForceRunRequest) GetQueueName 

func (x *TaskQueueForceRunRequest) GetQueueName() []byte

func (*TaskQueueForceRunRequest) GetTaskName 

func (x *TaskQueueForceRunRequest) GetTaskName() []byte

func (*TaskQueueForceRunRequest) ProtoMessage 

func (*TaskQueueForceRunRequest) ProtoMessage()

func (*TaskQueueForceRunRequest) ProtoReflect added in v2.0.4 

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

func (*TaskQueueForceRunRequest) Reset 

func (x *TaskQueueForceRunRequest) Reset()

func (*TaskQueueForceRunRequest) String 

func (x *TaskQueueForceRunRequest) String() string

type TaskQueueForceRunResponse 

type TaskQueueForceRunResponse struct {
	Result *TaskQueueServiceError_ErrorCode `protobuf:"varint,3,req,name=result,enum=appengine.v2.TaskQueueServiceError_ErrorCode" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskQueueForceRunResponse) Descriptor deprecated 

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

Deprecated: Use TaskQueueForceRunResponse.ProtoReflect.Descriptor instead.

func (*TaskQueueForceRunResponse) GetResult 

func (x *TaskQueueForceRunResponse) GetResult() TaskQueueServiceError_ErrorCode

func (*TaskQueueForceRunResponse) ProtoMessage 

func (*TaskQueueForceRunResponse) ProtoMessage()

func (*TaskQueueForceRunResponse) ProtoReflect added in v2.0.4 

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

func (*TaskQueueForceRunResponse) Reset 

func (x *TaskQueueForceRunResponse) Reset()

func (*TaskQueueForceRunResponse) String 

func (x *TaskQueueForceRunResponse) String() string

type TaskQueueHttpHeader 

type TaskQueueHttpHeader struct {
	Key   []byte `protobuf:"bytes,1,req,name=key" json:"key,omitempty"`
	Value []byte `protobuf:"bytes,2,req,name=value" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskQueueHttpHeader) Descriptor deprecated 

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

Deprecated: Use TaskQueueHttpHeader.ProtoReflect.Descriptor instead.

func (*TaskQueueHttpHeader) GetKey 

func (x *TaskQueueHttpHeader) GetKey() []byte

func (*TaskQueueHttpHeader) GetValue 

func (x *TaskQueueHttpHeader) GetValue() []byte

func (*TaskQueueHttpHeader) ProtoMessage 

func (*TaskQueueHttpHeader) ProtoMessage()

func (*TaskQueueHttpHeader) ProtoReflect added in v2.0.4 

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

func (*TaskQueueHttpHeader) Reset 

func (x *TaskQueueHttpHeader) Reset()

func (*TaskQueueHttpHeader) String 

func (x *TaskQueueHttpHeader) String() string

type TaskQueueMode 

type TaskQueueMode struct {
	// contains filtered or unexported fields
}

func (*TaskQueueMode) Descriptor deprecated 

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

Deprecated: Use TaskQueueMode.ProtoReflect.Descriptor instead.

func (*TaskQueueMode) ProtoMessage 

func (*TaskQueueMode) ProtoMessage()

func (*TaskQueueMode) ProtoReflect added in v2.0.4 

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

func (*TaskQueueMode) Reset 

func (x *TaskQueueMode) Reset()

func (*TaskQueueMode) String 

func (x *TaskQueueMode) String() string

type TaskQueueMode_Mode 

type TaskQueueMode_Mode int32
const (
	TaskQueueMode_PUSH TaskQueueMode_Mode = 0
	TaskQueueMode_PULL TaskQueueMode_Mode = 1
)

func (TaskQueueMode_Mode) Descriptor added in v2.0.4 

func (TaskQueueMode_Mode) Descriptor() protoreflect.EnumDescriptor

func (TaskQueueMode_Mode) Enum 

func (x TaskQueueMode_Mode) Enum() *TaskQueueMode_Mode

func (TaskQueueMode_Mode) EnumDescriptor deprecated 

func (TaskQueueMode_Mode) EnumDescriptor() ([]byte, []int)

Deprecated: Use TaskQueueMode_Mode.Descriptor instead.

func (TaskQueueMode_Mode) Number added in v2.0.4 

func (x TaskQueueMode_Mode) Number() protoreflect.EnumNumber

func (TaskQueueMode_Mode) String 

func (x TaskQueueMode_Mode) String() string

func (TaskQueueMode_Mode) Type added in v2.0.4 

func (TaskQueueMode_Mode) Type() protoreflect.EnumType

func (*TaskQueueMode_Mode) UnmarshalJSON deprecated 

func (x *TaskQueueMode_Mode) UnmarshalJSON(b []byte) error

Deprecated: Do not use.

type TaskQueueModifyTaskLeaseRequest 

type TaskQueueModifyTaskLeaseRequest struct {
	QueueName    []byte   `protobuf:"bytes,1,req,name=queue_name,json=queueName" json:"queue_name,omitempty"`
	TaskName     []byte   `protobuf:"bytes,2,req,name=task_name,json=taskName" json:"task_name,omitempty"`
	EtaUsec      *int64   `protobuf:"varint,3,req,name=eta_usec,json=etaUsec" json:"eta_usec,omitempty"`
	LeaseSeconds *float64 `protobuf:"fixed64,4,req,name=lease_seconds,json=leaseSeconds" json:"lease_seconds,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskQueueModifyTaskLeaseRequest) Descriptor deprecated 

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

Deprecated: Use TaskQueueModifyTaskLeaseRequest.ProtoReflect.Descriptor instead.

func (*TaskQueueModifyTaskLeaseRequest) GetEtaUsec 

func (x *TaskQueueModifyTaskLeaseRequest) GetEtaUsec() int64

func (*TaskQueueModifyTaskLeaseRequest) GetLeaseSeconds 

func (x *TaskQueueModifyTaskLeaseRequest) GetLeaseSeconds() float64

func (*TaskQueueModifyTaskLeaseRequest) GetQueueName 

func (x *TaskQueueModifyTaskLeaseRequest) GetQueueName() []byte

func (*TaskQueueModifyTaskLeaseRequest) GetTaskName 

func (x *TaskQueueModifyTaskLeaseRequest) GetTaskName() []byte

func (*TaskQueueModifyTaskLeaseRequest) ProtoMessage 

func (*TaskQueueModifyTaskLeaseRequest) ProtoMessage()

func (*TaskQueueModifyTaskLeaseRequest) ProtoReflect added in v2.0.4 

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

func (*TaskQueueModifyTaskLeaseRequest) Reset 

func (x *TaskQueueModifyTaskLeaseRequest) Reset()

func (*TaskQueueModifyTaskLeaseRequest) String 

func (x *TaskQueueModifyTaskLeaseRequest) String() string

type TaskQueueModifyTaskLeaseResponse 

type TaskQueueModifyTaskLeaseResponse struct {
	UpdatedEtaUsec *int64 `protobuf:"varint,1,req,name=updated_eta_usec,json=updatedEtaUsec" json:"updated_eta_usec,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskQueueModifyTaskLeaseResponse) Descriptor deprecated 

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

Deprecated: Use TaskQueueModifyTaskLeaseResponse.ProtoReflect.Descriptor instead.

func (*TaskQueueModifyTaskLeaseResponse) GetUpdatedEtaUsec 

func (x *TaskQueueModifyTaskLeaseResponse) GetUpdatedEtaUsec() int64

func (*TaskQueueModifyTaskLeaseResponse) ProtoMessage 

func (*TaskQueueModifyTaskLeaseResponse) ProtoMessage()

func (*TaskQueueModifyTaskLeaseResponse) ProtoReflect added in v2.0.4 

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

func (*TaskQueueModifyTaskLeaseResponse) Reset 

func (x *TaskQueueModifyTaskLeaseResponse) Reset()

func (*TaskQueueModifyTaskLeaseResponse) String 

func (x *TaskQueueModifyTaskLeaseResponse) String() string

type TaskQueuePauseQueueRequest 

type TaskQueuePauseQueueRequest struct {
	AppId     []byte `protobuf:"bytes,1,req,name=app_id,json=appId" json:"app_id,omitempty"`
	QueueName []byte `protobuf:"bytes,2,req,name=queue_name,json=queueName" json:"queue_name,omitempty"`
	Pause     *bool  `protobuf:"varint,3,req,name=pause" json:"pause,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskQueuePauseQueueRequest) Descriptor deprecated 

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

Deprecated: Use TaskQueuePauseQueueRequest.ProtoReflect.Descriptor instead.

func (*TaskQueuePauseQueueRequest) GetAppId 

func (x *TaskQueuePauseQueueRequest) GetAppId() []byte

func (*TaskQueuePauseQueueRequest) GetPause 

func (x *TaskQueuePauseQueueRequest) GetPause() bool

func (*TaskQueuePauseQueueRequest) GetQueueName 

func (x *TaskQueuePauseQueueRequest) GetQueueName() []byte

func (*TaskQueuePauseQueueRequest) ProtoMessage 

func (*TaskQueuePauseQueueRequest) ProtoMessage()

func (*TaskQueuePauseQueueRequest) ProtoReflect added in v2.0.4 

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

func (*TaskQueuePauseQueueRequest) Reset 

func (x *TaskQueuePauseQueueRequest) Reset()

func (*TaskQueuePauseQueueRequest) String 

func (x *TaskQueuePauseQueueRequest) String() string

type TaskQueuePauseQueueResponse 

type TaskQueuePauseQueueResponse struct {
	// contains filtered or unexported fields
}

func (*TaskQueuePauseQueueResponse) Descriptor deprecated 

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

Deprecated: Use TaskQueuePauseQueueResponse.ProtoReflect.Descriptor instead.

func (*TaskQueuePauseQueueResponse) ProtoMessage 

func (*TaskQueuePauseQueueResponse) ProtoMessage()

func (*TaskQueuePauseQueueResponse) ProtoReflect added in v2.0.4 

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

func (*TaskQueuePauseQueueResponse) Reset 

func (x *TaskQueuePauseQueueResponse) Reset()

func (*TaskQueuePauseQueueResponse) String 

func (x *TaskQueuePauseQueueResponse) String() string

type TaskQueuePurgeQueueRequest 

type TaskQueuePurgeQueueRequest struct {
	AppId     []byte `protobuf:"bytes,1,opt,name=app_id,json=appId" json:"app_id,omitempty"`
	QueueName []byte `protobuf:"bytes,2,req,name=queue_name,json=queueName" json:"queue_name,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskQueuePurgeQueueRequest) Descriptor deprecated 

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

Deprecated: Use TaskQueuePurgeQueueRequest.ProtoReflect.Descriptor instead.

func (*TaskQueuePurgeQueueRequest) GetAppId 

func (x *TaskQueuePurgeQueueRequest) GetAppId() []byte

func (*TaskQueuePurgeQueueRequest) GetQueueName 

func (x *TaskQueuePurgeQueueRequest) GetQueueName() []byte

func (*TaskQueuePurgeQueueRequest) ProtoMessage 

func (*TaskQueuePurgeQueueRequest) ProtoMessage()

func (*TaskQueuePurgeQueueRequest) ProtoReflect added in v2.0.4 

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

func (*TaskQueuePurgeQueueRequest) Reset 

func (x *TaskQueuePurgeQueueRequest) Reset()

func (*TaskQueuePurgeQueueRequest) String 

func (x *TaskQueuePurgeQueueRequest) String() string

type TaskQueuePurgeQueueResponse 

type TaskQueuePurgeQueueResponse struct {
	// contains filtered or unexported fields
}

func (*TaskQueuePurgeQueueResponse) Descriptor deprecated 

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

Deprecated: Use TaskQueuePurgeQueueResponse.ProtoReflect.Descriptor instead.

func (*TaskQueuePurgeQueueResponse) ProtoMessage 

func (*TaskQueuePurgeQueueResponse) ProtoMessage()

func (*TaskQueuePurgeQueueResponse) ProtoReflect added in v2.0.4 

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

func (*TaskQueuePurgeQueueResponse) Reset 

func (x *TaskQueuePurgeQueueResponse) Reset()

func (*TaskQueuePurgeQueueResponse) String 

func (x *TaskQueuePurgeQueueResponse) String() string

type TaskQueueQueryAndOwnTasksRequest 

type TaskQueueQueryAndOwnTasksRequest struct {
	QueueName    []byte   `protobuf:"bytes,1,req,name=queue_name,json=queueName" json:"queue_name,omitempty"`
	LeaseSeconds *float64 `protobuf:"fixed64,2,req,name=lease_seconds,json=leaseSeconds" json:"lease_seconds,omitempty"`
	MaxTasks     *int64   `protobuf:"varint,3,req,name=max_tasks,json=maxTasks" json:"max_tasks,omitempty"`
	GroupByTag   *bool    `protobuf:"varint,4,opt,name=group_by_tag,json=groupByTag,def=0" json:"group_by_tag,omitempty"`
	Tag          []byte   `protobuf:"bytes,5,opt,name=tag" json:"tag,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskQueueQueryAndOwnTasksRequest) Descriptor deprecated 

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

Deprecated: Use TaskQueueQueryAndOwnTasksRequest.ProtoReflect.Descriptor instead.

func (*TaskQueueQueryAndOwnTasksRequest) GetGroupByTag 

func (x *TaskQueueQueryAndOwnTasksRequest) GetGroupByTag() bool

func (*TaskQueueQueryAndOwnTasksRequest) GetLeaseSeconds 

func (x *TaskQueueQueryAndOwnTasksRequest) GetLeaseSeconds() float64

func (*TaskQueueQueryAndOwnTasksRequest) GetMaxTasks 

func (x *TaskQueueQueryAndOwnTasksRequest) GetMaxTasks() int64

func (*TaskQueueQueryAndOwnTasksRequest) GetQueueName 

func (x *TaskQueueQueryAndOwnTasksRequest) GetQueueName() []byte

func (*TaskQueueQueryAndOwnTasksRequest) GetTag 

func (x *TaskQueueQueryAndOwnTasksRequest) GetTag() []byte

func (*TaskQueueQueryAndOwnTasksRequest) ProtoMessage 

func (*TaskQueueQueryAndOwnTasksRequest) ProtoMessage()

func (*TaskQueueQueryAndOwnTasksRequest) ProtoReflect added in v2.0.4 

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

func (*TaskQueueQueryAndOwnTasksRequest) Reset 

func (x *TaskQueueQueryAndOwnTasksRequest) Reset()

func (*TaskQueueQueryAndOwnTasksRequest) String 

func (x *TaskQueueQueryAndOwnTasksRequest) String() string

type TaskQueueQueryAndOwnTasksResponse 

type TaskQueueQueryAndOwnTasksResponse struct {
	Task []*TaskQueueQueryAndOwnTasksResponse_Task `protobuf:"group,1,rep,name=Task,json=task" json:"task,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskQueueQueryAndOwnTasksResponse) Descriptor deprecated 

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

Deprecated: Use TaskQueueQueryAndOwnTasksResponse.ProtoReflect.Descriptor instead.

func (*TaskQueueQueryAndOwnTasksResponse) GetTask 

func (x *TaskQueueQueryAndOwnTasksResponse) GetTask() []*TaskQueueQueryAndOwnTasksResponse_Task

func (*TaskQueueQueryAndOwnTasksResponse) ProtoMessage 

func (*TaskQueueQueryAndOwnTasksResponse) ProtoMessage()

func (*TaskQueueQueryAndOwnTasksResponse) ProtoReflect added in v2.0.4 

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

func (*TaskQueueQueryAndOwnTasksResponse) Reset 

func (x *TaskQueueQueryAndOwnTasksResponse) Reset()

func (*TaskQueueQueryAndOwnTasksResponse) String 

func (x *TaskQueueQueryAndOwnTasksResponse) String() string

type TaskQueueQueryAndOwnTasksResponse_Task 

type TaskQueueQueryAndOwnTasksResponse_Task struct {
	TaskName   []byte `protobuf:"bytes,2,req,name=task_name,json=taskName" json:"task_name,omitempty"`
	EtaUsec    *int64 `protobuf:"varint,3,req,name=eta_usec,json=etaUsec" json:"eta_usec,omitempty"`
	RetryCount *int32 `protobuf:"varint,4,opt,name=retry_count,json=retryCount,def=0" json:"retry_count,omitempty"`
	Body       []byte `protobuf:"bytes,5,opt,name=body" json:"body,omitempty"`
	Tag        []byte `protobuf:"bytes,6,opt,name=tag" json:"tag,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskQueueQueryAndOwnTasksResponse_Task) Descriptor deprecated 

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

Deprecated: Use TaskQueueQueryAndOwnTasksResponse_Task.ProtoReflect.Descriptor instead.

func (*TaskQueueQueryAndOwnTasksResponse_Task) GetBody 

func (x *TaskQueueQueryAndOwnTasksResponse_Task) GetBody() []byte

func (*TaskQueueQueryAndOwnTasksResponse_Task) GetEtaUsec 

func (x *TaskQueueQueryAndOwnTasksResponse_Task) GetEtaUsec() int64

func (*TaskQueueQueryAndOwnTasksResponse_Task) GetRetryCount 

func (x *TaskQueueQueryAndOwnTasksResponse_Task) GetRetryCount() int32

func (*TaskQueueQueryAndOwnTasksResponse_Task) GetTag 

func (x *TaskQueueQueryAndOwnTasksResponse_Task) GetTag() []byte

func (*TaskQueueQueryAndOwnTasksResponse_Task) GetTaskName 

func (x *TaskQueueQueryAndOwnTasksResponse_Task) GetTaskName() []byte

func (*TaskQueueQueryAndOwnTasksResponse_Task) ProtoMessage 

func (*TaskQueueQueryAndOwnTasksResponse_Task) ProtoMessage()

func (*TaskQueueQueryAndOwnTasksResponse_Task) ProtoReflect added in v2.0.4 

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

func (*TaskQueueQueryAndOwnTasksResponse_Task) Reset 

func (x *TaskQueueQueryAndOwnTasksResponse_Task) Reset()

func (*TaskQueueQueryAndOwnTasksResponse_Task) String 

func (x *TaskQueueQueryAndOwnTasksResponse_Task) String() string

type TaskQueueQueryTasksRequest 

type TaskQueueQueryTasksRequest struct {
	AppId         []byte `protobuf:"bytes,1,opt,name=app_id,json=appId" json:"app_id,omitempty"`
	QueueName     []byte `protobuf:"bytes,2,req,name=queue_name,json=queueName" json:"queue_name,omitempty"`
	StartTaskName []byte `protobuf:"bytes,3,opt,name=start_task_name,json=startTaskName" json:"start_task_name,omitempty"`
	StartEtaUsec  *int64 `protobuf:"varint,4,opt,name=start_eta_usec,json=startEtaUsec" json:"start_eta_usec,omitempty"`
	StartTag      []byte `protobuf:"bytes,6,opt,name=start_tag,json=startTag" json:"start_tag,omitempty"`
	MaxRows       *int32 `protobuf:"varint,5,opt,name=max_rows,json=maxRows,def=1" json:"max_rows,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskQueueQueryTasksRequest) Descriptor deprecated 

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

Deprecated: Use TaskQueueQueryTasksRequest.ProtoReflect.Descriptor instead.

func (*TaskQueueQueryTasksRequest) GetAppId 

func (x *TaskQueueQueryTasksRequest) GetAppId() []byte

func (*TaskQueueQueryTasksRequest) GetMaxRows 

func (x *TaskQueueQueryTasksRequest) GetMaxRows() int32

func (*TaskQueueQueryTasksRequest) GetQueueName 

func (x *TaskQueueQueryTasksRequest) GetQueueName() []byte

func (*TaskQueueQueryTasksRequest) GetStartEtaUsec 

func (x *TaskQueueQueryTasksRequest) GetStartEtaUsec() int64

func (*TaskQueueQueryTasksRequest) GetStartTag 

func (x *TaskQueueQueryTasksRequest) GetStartTag() []byte

func (*TaskQueueQueryTasksRequest) GetStartTaskName 

func (x *TaskQueueQueryTasksRequest) GetStartTaskName() []byte

func (*TaskQueueQueryTasksRequest) ProtoMessage 

func (*TaskQueueQueryTasksRequest) ProtoMessage()

func (*TaskQueueQueryTasksRequest) ProtoReflect added in v2.0.4 

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

func (*TaskQueueQueryTasksRequest) Reset 

func (x *TaskQueueQueryTasksRequest) Reset()

func (*TaskQueueQueryTasksRequest) String 

func (x *TaskQueueQueryTasksRequest) String() string

type TaskQueueQueryTasksResponse 

type TaskQueueQueryTasksResponse struct {
	Task []*TaskQueueQueryTasksResponse_Task `protobuf:"group,1,rep,name=Task,json=task" json:"task,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskQueueQueryTasksResponse) Descriptor deprecated 

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

Deprecated: Use TaskQueueQueryTasksResponse.ProtoReflect.Descriptor instead.

func (*TaskQueueQueryTasksResponse) GetTask 

func (x *TaskQueueQueryTasksResponse) GetTask() []*TaskQueueQueryTasksResponse_Task

func (*TaskQueueQueryTasksResponse) ProtoMessage 

func (*TaskQueueQueryTasksResponse) ProtoMessage()

func (*TaskQueueQueryTasksResponse) ProtoReflect added in v2.0.4 

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

func (*TaskQueueQueryTasksResponse) Reset 

func (x *TaskQueueQueryTasksResponse) Reset()

func (*TaskQueueQueryTasksResponse) String 

func (x *TaskQueueQueryTasksResponse) String() string

type TaskQueueQueryTasksResponse_Task 

type TaskQueueQueryTasksResponse_Task struct {
	TaskName         []byte                                          `protobuf:"bytes,2,req,name=task_name,json=taskName" json:"task_name,omitempty"`
	EtaUsec          *int64                                          `protobuf:"varint,3,req,name=eta_usec,json=etaUsec" json:"eta_usec,omitempty"`
	Url              []byte                                          `protobuf:"bytes,4,opt,name=url" json:"url,omitempty"`
	Method           *TaskQueueQueryTasksResponse_Task_RequestMethod `protobuf:"varint,5,opt,name=method,enum=appengine.v2.TaskQueueQueryTasksResponse_Task_RequestMethod" json:"method,omitempty"`
	RetryCount       *int32                                          `protobuf:"varint,6,opt,name=retry_count,json=retryCount,def=0" json:"retry_count,omitempty"`
	Header           []*TaskQueueQueryTasksResponse_Task_Header      `protobuf:"group,7,rep,name=Header,json=header" json:"header,omitempty"`
	BodySize         *int32                                          `protobuf:"varint,10,opt,name=body_size,json=bodySize" json:"body_size,omitempty"`
	Body             []byte                                          `protobuf:"bytes,11,opt,name=body" json:"body,omitempty"`
	CreationTimeUsec *int64                                          `protobuf:"varint,12,req,name=creation_time_usec,json=creationTimeUsec" json:"creation_time_usec,omitempty"`
	Crontimetable    *TaskQueueQueryTasksResponse_Task_CronTimetable `protobuf:"group,13,opt,name=CronTimetable,json=crontimetable" json:"crontimetable,omitempty"`
	Runlog           *TaskQueueQueryTasksResponse_Task_RunLog        `protobuf:"group,16,opt,name=RunLog,json=runlog" json:"runlog,omitempty"`
	Description      []byte                                          `protobuf:"bytes,21,opt,name=description" json:"description,omitempty"`
	Payload          *TaskPayload                                    `protobuf:"bytes,22,opt,name=payload" json:"payload,omitempty"`
	RetryParameters  *TaskQueueRetryParameters                       `protobuf:"bytes,23,opt,name=retry_parameters,json=retryParameters" json:"retry_parameters,omitempty"`
	FirstTryUsec     *int64                                          `protobuf:"varint,24,opt,name=first_try_usec,json=firstTryUsec" json:"first_try_usec,omitempty"`
	Tag              []byte                                          `protobuf:"bytes,25,opt,name=tag" json:"tag,omitempty"`
	ExecutionCount   *int32                                          `protobuf:"varint,26,opt,name=execution_count,json=executionCount,def=0" json:"execution_count,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskQueueQueryTasksResponse_Task) Descriptor deprecated 

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

Deprecated: Use TaskQueueQueryTasksResponse_Task.ProtoReflect.Descriptor instead.

func (*TaskQueueQueryTasksResponse_Task) GetBody 

func (x *TaskQueueQueryTasksResponse_Task) GetBody() []byte

func (*TaskQueueQueryTasksResponse_Task) GetBodySize 

func (x *TaskQueueQueryTasksResponse_Task) GetBodySize() int32

func (*TaskQueueQueryTasksResponse_Task) GetCreationTimeUsec 

func (x *TaskQueueQueryTasksResponse_Task) GetCreationTimeUsec() int64

func (*TaskQueueQueryTasksResponse_Task) GetCrontimetable 

func (x *TaskQueueQueryTasksResponse_Task) GetCrontimetable() *TaskQueueQueryTasksResponse_Task_CronTimetable

func (*TaskQueueQueryTasksResponse_Task) GetDescription 

func (x *TaskQueueQueryTasksResponse_Task) GetDescription() []byte

func (*TaskQueueQueryTasksResponse_Task) GetEtaUsec 

func (x *TaskQueueQueryTasksResponse_Task) GetEtaUsec() int64

func (*TaskQueueQueryTasksResponse_Task) GetExecutionCount 

func (x *TaskQueueQueryTasksResponse_Task) GetExecutionCount() int32

func (*TaskQueueQueryTasksResponse_Task) GetFirstTryUsec 

func (x *TaskQueueQueryTasksResponse_Task) GetFirstTryUsec() int64

func (*TaskQueueQueryTasksResponse_Task) GetHeader 

func (x *TaskQueueQueryTasksResponse_Task) GetHeader() []*TaskQueueQueryTasksResponse_Task_Header

func (*TaskQueueQueryTasksResponse_Task) GetMethod 

func (x *TaskQueueQueryTasksResponse_Task) GetMethod() TaskQueueQueryTasksResponse_Task_RequestMethod

func (*TaskQueueQueryTasksResponse_Task) GetPayload 

func (x *TaskQueueQueryTasksResponse_Task) GetPayload() *TaskPayload

func (*TaskQueueQueryTasksResponse_Task) GetRetryCount 

func (x *TaskQueueQueryTasksResponse_Task) GetRetryCount() int32

func (*TaskQueueQueryTasksResponse_Task) GetRetryParameters 

func (x *TaskQueueQueryTasksResponse_Task) GetRetryParameters() *TaskQueueRetryParameters

func (*TaskQueueQueryTasksResponse_Task) GetRunlog 

func (x *TaskQueueQueryTasksResponse_Task) GetRunlog() *TaskQueueQueryTasksResponse_Task_RunLog

func (*TaskQueueQueryTasksResponse_Task) GetTag 

func (x *TaskQueueQueryTasksResponse_Task) GetTag() []byte

func (*TaskQueueQueryTasksResponse_Task) GetTaskName 

func (x *TaskQueueQueryTasksResponse_Task) GetTaskName() []byte

func (*TaskQueueQueryTasksResponse_Task) GetUrl 

func (x *TaskQueueQueryTasksResponse_Task) GetUrl() []byte

func (*TaskQueueQueryTasksResponse_Task) ProtoMessage 

func (*TaskQueueQueryTasksResponse_Task) ProtoMessage()

func (*TaskQueueQueryTasksResponse_Task) ProtoReflect added in v2.0.4 

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

func (*TaskQueueQueryTasksResponse_Task) Reset 

func (x *TaskQueueQueryTasksResponse_Task) Reset()

func (*TaskQueueQueryTasksResponse_Task) String 

func (x *TaskQueueQueryTasksResponse_Task) String() string

type TaskQueueQueryTasksResponse_Task_CronTimetable 

type TaskQueueQueryTasksResponse_Task_CronTimetable struct {
	Schedule []byte `protobuf:"bytes,14,req,name=schedule" json:"schedule,omitempty"`
	Timezone []byte `protobuf:"bytes,15,req,name=timezone" json:"timezone,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskQueueQueryTasksResponse_Task_CronTimetable) Descriptor deprecated 

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

Deprecated: Use TaskQueueQueryTasksResponse_Task_CronTimetable.ProtoReflect.Descriptor instead.

func (*TaskQueueQueryTasksResponse_Task_CronTimetable) GetSchedule 

func (x *TaskQueueQueryTasksResponse_Task_CronTimetable) GetSchedule() []byte

func (*TaskQueueQueryTasksResponse_Task_CronTimetable) GetTimezone 

func (x *TaskQueueQueryTasksResponse_Task_CronTimetable) GetTimezone() []byte

func (*TaskQueueQueryTasksResponse_Task_CronTimetable) ProtoMessage 

func (*TaskQueueQueryTasksResponse_Task_CronTimetable) ProtoMessage()

func (*TaskQueueQueryTasksResponse_Task_CronTimetable) ProtoReflect added in v2.0.4 

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

func (*TaskQueueQueryTasksResponse_Task_CronTimetable) Reset 

func (x *TaskQueueQueryTasksResponse_Task_CronTimetable) Reset()

func (*TaskQueueQueryTasksResponse_Task_CronTimetable) String 

func (x *TaskQueueQueryTasksResponse_Task_CronTimetable) String() string

type TaskQueueQueryTasksResponse_Task_Header 

type TaskQueueQueryTasksResponse_Task_Header struct {
	Key   []byte `protobuf:"bytes,8,req,name=key" json:"key,omitempty"`
	Value []byte `protobuf:"bytes,9,req,name=value" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskQueueQueryTasksResponse_Task_Header) Descriptor deprecated 

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

Deprecated: Use TaskQueueQueryTasksResponse_Task_Header.ProtoReflect.Descriptor instead.

func (*TaskQueueQueryTasksResponse_Task_Header) GetKey 

func (x *TaskQueueQueryTasksResponse_Task_Header) GetKey() []byte

func (*TaskQueueQueryTasksResponse_Task_Header) GetValue 

func (x *TaskQueueQueryTasksResponse_Task_Header) GetValue() []byte

func (*TaskQueueQueryTasksResponse_Task_Header) ProtoMessage 

func (*TaskQueueQueryTasksResponse_Task_Header) ProtoMessage()

func (*TaskQueueQueryTasksResponse_Task_Header) ProtoReflect added in v2.0.4 

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

func (*TaskQueueQueryTasksResponse_Task_Header) Reset 

func (x *TaskQueueQueryTasksResponse_Task_Header) Reset()

func (*TaskQueueQueryTasksResponse_Task_Header) String 

func (x *TaskQueueQueryTasksResponse_Task_Header) String() string

type TaskQueueQueryTasksResponse_Task_RequestMethod 

type TaskQueueQueryTasksResponse_Task_RequestMethod int32
const (
	TaskQueueQueryTasksResponse_Task_GET    TaskQueueQueryTasksResponse_Task_RequestMethod = 1
	TaskQueueQueryTasksResponse_Task_POST   TaskQueueQueryTasksResponse_Task_RequestMethod = 2
	TaskQueueQueryTasksResponse_Task_HEAD   TaskQueueQueryTasksResponse_Task_RequestMethod = 3
	TaskQueueQueryTasksResponse_Task_PUT    TaskQueueQueryTasksResponse_Task_RequestMethod = 4
	TaskQueueQueryTasksResponse_Task_DELETE TaskQueueQueryTasksResponse_Task_RequestMethod = 5
)

func (TaskQueueQueryTasksResponse_Task_RequestMethod) Descriptor added in v2.0.4 

func (TaskQueueQueryTasksResponse_Task_RequestMethod) Descriptor() protoreflect.EnumDescriptor

func (TaskQueueQueryTasksResponse_Task_RequestMethod) Enum 

func (x TaskQueueQueryTasksResponse_Task_RequestMethod) Enum() *TaskQueueQueryTasksResponse_Task_RequestMethod

func (TaskQueueQueryTasksResponse_Task_RequestMethod) EnumDescriptor deprecated 

func (TaskQueueQueryTasksResponse_Task_RequestMethod) EnumDescriptor() ([]byte, []int)

Deprecated: Use TaskQueueQueryTasksResponse_Task_RequestMethod.Descriptor instead.

func (TaskQueueQueryTasksResponse_Task_RequestMethod) Number added in v2.0.4 

func (x TaskQueueQueryTasksResponse_Task_RequestMethod) Number() protoreflect.EnumNumber

func (TaskQueueQueryTasksResponse_Task_RequestMethod) String 

func (x TaskQueueQueryTasksResponse_Task_RequestMethod) String() string

func (TaskQueueQueryTasksResponse_Task_RequestMethod) Type added in v2.0.4 

func (TaskQueueQueryTasksResponse_Task_RequestMethod) Type() protoreflect.EnumType

func (*TaskQueueQueryTasksResponse_Task_RequestMethod) UnmarshalJSON deprecated 

func (x *TaskQueueQueryTasksResponse_Task_RequestMethod) UnmarshalJSON(b []byte) error

Deprecated: Do not use.

type TaskQueueQueryTasksResponse_Task_RunLog 

type TaskQueueQueryTasksResponse_Task_RunLog struct {
	DispatchedUsec *int64  `protobuf:"varint,17,req,name=dispatched_usec,json=dispatchedUsec" json:"dispatched_usec,omitempty"`
	LagUsec        *int64  `protobuf:"varint,18,req,name=lag_usec,json=lagUsec" json:"lag_usec,omitempty"`
	ElapsedUsec    *int64  `protobuf:"varint,19,req,name=elapsed_usec,json=elapsedUsec" json:"elapsed_usec,omitempty"`
	ResponseCode   *int64  `protobuf:"varint,20,opt,name=response_code,json=responseCode" json:"response_code,omitempty"`
	RetryReason    *string `protobuf:"bytes,27,opt,name=retry_reason,json=retryReason" json:"retry_reason,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskQueueQueryTasksResponse_Task_RunLog) Descriptor deprecated 

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

Deprecated: Use TaskQueueQueryTasksResponse_Task_RunLog.ProtoReflect.Descriptor instead.

func (*TaskQueueQueryTasksResponse_Task_RunLog) GetDispatchedUsec 

func (x *TaskQueueQueryTasksResponse_Task_RunLog) GetDispatchedUsec() int64

func (*TaskQueueQueryTasksResponse_Task_RunLog) GetElapsedUsec 

func (x *TaskQueueQueryTasksResponse_Task_RunLog) GetElapsedUsec() int64

func (*TaskQueueQueryTasksResponse_Task_RunLog) GetLagUsec 

func (x *TaskQueueQueryTasksResponse_Task_RunLog) GetLagUsec() int64

func (*TaskQueueQueryTasksResponse_Task_RunLog) GetResponseCode 

func (x *TaskQueueQueryTasksResponse_Task_RunLog) GetResponseCode() int64

func (*TaskQueueQueryTasksResponse_Task_RunLog) GetRetryReason 

func (x *TaskQueueQueryTasksResponse_Task_RunLog) GetRetryReason() string

func (*TaskQueueQueryTasksResponse_Task_RunLog) ProtoMessage 

func (*TaskQueueQueryTasksResponse_Task_RunLog) ProtoMessage()

func (*TaskQueueQueryTasksResponse_Task_RunLog) ProtoReflect added in v2.0.4 

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

func (*TaskQueueQueryTasksResponse_Task_RunLog) Reset 

func (x *TaskQueueQueryTasksResponse_Task_RunLog) Reset()

func (*TaskQueueQueryTasksResponse_Task_RunLog) String 

func (x *TaskQueueQueryTasksResponse_Task_RunLog) String() string

type TaskQueueRetryParameters 

type TaskQueueRetryParameters struct {
	RetryLimit    *int32   `protobuf:"varint,1,opt,name=retry_limit,json=retryLimit" json:"retry_limit,omitempty"`
	AgeLimitSec   *int64   `protobuf:"varint,2,opt,name=age_limit_sec,json=ageLimitSec" json:"age_limit_sec,omitempty"`
	MinBackoffSec *float64 `protobuf:"fixed64,3,opt,name=min_backoff_sec,json=minBackoffSec,def=0.1" json:"min_backoff_sec,omitempty"`
	MaxBackoffSec *float64 `protobuf:"fixed64,4,opt,name=max_backoff_sec,json=maxBackoffSec,def=3600" json:"max_backoff_sec,omitempty"`
	MaxDoublings  *int32   `protobuf:"varint,5,opt,name=max_doublings,json=maxDoublings,def=16" json:"max_doublings,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskQueueRetryParameters) Descriptor deprecated 

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

Deprecated: Use TaskQueueRetryParameters.ProtoReflect.Descriptor instead.

func (*TaskQueueRetryParameters) GetAgeLimitSec 

func (x *TaskQueueRetryParameters) GetAgeLimitSec() int64

func (*TaskQueueRetryParameters) GetMaxBackoffSec 

func (x *TaskQueueRetryParameters) GetMaxBackoffSec() float64

func (*TaskQueueRetryParameters) GetMaxDoublings 

func (x *TaskQueueRetryParameters) GetMaxDoublings() int32

func (*TaskQueueRetryParameters) GetMinBackoffSec 

func (x *TaskQueueRetryParameters) GetMinBackoffSec() float64

func (*TaskQueueRetryParameters) GetRetryLimit 

func (x *TaskQueueRetryParameters) GetRetryLimit() int32

func (*TaskQueueRetryParameters) ProtoMessage 

func (*TaskQueueRetryParameters) ProtoMessage()

func (*TaskQueueRetryParameters) ProtoReflect added in v2.0.4 

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

func (*TaskQueueRetryParameters) Reset 

func (x *TaskQueueRetryParameters) Reset()

func (*TaskQueueRetryParameters) String 

func (x *TaskQueueRetryParameters) String() string

type TaskQueueScannerQueueInfo 

type TaskQueueScannerQueueInfo struct {
	ExecutedLastMinute      *int64   `protobuf:"varint,1,req,name=executed_last_minute,json=executedLastMinute" json:"executed_last_minute,omitempty"`
	ExecutedLastHour        *int64   `protobuf:"varint,2,req,name=executed_last_hour,json=executedLastHour" json:"executed_last_hour,omitempty"`
	SamplingDurationSeconds *float64 `` /* 127-byte string literal not displayed */
	RequestsInFlight        *int32   `protobuf:"varint,4,opt,name=requests_in_flight,json=requestsInFlight" json:"requests_in_flight,omitempty"`
	EnforcedRate            *float64 `protobuf:"fixed64,5,opt,name=enforced_rate,json=enforcedRate" json:"enforced_rate,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskQueueScannerQueueInfo) Descriptor deprecated 

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

Deprecated: Use TaskQueueScannerQueueInfo.ProtoReflect.Descriptor instead.

func (*TaskQueueScannerQueueInfo) GetEnforcedRate 

func (x *TaskQueueScannerQueueInfo) GetEnforcedRate() float64

func (*TaskQueueScannerQueueInfo) GetExecutedLastHour 

func (x *TaskQueueScannerQueueInfo) GetExecutedLastHour() int64

func (*TaskQueueScannerQueueInfo) GetExecutedLastMinute 

func (x *TaskQueueScannerQueueInfo) GetExecutedLastMinute() int64

func (*TaskQueueScannerQueueInfo) GetRequestsInFlight 

func (x *TaskQueueScannerQueueInfo) GetRequestsInFlight() int32

func (*TaskQueueScannerQueueInfo) GetSamplingDurationSeconds 

func (x *TaskQueueScannerQueueInfo) GetSamplingDurationSeconds() float64

func (*TaskQueueScannerQueueInfo) ProtoMessage 

func (*TaskQueueScannerQueueInfo) ProtoMessage()

func (*TaskQueueScannerQueueInfo) ProtoReflect added in v2.0.4 

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

func (*TaskQueueScannerQueueInfo) Reset 

func (x *TaskQueueScannerQueueInfo) Reset()

func (*TaskQueueScannerQueueInfo) String 

func (x *TaskQueueScannerQueueInfo) String() string

type TaskQueueServiceError 

type TaskQueueServiceError struct {
	// contains filtered or unexported fields
}

func (*TaskQueueServiceError) Descriptor deprecated 

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

Deprecated: Use TaskQueueServiceError.ProtoReflect.Descriptor instead.

func (*TaskQueueServiceError) ProtoMessage 

func (*TaskQueueServiceError) ProtoMessage()

func (*TaskQueueServiceError) ProtoReflect added in v2.0.4 

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

func (*TaskQueueServiceError) Reset 

func (x *TaskQueueServiceError) Reset()

func (*TaskQueueServiceError) String 

func (x *TaskQueueServiceError) String() string

type TaskQueueServiceError_ErrorCode 

type TaskQueueServiceError_ErrorCode int32
const (
	TaskQueueServiceError_OK                              TaskQueueServiceError_ErrorCode = 0
	TaskQueueServiceError_UNKNOWN_QUEUE                   TaskQueueServiceError_ErrorCode = 1
	TaskQueueServiceError_TRANSIENT_ERROR                 TaskQueueServiceError_ErrorCode = 2
	TaskQueueServiceError_INTERNAL_ERROR                  TaskQueueServiceError_ErrorCode = 3
	TaskQueueServiceError_TASK_TOO_LARGE                  TaskQueueServiceError_ErrorCode = 4
	TaskQueueServiceError_INVALID_TASK_NAME               TaskQueueServiceError_ErrorCode = 5
	TaskQueueServiceError_INVALID_QUEUE_NAME              TaskQueueServiceError_ErrorCode = 6
	TaskQueueServiceError_INVALID_URL                     TaskQueueServiceError_ErrorCode = 7
	TaskQueueServiceError_INVALID_QUEUE_RATE              TaskQueueServiceError_ErrorCode = 8
	TaskQueueServiceError_PERMISSION_DENIED               TaskQueueServiceError_ErrorCode = 9
	TaskQueueServiceError_TASK_ALREADY_EXISTS             TaskQueueServiceError_ErrorCode = 10
	TaskQueueServiceError_TOMBSTONED_TASK                 TaskQueueServiceError_ErrorCode = 11
	TaskQueueServiceError_INVALID_ETA                     TaskQueueServiceError_ErrorCode = 12
	TaskQueueServiceError_INVALID_REQUEST                 TaskQueueServiceError_ErrorCode = 13
	TaskQueueServiceError_UNKNOWN_TASK                    TaskQueueServiceError_ErrorCode = 14
	TaskQueueServiceError_TOMBSTONED_QUEUE                TaskQueueServiceError_ErrorCode = 15
	TaskQueueServiceError_DUPLICATE_TASK_NAME             TaskQueueServiceError_ErrorCode = 16
	TaskQueueServiceError_SKIPPED                         TaskQueueServiceError_ErrorCode = 17
	TaskQueueServiceError_TOO_MANY_TASKS                  TaskQueueServiceError_ErrorCode = 18
	TaskQueueServiceError_INVALID_PAYLOAD                 TaskQueueServiceError_ErrorCode = 19
	TaskQueueServiceError_INVALID_RETRY_PARAMETERS        TaskQueueServiceError_ErrorCode = 20
	TaskQueueServiceError_INVALID_QUEUE_MODE              TaskQueueServiceError_ErrorCode = 21
	TaskQueueServiceError_ACL_LOOKUP_ERROR                TaskQueueServiceError_ErrorCode = 22
	TaskQueueServiceError_TRANSACTIONAL_REQUEST_TOO_LARGE TaskQueueServiceError_ErrorCode = 23
	TaskQueueServiceError_INCORRECT_CREATOR_NAME          TaskQueueServiceError_ErrorCode = 24
	TaskQueueServiceError_TASK_LEASE_EXPIRED              TaskQueueServiceError_ErrorCode = 25
	TaskQueueServiceError_QUEUE_PAUSED                    TaskQueueServiceError_ErrorCode = 26
	TaskQueueServiceError_INVALID_TAG                     TaskQueueServiceError_ErrorCode = 27
	// Reserved range for the Datastore error codes.
	// Original Datastore error code is shifted by DATASTORE_ERROR offset.
	TaskQueueServiceError_DATASTORE_ERROR TaskQueueServiceError_ErrorCode = 10000
)

func (TaskQueueServiceError_ErrorCode) Descriptor added in v2.0.4 

func (TaskQueueServiceError_ErrorCode) Descriptor() protoreflect.EnumDescriptor

func (TaskQueueServiceError_ErrorCode) Enum 

func (x TaskQueueServiceError_ErrorCode) Enum() *TaskQueueServiceError_ErrorCode

func (TaskQueueServiceError_ErrorCode) EnumDescriptor deprecated 

func (TaskQueueServiceError_ErrorCode) EnumDescriptor() ([]byte, []int)

Deprecated: Use TaskQueueServiceError_ErrorCode.Descriptor instead.

func (TaskQueueServiceError_ErrorCode) Number added in v2.0.4 

func (x TaskQueueServiceError_ErrorCode) Number() protoreflect.EnumNumber

func (TaskQueueServiceError_ErrorCode) String 

func (x TaskQueueServiceError_ErrorCode) String() string

func (TaskQueueServiceError_ErrorCode) Type added in v2.0.4 

func (TaskQueueServiceError_ErrorCode) Type() protoreflect.EnumType

func (*TaskQueueServiceError_ErrorCode) UnmarshalJSON deprecated 

func (x *TaskQueueServiceError_ErrorCode) UnmarshalJSON(b []byte) error

Deprecated: Do not use.

type TaskQueueUpdateQueueRequest 

type TaskQueueUpdateQueueRequest struct {
	AppId                 []byte                    `protobuf:"bytes,1,opt,name=app_id,json=appId" json:"app_id,omitempty"`
	QueueName             []byte                    `protobuf:"bytes,2,req,name=queue_name,json=queueName" json:"queue_name,omitempty"`
	BucketRefillPerSecond *float64                  `protobuf:"fixed64,3,req,name=bucket_refill_per_second,json=bucketRefillPerSecond" json:"bucket_refill_per_second,omitempty"`
	BucketCapacity        *int32                    `protobuf:"varint,4,req,name=bucket_capacity,json=bucketCapacity" json:"bucket_capacity,omitempty"`
	UserSpecifiedRate     *string                   `protobuf:"bytes,5,opt,name=user_specified_rate,json=userSpecifiedRate" json:"user_specified_rate,omitempty"`
	RetryParameters       *TaskQueueRetryParameters `protobuf:"bytes,6,opt,name=retry_parameters,json=retryParameters" json:"retry_parameters,omitempty"`
	MaxConcurrentRequests *int32                    `protobuf:"varint,7,opt,name=max_concurrent_requests,json=maxConcurrentRequests" json:"max_concurrent_requests,omitempty"`
	Mode                  *TaskQueueMode_Mode       `protobuf:"varint,8,opt,name=mode,enum=appengine.v2.TaskQueueMode_Mode,def=0" json:"mode,omitempty"`
	Acl                   *TaskQueueAcl             `protobuf:"bytes,9,opt,name=acl" json:"acl,omitempty"`
	HeaderOverride        []*TaskQueueHttpHeader    `protobuf:"bytes,10,rep,name=header_override,json=headerOverride" json:"header_override,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskQueueUpdateQueueRequest) Descriptor deprecated 

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

Deprecated: Use TaskQueueUpdateQueueRequest.ProtoReflect.Descriptor instead.

func (*TaskQueueUpdateQueueRequest) GetAcl 

func (x *TaskQueueUpdateQueueRequest) GetAcl() *TaskQueueAcl

func (*TaskQueueUpdateQueueRequest) GetAppId 

func (x *TaskQueueUpdateQueueRequest) GetAppId() []byte

func (*TaskQueueUpdateQueueRequest) GetBucketCapacity 

func (x *TaskQueueUpdateQueueRequest) GetBucketCapacity() int32

func (*TaskQueueUpdateQueueRequest) GetBucketRefillPerSecond 

func (x *TaskQueueUpdateQueueRequest) GetBucketRefillPerSecond() float64

func (*TaskQueueUpdateQueueRequest) GetHeaderOverride 

func (x *TaskQueueUpdateQueueRequest) GetHeaderOverride() []*TaskQueueHttpHeader

func (*TaskQueueUpdateQueueRequest) GetMaxConcurrentRequests 

func (x *TaskQueueUpdateQueueRequest) GetMaxConcurrentRequests() int32

func (*TaskQueueUpdateQueueRequest) GetMode 

func (x *TaskQueueUpdateQueueRequest) GetMode() TaskQueueMode_Mode

func (*TaskQueueUpdateQueueRequest) GetQueueName 

func (x *TaskQueueUpdateQueueRequest) GetQueueName() []byte

func (*TaskQueueUpdateQueueRequest) GetRetryParameters 

func (x *TaskQueueUpdateQueueRequest) GetRetryParameters() *TaskQueueRetryParameters

func (*TaskQueueUpdateQueueRequest) GetUserSpecifiedRate 

func (x *TaskQueueUpdateQueueRequest) GetUserSpecifiedRate() string

func (*TaskQueueUpdateQueueRequest) ProtoMessage 

func (*TaskQueueUpdateQueueRequest) ProtoMessage()

func (*TaskQueueUpdateQueueRequest) ProtoReflect added in v2.0.4 

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

func (*TaskQueueUpdateQueueRequest) Reset 

func (x *TaskQueueUpdateQueueRequest) Reset()

func (*TaskQueueUpdateQueueRequest) String 

func (x *TaskQueueUpdateQueueRequest) String() string

type TaskQueueUpdateQueueResponse 

type TaskQueueUpdateQueueResponse struct {
	// contains filtered or unexported fields
}

func (*TaskQueueUpdateQueueResponse) Descriptor deprecated 

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

Deprecated: Use TaskQueueUpdateQueueResponse.ProtoReflect.Descriptor instead.

func (*TaskQueueUpdateQueueResponse) ProtoMessage 

func (*TaskQueueUpdateQueueResponse) ProtoMessage()

func (*TaskQueueUpdateQueueResponse) ProtoReflect added in v2.0.4 

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

func (*TaskQueueUpdateQueueResponse) Reset 

func (x *TaskQueueUpdateQueueResponse) Reset()

func (*TaskQueueUpdateQueueResponse) String 

func (x *TaskQueueUpdateQueueResponse) String() string

type TaskQueueUpdateStorageLimitRequest 

type TaskQueueUpdateStorageLimitRequest struct {
	AppId []byte `protobuf:"bytes,1,req,name=app_id,json=appId" json:"app_id,omitempty"`
	Limit *int64 `protobuf:"varint,2,req,name=limit" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskQueueUpdateStorageLimitRequest) Descriptor deprecated 

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

Deprecated: Use TaskQueueUpdateStorageLimitRequest.ProtoReflect.Descriptor instead.

func (*TaskQueueUpdateStorageLimitRequest) GetAppId 

func (x *TaskQueueUpdateStorageLimitRequest) GetAppId() []byte

func (*TaskQueueUpdateStorageLimitRequest) GetLimit 

func (x *TaskQueueUpdateStorageLimitRequest) GetLimit() int64

func (*TaskQueueUpdateStorageLimitRequest) ProtoMessage 

func (*TaskQueueUpdateStorageLimitRequest) ProtoMessage()

func (*TaskQueueUpdateStorageLimitRequest) ProtoReflect added in v2.0.4 

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

func (*TaskQueueUpdateStorageLimitRequest) Reset 

func (x *TaskQueueUpdateStorageLimitRequest) Reset()

func (*TaskQueueUpdateStorageLimitRequest) String 

func (x *TaskQueueUpdateStorageLimitRequest) String() string

type TaskQueueUpdateStorageLimitResponse 

type TaskQueueUpdateStorageLimitResponse struct {
	NewLimit *int64 `protobuf:"varint,1,req,name=new_limit,json=newLimit" json:"new_limit,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskQueueUpdateStorageLimitResponse) Descriptor deprecated 

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

Deprecated: Use TaskQueueUpdateStorageLimitResponse.ProtoReflect.Descriptor instead.

func (*TaskQueueUpdateStorageLimitResponse) GetNewLimit 

func (x *TaskQueueUpdateStorageLimitResponse) GetNewLimit() int64

func (*TaskQueueUpdateStorageLimitResponse) ProtoMessage 

func (*TaskQueueUpdateStorageLimitResponse) ProtoMessage()

func (*TaskQueueUpdateStorageLimitResponse) ProtoReflect added in v2.0.4 

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

func (*TaskQueueUpdateStorageLimitResponse) Reset 

func (x *TaskQueueUpdateStorageLimitResponse) Reset()

func (*TaskQueueUpdateStorageLimitResponse) String 

func (x *TaskQueueUpdateStorageLimitResponse) 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.