taskqueue

package
v0.0.0-...-0e76970 Latest Latest
Warning

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

 Go to latest Published: Dec 13, 2022 License: Apache-2.0, Apache-2.0 Imports: 4 Imported by: 0

Documentation

Overview

Package taskqueue is a generated protocol buffer package.

It is generated from these files: 

google.golang.org/appengine/internal/taskqueue/taskqueue_service.proto

It has these top-level messages: 

TaskQueueServiceError
TaskPayload
TaskQueueRetryParameters
TaskQueueAcl
TaskQueueHttpHeader
TaskQueueMode
TaskQueueAddRequest
TaskQueueAddResponse
TaskQueueBulkAddRequest
TaskQueueBulkAddResponse
TaskQueueDeleteRequest
TaskQueueDeleteResponse
TaskQueueForceRunRequest
TaskQueueForceRunResponse
TaskQueueUpdateQueueRequest
TaskQueueUpdateQueueResponse
TaskQueueFetchQueuesRequest
TaskQueueFetchQueuesResponse
TaskQueueFetchQueueStatsRequest
TaskQueueScannerQueueInfo
TaskQueueFetchQueueStatsResponse
TaskQueuePauseQueueRequest
TaskQueuePauseQueueResponse
TaskQueuePurgeQueueRequest
TaskQueuePurgeQueueResponse
TaskQueueDeleteQueueRequest
TaskQueueDeleteQueueResponse
TaskQueueDeleteGroupRequest
TaskQueueDeleteGroupResponse
TaskQueueQueryTasksRequest
TaskQueueQueryTasksResponse
TaskQueueFetchTaskRequest
TaskQueueFetchTaskResponse
TaskQueueUpdateStorageLimitRequest
TaskQueueUpdateStorageLimitResponse
TaskQueueQueryAndOwnTasksRequest
TaskQueueQueryAndOwnTasksResponse
TaskQueueModifyTaskLeaseRequest
TaskQueueModifyTaskLeaseResponse

Index

Constants

View Source 
const Default_TaskQueueFetchQueueStatsRequest_MaxNumTasks int32 = 0
View Source 
const Default_TaskQueueFetchQueuesResponse_Queue_CreatorName string = "apphosting"
View Source 
const Default_TaskQueueFetchQueuesResponse_Queue_Paused bool = false
View Source 
const Default_TaskQueueQueryAndOwnTasksRequest_GroupByTag bool = false
View Source 
const Default_TaskQueueQueryAndOwnTasksResponse_Task_RetryCount int32 = 0
View Source 
const Default_TaskQueueQueryTasksRequest_MaxRows int32 = 1
View Source 
const Default_TaskQueueQueryTasksResponse_Task_ExecutionCount int32 = 0
View Source 
const Default_TaskQueueQueryTasksResponse_Task_RetryCount int32 = 0
View Source 
const Default_TaskQueueRetryParameters_MaxBackoffSec float64 = 3600
View Source 
const Default_TaskQueueRetryParameters_MaxDoublings int32 = 16
View Source 
const Default_TaskQueueRetryParameters_MinBackoffSec float64 = 0.1

Variables

View Source 
var TaskQueueAddRequest_RequestMethod_name = map[int32]string{
	1: "GET",
	2: "POST",
	3: "HEAD",
	4: "PUT",
	5: "DELETE",
}
View Source 
var TaskQueueAddRequest_RequestMethod_value = map[string]int32{
	"GET":    1,
	"POST":   2,
	"HEAD":   3,
	"PUT":    4,
	"DELETE": 5,
}
View Source 
var TaskQueueMode_Mode_name = map[int32]string{
	0: "PUSH",
	1: "PULL",
}
View Source 
var TaskQueueMode_Mode_value = map[string]int32{
	"PUSH": 0,
	"PULL": 1,
}
View Source 
var TaskQueueQueryTasksResponse_Task_RequestMethod_name = map[int32]string{
	1: "GET",
	2: "POST",
	3: "HEAD",
	4: "PUT",
	5: "DELETE",
}
View Source 
var TaskQueueQueryTasksResponse_Task_RequestMethod_value = map[string]int32{
	"GET":    1,
	"POST":   2,
	"HEAD":   3,
	"PUT":    4,
	"DELETE": 5,
}
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",
}
View Source 
var 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,
}

Functions

This section is empty.

Types

type TaskPayload 

type TaskPayload struct {
	XXX_extensions   map[int32]proto.Extension `json:"-"`
	XXX_unrecognized []byte                    `json:"-"`
}

func (*TaskPayload) ExtensionMap 

func (m *TaskPayload) ExtensionMap() map[int32]proto.Extension

func (*TaskPayload) ExtensionRangeArray 

func (*TaskPayload) ExtensionRangeArray() []proto.ExtensionRange

func (*TaskPayload) Marshal 

func (m *TaskPayload) Marshal() ([]byte, error)

func (*TaskPayload) MarshalJSON 

func (m *TaskPayload) MarshalJSON() ([]byte, error)

func (*TaskPayload) ProtoMessage 

func (*TaskPayload) ProtoMessage()

func (*TaskPayload) Reset 

func (m *TaskPayload) Reset()

func (*TaskPayload) String 

func (m *TaskPayload) String() string

func (*TaskPayload) Unmarshal 

func (m *TaskPayload) Unmarshal(buf []byte) error

func (*TaskPayload) UnmarshalJSON 

func (m *TaskPayload) UnmarshalJSON(buf []byte) error

type TaskQueueAcl 

type TaskQueueAcl struct {
	UserEmail        [][]byte `protobuf:"bytes,1,rep,name=user_email" json:"user_email,omitempty"`
	WriterEmail      [][]byte `protobuf:"bytes,2,rep,name=writer_email" json:"writer_email,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*TaskQueueAcl) GetUserEmail 

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

func (*TaskQueueAcl) GetWriterEmail 

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

func (*TaskQueueAcl) ProtoMessage 

func (*TaskQueueAcl) ProtoMessage()

func (*TaskQueueAcl) Reset 

func (m *TaskQueueAcl) Reset()

func (*TaskQueueAcl) String 

func (m *TaskQueueAcl) String() string

type TaskQueueAddRequest 

type TaskQueueAddRequest struct {
	QueueName        []byte                             `protobuf:"bytes,1,req,name=queue_name" json:"queue_name,omitempty"`
	TaskName         []byte                             `protobuf:"bytes,2,req,name=task_name" json:"task_name,omitempty"`
	EtaUsec          *int64                             `protobuf:"varint,3,req,name=eta_usec" json:"eta_usec,omitempty"`
	Method           *TaskQueueAddRequest_RequestMethod `protobuf:"varint,5,opt,name=method,enum=appengine.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,omitempty"`
	Body             []byte                             `protobuf:"bytes,9,opt,name=body" json:"body,omitempty"`
	Transaction      *appengine.Transaction             `protobuf:"bytes,10,opt,name=transaction" json:"transaction,omitempty"`
	AppId            []byte                             `protobuf:"bytes,11,opt,name=app_id" json:"app_id,omitempty"`
	Crontimetable    *TaskQueueAddRequest_CronTimetable `protobuf:"group,12,opt,name=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:"retry_parameters,omitempty"`
	Mode             *TaskQueueMode_Mode                `protobuf:"varint,18,opt,name=mode,enum=appengine.TaskQueueMode_Mode,def=0" json:"mode,omitempty"`
	Tag              []byte                             `protobuf:"bytes,19,opt,name=tag" json:"tag,omitempty"`
	XXX_unrecognized []byte                             `json:"-"`
}

func (*TaskQueueAddRequest) GetAppId 

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

func (*TaskQueueAddRequest) GetBody 

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

func (*TaskQueueAddRequest) GetCrontimetable 

func (m *TaskQueueAddRequest) GetCrontimetable() *TaskQueueAddRequest_CronTimetable

func (*TaskQueueAddRequest) GetDescription 

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

func (*TaskQueueAddRequest) GetEtaUsec 

func (m *TaskQueueAddRequest) GetEtaUsec() int64

func (*TaskQueueAddRequest) GetHeader 

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

func (*TaskQueueAddRequest) GetMethod 

func (m *TaskQueueAddRequest) GetMethod() TaskQueueAddRequest_RequestMethod

func (*TaskQueueAddRequest) GetMode 

func (m *TaskQueueAddRequest) GetMode() TaskQueueMode_Mode

func (*TaskQueueAddRequest) GetPayload 

func (m *TaskQueueAddRequest) GetPayload() *TaskPayload

func (*TaskQueueAddRequest) GetQueueName 

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

func (*TaskQueueAddRequest) GetRetryParameters 

func (m *TaskQueueAddRequest) GetRetryParameters() *TaskQueueRetryParameters

func (*TaskQueueAddRequest) GetTag 

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

func (*TaskQueueAddRequest) GetTaskName 

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

func (*TaskQueueAddRequest) GetTransaction 

func (m *TaskQueueAddRequest) GetTransaction() *appengine.Transaction

func (*TaskQueueAddRequest) GetUrl 

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

func (*TaskQueueAddRequest) ProtoMessage 

func (*TaskQueueAddRequest) ProtoMessage()

func (*TaskQueueAddRequest) Reset 

func (m *TaskQueueAddRequest) Reset()

func (*TaskQueueAddRequest) String 

func (m *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"`
	XXX_unrecognized []byte `json:"-"`
}

func (*TaskQueueAddRequest_CronTimetable) GetSchedule 

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

func (*TaskQueueAddRequest_CronTimetable) GetTimezone 

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

func (*TaskQueueAddRequest_CronTimetable) ProtoMessage 

func (*TaskQueueAddRequest_CronTimetable) ProtoMessage()

func (*TaskQueueAddRequest_CronTimetable) Reset 

func (m *TaskQueueAddRequest_CronTimetable) Reset()

func (*TaskQueueAddRequest_CronTimetable) String 

func (m *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"`
	XXX_unrecognized []byte `json:"-"`
}

func (*TaskQueueAddRequest_Header) GetKey 

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

func (*TaskQueueAddRequest_Header) GetValue 

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

func (*TaskQueueAddRequest_Header) ProtoMessage 

func (*TaskQueueAddRequest_Header) ProtoMessage()

func (*TaskQueueAddRequest_Header) Reset 

func (m *TaskQueueAddRequest_Header) Reset()

func (*TaskQueueAddRequest_Header) String 

func (m *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
)
const Default_TaskQueueAddRequest_Method TaskQueueAddRequest_RequestMethod = TaskQueueAddRequest_POST

func (TaskQueueAddRequest_RequestMethod) Enum 

func (x TaskQueueAddRequest_RequestMethod) Enum() *TaskQueueAddRequest_RequestMethod

func (TaskQueueAddRequest_RequestMethod) String 

func (x TaskQueueAddRequest_RequestMethod) String() string

func (*TaskQueueAddRequest_RequestMethod) UnmarshalJSON 

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

type TaskQueueAddResponse 

type TaskQueueAddResponse struct {
	ChosenTaskName   []byte `protobuf:"bytes,1,opt,name=chosen_task_name" json:"chosen_task_name,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*TaskQueueAddResponse) GetChosenTaskName 

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

func (*TaskQueueAddResponse) ProtoMessage 

func (*TaskQueueAddResponse) ProtoMessage()

func (*TaskQueueAddResponse) Reset 

func (m *TaskQueueAddResponse) Reset()

func (*TaskQueueAddResponse) String 

func (m *TaskQueueAddResponse) String() string

type TaskQueueBulkAddRequest 

type TaskQueueBulkAddRequest struct {
	AddRequest       []*TaskQueueAddRequest `protobuf:"bytes,1,rep,name=add_request" json:"add_request,omitempty"`
	XXX_unrecognized []byte                 `json:"-"`
}

func (*TaskQueueBulkAddRequest) GetAddRequest 

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

func (*TaskQueueBulkAddRequest) ProtoMessage 

func (*TaskQueueBulkAddRequest) ProtoMessage()

func (*TaskQueueBulkAddRequest) Reset 

func (m *TaskQueueBulkAddRequest) Reset()

func (*TaskQueueBulkAddRequest) String 

func (m *TaskQueueBulkAddRequest) String() string

type TaskQueueBulkAddResponse 

type TaskQueueBulkAddResponse struct {
	Taskresult       []*TaskQueueBulkAddResponse_TaskResult `protobuf:"group,1,rep,name=TaskResult" json:"taskresult,omitempty"`
	XXX_unrecognized []byte                                 `json:"-"`
}

func (*TaskQueueBulkAddResponse) GetTaskresult 

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

func (*TaskQueueBulkAddResponse) ProtoMessage 

func (*TaskQueueBulkAddResponse) ProtoMessage()

func (*TaskQueueBulkAddResponse) Reset 

func (m *TaskQueueBulkAddResponse) Reset()

func (*TaskQueueBulkAddResponse) String 

func (m *TaskQueueBulkAddResponse) String() string

type TaskQueueBulkAddResponse_TaskResult 

type TaskQueueBulkAddResponse_TaskResult struct {
	Result           *TaskQueueServiceError_ErrorCode `protobuf:"varint,2,req,name=result,enum=appengine.TaskQueueServiceError_ErrorCode" json:"result,omitempty"`
	ChosenTaskName   []byte                           `protobuf:"bytes,3,opt,name=chosen_task_name" json:"chosen_task_name,omitempty"`
	XXX_unrecognized []byte                           `json:"-"`
}

func (*TaskQueueBulkAddResponse_TaskResult) GetChosenTaskName 

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

func (*TaskQueueBulkAddResponse_TaskResult) GetResult 

func (m *TaskQueueBulkAddResponse_TaskResult) GetResult() TaskQueueServiceError_ErrorCode

func (*TaskQueueBulkAddResponse_TaskResult) ProtoMessage 

func (*TaskQueueBulkAddResponse_TaskResult) ProtoMessage()

func (*TaskQueueBulkAddResponse_TaskResult) Reset 

func (m *TaskQueueBulkAddResponse_TaskResult) Reset()

func (*TaskQueueBulkAddResponse_TaskResult) String 

func (m *TaskQueueBulkAddResponse_TaskResult) String() string

type TaskQueueDeleteGroupRequest 

type TaskQueueDeleteGroupRequest struct {
	AppId            []byte `protobuf:"bytes,1,req,name=app_id" json:"app_id,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*TaskQueueDeleteGroupRequest) GetAppId 

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

func (*TaskQueueDeleteGroupRequest) ProtoMessage 

func (*TaskQueueDeleteGroupRequest) ProtoMessage()

func (*TaskQueueDeleteGroupRequest) Reset 

func (m *TaskQueueDeleteGroupRequest) Reset()

func (*TaskQueueDeleteGroupRequest) String 

func (m *TaskQueueDeleteGroupRequest) String() string

type TaskQueueDeleteGroupResponse 

type TaskQueueDeleteGroupResponse struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*TaskQueueDeleteGroupResponse) ProtoMessage 

func (*TaskQueueDeleteGroupResponse) ProtoMessage()

func (*TaskQueueDeleteGroupResponse) Reset 

func (m *TaskQueueDeleteGroupResponse) Reset()

func (*TaskQueueDeleteGroupResponse) String 

func (m *TaskQueueDeleteGroupResponse) String() string

type TaskQueueDeleteQueueRequest 

type TaskQueueDeleteQueueRequest struct {
	AppId            []byte `protobuf:"bytes,1,req,name=app_id" json:"app_id,omitempty"`
	QueueName        []byte `protobuf:"bytes,2,req,name=queue_name" json:"queue_name,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*TaskQueueDeleteQueueRequest) GetAppId 

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

func (*TaskQueueDeleteQueueRequest) GetQueueName 

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

func (*TaskQueueDeleteQueueRequest) ProtoMessage 

func (*TaskQueueDeleteQueueRequest) ProtoMessage()

func (*TaskQueueDeleteQueueRequest) Reset 

func (m *TaskQueueDeleteQueueRequest) Reset()

func (*TaskQueueDeleteQueueRequest) String 

func (m *TaskQueueDeleteQueueRequest) String() string

type TaskQueueDeleteQueueResponse 

type TaskQueueDeleteQueueResponse struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*TaskQueueDeleteQueueResponse) ProtoMessage 

func (*TaskQueueDeleteQueueResponse) ProtoMessage()

func (*TaskQueueDeleteQueueResponse) Reset 

func (m *TaskQueueDeleteQueueResponse) Reset()

func (*TaskQueueDeleteQueueResponse) String 

func (m *TaskQueueDeleteQueueResponse) String() string

type TaskQueueDeleteRequest 

type TaskQueueDeleteRequest struct {
	QueueName        []byte   `protobuf:"bytes,1,req,name=queue_name" json:"queue_name,omitempty"`
	TaskName         [][]byte `protobuf:"bytes,2,rep,name=task_name" json:"task_name,omitempty"`
	AppId            []byte   `protobuf:"bytes,3,opt,name=app_id" json:"app_id,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*TaskQueueDeleteRequest) GetAppId 

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

func (*TaskQueueDeleteRequest) GetQueueName 

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

func (*TaskQueueDeleteRequest) GetTaskName 

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

func (*TaskQueueDeleteRequest) ProtoMessage 

func (*TaskQueueDeleteRequest) ProtoMessage()

func (*TaskQueueDeleteRequest) Reset 

func (m *TaskQueueDeleteRequest) Reset()

func (*TaskQueueDeleteRequest) String 

func (m *TaskQueueDeleteRequest) String() string

type TaskQueueDeleteResponse 

type TaskQueueDeleteResponse struct {
	Result           []TaskQueueServiceError_ErrorCode `protobuf:"varint,3,rep,name=result,enum=appengine.TaskQueueServiceError_ErrorCode" json:"result,omitempty"`
	XXX_unrecognized []byte                            `json:"-"`
}

func (*TaskQueueDeleteResponse) GetResult 

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

func (*TaskQueueDeleteResponse) ProtoMessage 

func (*TaskQueueDeleteResponse) ProtoMessage()

func (*TaskQueueDeleteResponse) Reset 

func (m *TaskQueueDeleteResponse) Reset()

func (*TaskQueueDeleteResponse) String 

func (m *TaskQueueDeleteResponse) String() string

type TaskQueueFetchQueueStatsRequest 

type TaskQueueFetchQueueStatsRequest struct {
	AppId            []byte   `protobuf:"bytes,1,opt,name=app_id" json:"app_id,omitempty"`
	QueueName        [][]byte `protobuf:"bytes,2,rep,name=queue_name" json:"queue_name,omitempty"`
	MaxNumTasks      *int32   `protobuf:"varint,3,opt,name=max_num_tasks,def=0" json:"max_num_tasks,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*TaskQueueFetchQueueStatsRequest) GetAppId 

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

func (*TaskQueueFetchQueueStatsRequest) GetMaxNumTasks 

func (m *TaskQueueFetchQueueStatsRequest) GetMaxNumTasks() int32

func (*TaskQueueFetchQueueStatsRequest) GetQueueName 

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

func (*TaskQueueFetchQueueStatsRequest) ProtoMessage 

func (*TaskQueueFetchQueueStatsRequest) ProtoMessage()

func (*TaskQueueFetchQueueStatsRequest) Reset 

func (m *TaskQueueFetchQueueStatsRequest) Reset()

func (*TaskQueueFetchQueueStatsRequest) String 

func (m *TaskQueueFetchQueueStatsRequest) String() string

type TaskQueueFetchQueueStatsResponse 

type TaskQueueFetchQueueStatsResponse struct {
	Queuestats       []*TaskQueueFetchQueueStatsResponse_QueueStats `protobuf:"group,1,rep,name=QueueStats" json:"queuestats,omitempty"`
	XXX_unrecognized []byte                                         `json:"-"`
}

func (*TaskQueueFetchQueueStatsResponse) GetQueuestats 

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

func (*TaskQueueFetchQueueStatsResponse) ProtoMessage 

func (*TaskQueueFetchQueueStatsResponse) ProtoMessage()

func (*TaskQueueFetchQueueStatsResponse) Reset 

func (m *TaskQueueFetchQueueStatsResponse) Reset()

func (*TaskQueueFetchQueueStatsResponse) String 

func (m *TaskQueueFetchQueueStatsResponse) String() string

type TaskQueueFetchQueueStatsResponse_QueueStats 

type TaskQueueFetchQueueStatsResponse_QueueStats struct {
	NumTasks         *int32                     `protobuf:"varint,2,req,name=num_tasks" json:"num_tasks,omitempty"`
	OldestEtaUsec    *int64                     `protobuf:"varint,3,req,name=oldest_eta_usec" json:"oldest_eta_usec,omitempty"`
	ScannerInfo      *TaskQueueScannerQueueInfo `protobuf:"bytes,4,opt,name=scanner_info" json:"scanner_info,omitempty"`
	XXX_unrecognized []byte                     `json:"-"`
}

func (*TaskQueueFetchQueueStatsResponse_QueueStats) GetNumTasks 

func (m *TaskQueueFetchQueueStatsResponse_QueueStats) GetNumTasks() int32

func (*TaskQueueFetchQueueStatsResponse_QueueStats) GetOldestEtaUsec 

func (m *TaskQueueFetchQueueStatsResponse_QueueStats) GetOldestEtaUsec() int64

func (*TaskQueueFetchQueueStatsResponse_QueueStats) GetScannerInfo 

func (m *TaskQueueFetchQueueStatsResponse_QueueStats) GetScannerInfo() *TaskQueueScannerQueueInfo

func (*TaskQueueFetchQueueStatsResponse_QueueStats) ProtoMessage 

func (*TaskQueueFetchQueueStatsResponse_QueueStats) ProtoMessage()

func (*TaskQueueFetchQueueStatsResponse_QueueStats) Reset 

func (m *TaskQueueFetchQueueStatsResponse_QueueStats) Reset()

func (*TaskQueueFetchQueueStatsResponse_QueueStats) String 

func (m *TaskQueueFetchQueueStatsResponse_QueueStats) String() string

type TaskQueueFetchQueuesRequest 

type TaskQueueFetchQueuesRequest struct {
	AppId            []byte `protobuf:"bytes,1,opt,name=app_id" json:"app_id,omitempty"`
	MaxRows          *int32 `protobuf:"varint,2,req,name=max_rows" json:"max_rows,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*TaskQueueFetchQueuesRequest) GetAppId 

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

func (*TaskQueueFetchQueuesRequest) GetMaxRows 

func (m *TaskQueueFetchQueuesRequest) GetMaxRows() int32

func (*TaskQueueFetchQueuesRequest) ProtoMessage 

func (*TaskQueueFetchQueuesRequest) ProtoMessage()

func (*TaskQueueFetchQueuesRequest) Reset 

func (m *TaskQueueFetchQueuesRequest) Reset()

func (*TaskQueueFetchQueuesRequest) String 

func (m *TaskQueueFetchQueuesRequest) String() string

type TaskQueueFetchQueuesResponse 

type TaskQueueFetchQueuesResponse struct {
	Queue            []*TaskQueueFetchQueuesResponse_Queue `protobuf:"group,1,rep,name=Queue" json:"queue,omitempty"`
	XXX_unrecognized []byte                                `json:"-"`
}

func (*TaskQueueFetchQueuesResponse) GetQueue 

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

func (*TaskQueueFetchQueuesResponse) ProtoMessage 

func (*TaskQueueFetchQueuesResponse) ProtoMessage()

func (*TaskQueueFetchQueuesResponse) Reset 

func (m *TaskQueueFetchQueuesResponse) Reset()

func (*TaskQueueFetchQueuesResponse) String 

func (m *TaskQueueFetchQueuesResponse) String() string

type TaskQueueFetchQueuesResponse_Queue 

type TaskQueueFetchQueuesResponse_Queue struct {
	QueueName             []byte                    `protobuf:"bytes,2,req,name=queue_name" json:"queue_name,omitempty"`
	BucketRefillPerSecond *float64                  `protobuf:"fixed64,3,req,name=bucket_refill_per_second" json:"bucket_refill_per_second,omitempty"`
	BucketCapacity        *float64                  `protobuf:"fixed64,4,req,name=bucket_capacity" json:"bucket_capacity,omitempty"`
	UserSpecifiedRate     *string                   `protobuf:"bytes,5,opt,name=user_specified_rate" 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:"retry_parameters,omitempty"`
	MaxConcurrentRequests *int32                    `protobuf:"varint,8,opt,name=max_concurrent_requests" json:"max_concurrent_requests,omitempty"`
	Mode                  *TaskQueueMode_Mode       `protobuf:"varint,9,opt,name=mode,enum=appengine.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:"header_override,omitempty"`
	CreatorName           *string                   `protobuf:"bytes,12,opt,name=creator_name,def=apphosting" json:"creator_name,omitempty"`
	XXX_unrecognized      []byte                    `json:"-"`
}

func (*TaskQueueFetchQueuesResponse_Queue) GetAcl 

func (m *TaskQueueFetchQueuesResponse_Queue) GetAcl() *TaskQueueAcl

func (*TaskQueueFetchQueuesResponse_Queue) GetBucketCapacity 

func (m *TaskQueueFetchQueuesResponse_Queue) GetBucketCapacity() float64

func (*TaskQueueFetchQueuesResponse_Queue) GetBucketRefillPerSecond 

func (m *TaskQueueFetchQueuesResponse_Queue) GetBucketRefillPerSecond() float64

func (*TaskQueueFetchQueuesResponse_Queue) GetCreatorName 

func (m *TaskQueueFetchQueuesResponse_Queue) GetCreatorName() string

func (*TaskQueueFetchQueuesResponse_Queue) GetHeaderOverride 

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

func (*TaskQueueFetchQueuesResponse_Queue) GetMaxConcurrentRequests 

func (m *TaskQueueFetchQueuesResponse_Queue) GetMaxConcurrentRequests() int32

func (*TaskQueueFetchQueuesResponse_Queue) GetMode 

func (m *TaskQueueFetchQueuesResponse_Queue) GetMode() TaskQueueMode_Mode

func (*TaskQueueFetchQueuesResponse_Queue) GetPaused 

func (m *TaskQueueFetchQueuesResponse_Queue) GetPaused() bool

func (*TaskQueueFetchQueuesResponse_Queue) GetQueueName 

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

func (*TaskQueueFetchQueuesResponse_Queue) GetRetryParameters 

func (m *TaskQueueFetchQueuesResponse_Queue) GetRetryParameters() *TaskQueueRetryParameters

func (*TaskQueueFetchQueuesResponse_Queue) GetUserSpecifiedRate 

func (m *TaskQueueFetchQueuesResponse_Queue) GetUserSpecifiedRate() string

func (*TaskQueueFetchQueuesResponse_Queue) ProtoMessage 

func (*TaskQueueFetchQueuesResponse_Queue) ProtoMessage()

func (*TaskQueueFetchQueuesResponse_Queue) Reset 

func (m *TaskQueueFetchQueuesResponse_Queue) Reset()

func (*TaskQueueFetchQueuesResponse_Queue) String 

func (m *TaskQueueFetchQueuesResponse_Queue) String() string

type TaskQueueFetchTaskRequest 

type TaskQueueFetchTaskRequest struct {
	AppId            []byte `protobuf:"bytes,1,opt,name=app_id" json:"app_id,omitempty"`
	QueueName        []byte `protobuf:"bytes,2,req,name=queue_name" json:"queue_name,omitempty"`
	TaskName         []byte `protobuf:"bytes,3,req,name=task_name" json:"task_name,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*TaskQueueFetchTaskRequest) GetAppId 

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

func (*TaskQueueFetchTaskRequest) GetQueueName 

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

func (*TaskQueueFetchTaskRequest) GetTaskName 

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

func (*TaskQueueFetchTaskRequest) ProtoMessage 

func (*TaskQueueFetchTaskRequest) ProtoMessage()

func (*TaskQueueFetchTaskRequest) Reset 

func (m *TaskQueueFetchTaskRequest) Reset()

func (*TaskQueueFetchTaskRequest) String 

func (m *TaskQueueFetchTaskRequest) String() string

type TaskQueueFetchTaskResponse 

type TaskQueueFetchTaskResponse struct {
	Task             *TaskQueueQueryTasksResponse `protobuf:"bytes,1,req,name=task" json:"task,omitempty"`
	XXX_unrecognized []byte                       `json:"-"`
}

func (*TaskQueueFetchTaskResponse) GetTask 

func (m *TaskQueueFetchTaskResponse) GetTask() *TaskQueueQueryTasksResponse

func (*TaskQueueFetchTaskResponse) ProtoMessage 

func (*TaskQueueFetchTaskResponse) ProtoMessage()

func (*TaskQueueFetchTaskResponse) Reset 

func (m *TaskQueueFetchTaskResponse) Reset()

func (*TaskQueueFetchTaskResponse) String 

func (m *TaskQueueFetchTaskResponse) String() string

type TaskQueueForceRunRequest 

type TaskQueueForceRunRequest struct {
	AppId            []byte `protobuf:"bytes,1,opt,name=app_id" json:"app_id,omitempty"`
	QueueName        []byte `protobuf:"bytes,2,req,name=queue_name" json:"queue_name,omitempty"`
	TaskName         []byte `protobuf:"bytes,3,req,name=task_name" json:"task_name,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*TaskQueueForceRunRequest) GetAppId 

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

func (*TaskQueueForceRunRequest) GetQueueName 

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

func (*TaskQueueForceRunRequest) GetTaskName 

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

func (*TaskQueueForceRunRequest) ProtoMessage 

func (*TaskQueueForceRunRequest) ProtoMessage()

func (*TaskQueueForceRunRequest) Reset 

func (m *TaskQueueForceRunRequest) Reset()

func (*TaskQueueForceRunRequest) String 

func (m *TaskQueueForceRunRequest) String() string

type TaskQueueForceRunResponse 

type TaskQueueForceRunResponse struct {
	Result           *TaskQueueServiceError_ErrorCode `protobuf:"varint,3,req,name=result,enum=appengine.TaskQueueServiceError_ErrorCode" json:"result,omitempty"`
	XXX_unrecognized []byte                           `json:"-"`
}

func (*TaskQueueForceRunResponse) GetResult 

func (m *TaskQueueForceRunResponse) GetResult() TaskQueueServiceError_ErrorCode

func (*TaskQueueForceRunResponse) ProtoMessage 

func (*TaskQueueForceRunResponse) ProtoMessage()

func (*TaskQueueForceRunResponse) Reset 

func (m *TaskQueueForceRunResponse) Reset()

func (*TaskQueueForceRunResponse) String 

func (m *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"`
	XXX_unrecognized []byte `json:"-"`
}

func (*TaskQueueHttpHeader) GetKey 

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

func (*TaskQueueHttpHeader) GetValue 

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

func (*TaskQueueHttpHeader) ProtoMessage 

func (*TaskQueueHttpHeader) ProtoMessage()

func (*TaskQueueHttpHeader) Reset 

func (m *TaskQueueHttpHeader) Reset()

func (*TaskQueueHttpHeader) String 

func (m *TaskQueueHttpHeader) String() string

type TaskQueueMode 

type TaskQueueMode struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*TaskQueueMode) ProtoMessage 

func (*TaskQueueMode) ProtoMessage()

func (*TaskQueueMode) Reset 

func (m *TaskQueueMode) Reset()

func (*TaskQueueMode) String 

func (m *TaskQueueMode) String() string

type TaskQueueMode_Mode 

type TaskQueueMode_Mode int32
const (
	TaskQueueMode_PUSH TaskQueueMode_Mode = 0
	TaskQueueMode_PULL TaskQueueMode_Mode = 1
)
const Default_TaskQueueAddRequest_Mode TaskQueueMode_Mode = TaskQueueMode_PUSH
const Default_TaskQueueFetchQueuesResponse_Queue_Mode TaskQueueMode_Mode = TaskQueueMode_PUSH
const Default_TaskQueueUpdateQueueRequest_Mode TaskQueueMode_Mode = TaskQueueMode_PUSH

func (TaskQueueMode_Mode) Enum 

func (x TaskQueueMode_Mode) Enum() *TaskQueueMode_Mode

func (TaskQueueMode_Mode) String 

func (x TaskQueueMode_Mode) String() string

func (*TaskQueueMode_Mode) UnmarshalJSON 

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

type TaskQueueModifyTaskLeaseRequest 

type TaskQueueModifyTaskLeaseRequest struct {
	QueueName        []byte   `protobuf:"bytes,1,req,name=queue_name" json:"queue_name,omitempty"`
	TaskName         []byte   `protobuf:"bytes,2,req,name=task_name" json:"task_name,omitempty"`
	EtaUsec          *int64   `protobuf:"varint,3,req,name=eta_usec" json:"eta_usec,omitempty"`
	LeaseSeconds     *float64 `protobuf:"fixed64,4,req,name=lease_seconds" json:"lease_seconds,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*TaskQueueModifyTaskLeaseRequest) GetEtaUsec 

func (m *TaskQueueModifyTaskLeaseRequest) GetEtaUsec() int64

func (*TaskQueueModifyTaskLeaseRequest) GetLeaseSeconds 

func (m *TaskQueueModifyTaskLeaseRequest) GetLeaseSeconds() float64

func (*TaskQueueModifyTaskLeaseRequest) GetQueueName 

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

func (*TaskQueueModifyTaskLeaseRequest) GetTaskName 

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

func (*TaskQueueModifyTaskLeaseRequest) ProtoMessage 

func (*TaskQueueModifyTaskLeaseRequest) ProtoMessage()

func (*TaskQueueModifyTaskLeaseRequest) Reset 

func (m *TaskQueueModifyTaskLeaseRequest) Reset()

func (*TaskQueueModifyTaskLeaseRequest) String 

func (m *TaskQueueModifyTaskLeaseRequest) String() string

type TaskQueueModifyTaskLeaseResponse 

type TaskQueueModifyTaskLeaseResponse struct {
	UpdatedEtaUsec   *int64 `protobuf:"varint,1,req,name=updated_eta_usec" json:"updated_eta_usec,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*TaskQueueModifyTaskLeaseResponse) GetUpdatedEtaUsec 

func (m *TaskQueueModifyTaskLeaseResponse) GetUpdatedEtaUsec() int64

func (*TaskQueueModifyTaskLeaseResponse) ProtoMessage 

func (*TaskQueueModifyTaskLeaseResponse) ProtoMessage()

func (*TaskQueueModifyTaskLeaseResponse) Reset 

func (m *TaskQueueModifyTaskLeaseResponse) Reset()

func (*TaskQueueModifyTaskLeaseResponse) String 

func (m *TaskQueueModifyTaskLeaseResponse) String() string

type TaskQueuePauseQueueRequest 

type TaskQueuePauseQueueRequest struct {
	AppId            []byte `protobuf:"bytes,1,req,name=app_id" json:"app_id,omitempty"`
	QueueName        []byte `protobuf:"bytes,2,req,name=queue_name" json:"queue_name,omitempty"`
	Pause            *bool  `protobuf:"varint,3,req,name=pause" json:"pause,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*TaskQueuePauseQueueRequest) GetAppId 

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

func (*TaskQueuePauseQueueRequest) GetPause 

func (m *TaskQueuePauseQueueRequest) GetPause() bool

func (*TaskQueuePauseQueueRequest) GetQueueName 

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

func (*TaskQueuePauseQueueRequest) ProtoMessage 

func (*TaskQueuePauseQueueRequest) ProtoMessage()

func (*TaskQueuePauseQueueRequest) Reset 

func (m *TaskQueuePauseQueueRequest) Reset()

func (*TaskQueuePauseQueueRequest) String 

func (m *TaskQueuePauseQueueRequest) String() string

type TaskQueuePauseQueueResponse 

type TaskQueuePauseQueueResponse struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*TaskQueuePauseQueueResponse) ProtoMessage 

func (*TaskQueuePauseQueueResponse) ProtoMessage()

func (*TaskQueuePauseQueueResponse) Reset 

func (m *TaskQueuePauseQueueResponse) Reset()

func (*TaskQueuePauseQueueResponse) String 

func (m *TaskQueuePauseQueueResponse) String() string

type TaskQueuePurgeQueueRequest 

type TaskQueuePurgeQueueRequest struct {
	AppId            []byte `protobuf:"bytes,1,opt,name=app_id" json:"app_id,omitempty"`
	QueueName        []byte `protobuf:"bytes,2,req,name=queue_name" json:"queue_name,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*TaskQueuePurgeQueueRequest) GetAppId 

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

func (*TaskQueuePurgeQueueRequest) GetQueueName 

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

func (*TaskQueuePurgeQueueRequest) ProtoMessage 

func (*TaskQueuePurgeQueueRequest) ProtoMessage()

func (*TaskQueuePurgeQueueRequest) Reset 

func (m *TaskQueuePurgeQueueRequest) Reset()

func (*TaskQueuePurgeQueueRequest) String 

func (m *TaskQueuePurgeQueueRequest) String() string

type TaskQueuePurgeQueueResponse 

type TaskQueuePurgeQueueResponse struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*TaskQueuePurgeQueueResponse) ProtoMessage 

func (*TaskQueuePurgeQueueResponse) ProtoMessage()

func (*TaskQueuePurgeQueueResponse) Reset 

func (m *TaskQueuePurgeQueueResponse) Reset()

func (*TaskQueuePurgeQueueResponse) String 

func (m *TaskQueuePurgeQueueResponse) String() string

type TaskQueueQueryAndOwnTasksRequest 

type TaskQueueQueryAndOwnTasksRequest struct {
	QueueName        []byte   `protobuf:"bytes,1,req,name=queue_name" json:"queue_name,omitempty"`
	LeaseSeconds     *float64 `protobuf:"fixed64,2,req,name=lease_seconds" json:"lease_seconds,omitempty"`
	MaxTasks         *int64   `protobuf:"varint,3,req,name=max_tasks" json:"max_tasks,omitempty"`
	GroupByTag       *bool    `protobuf:"varint,4,opt,name=group_by_tag,def=0" json:"group_by_tag,omitempty"`
	Tag              []byte   `protobuf:"bytes,5,opt,name=tag" json:"tag,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*TaskQueueQueryAndOwnTasksRequest) GetGroupByTag 

func (m *TaskQueueQueryAndOwnTasksRequest) GetGroupByTag() bool

func (*TaskQueueQueryAndOwnTasksRequest) GetLeaseSeconds 

func (m *TaskQueueQueryAndOwnTasksRequest) GetLeaseSeconds() float64

func (*TaskQueueQueryAndOwnTasksRequest) GetMaxTasks 

func (m *TaskQueueQueryAndOwnTasksRequest) GetMaxTasks() int64

func (*TaskQueueQueryAndOwnTasksRequest) GetQueueName 

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

func (*TaskQueueQueryAndOwnTasksRequest) GetTag 

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

func (*TaskQueueQueryAndOwnTasksRequest) ProtoMessage 

func (*TaskQueueQueryAndOwnTasksRequest) ProtoMessage()

func (*TaskQueueQueryAndOwnTasksRequest) Reset 

func (m *TaskQueueQueryAndOwnTasksRequest) Reset()

func (*TaskQueueQueryAndOwnTasksRequest) String 

func (m *TaskQueueQueryAndOwnTasksRequest) String() string

type TaskQueueQueryAndOwnTasksResponse 

type TaskQueueQueryAndOwnTasksResponse struct {
	Task             []*TaskQueueQueryAndOwnTasksResponse_Task `protobuf:"group,1,rep,name=Task" json:"task,omitempty"`
	XXX_unrecognized []byte                                    `json:"-"`
}

func (*TaskQueueQueryAndOwnTasksResponse) GetTask 

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

func (*TaskQueueQueryAndOwnTasksResponse) ProtoMessage 

func (*TaskQueueQueryAndOwnTasksResponse) ProtoMessage()

func (*TaskQueueQueryAndOwnTasksResponse) Reset 

func (m *TaskQueueQueryAndOwnTasksResponse) Reset()

func (*TaskQueueQueryAndOwnTasksResponse) String 

func (m *TaskQueueQueryAndOwnTasksResponse) String() string

type TaskQueueQueryAndOwnTasksResponse_Task 

type TaskQueueQueryAndOwnTasksResponse_Task struct {
	TaskName         []byte `protobuf:"bytes,2,req,name=task_name" json:"task_name,omitempty"`
	EtaUsec          *int64 `protobuf:"varint,3,req,name=eta_usec" json:"eta_usec,omitempty"`
	RetryCount       *int32 `protobuf:"varint,4,opt,name=retry_count,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"`
	XXX_unrecognized []byte `json:"-"`
}

func (*TaskQueueQueryAndOwnTasksResponse_Task) GetBody 

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

func (*TaskQueueQueryAndOwnTasksResponse_Task) GetEtaUsec 

func (m *TaskQueueQueryAndOwnTasksResponse_Task) GetEtaUsec() int64

func (*TaskQueueQueryAndOwnTasksResponse_Task) GetRetryCount 

func (m *TaskQueueQueryAndOwnTasksResponse_Task) GetRetryCount() int32

func (*TaskQueueQueryAndOwnTasksResponse_Task) GetTag 

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

func (*TaskQueueQueryAndOwnTasksResponse_Task) GetTaskName 

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

func (*TaskQueueQueryAndOwnTasksResponse_Task) ProtoMessage 

func (*TaskQueueQueryAndOwnTasksResponse_Task) ProtoMessage()

func (*TaskQueueQueryAndOwnTasksResponse_Task) Reset 

func (m *TaskQueueQueryAndOwnTasksResponse_Task) Reset()

func (*TaskQueueQueryAndOwnTasksResponse_Task) String 

func (m *TaskQueueQueryAndOwnTasksResponse_Task) String() string

type TaskQueueQueryTasksRequest 

type TaskQueueQueryTasksRequest struct {
	AppId            []byte `protobuf:"bytes,1,opt,name=app_id" json:"app_id,omitempty"`
	QueueName        []byte `protobuf:"bytes,2,req,name=queue_name" json:"queue_name,omitempty"`
	StartTaskName    []byte `protobuf:"bytes,3,opt,name=start_task_name" json:"start_task_name,omitempty"`
	StartEtaUsec     *int64 `protobuf:"varint,4,opt,name=start_eta_usec" json:"start_eta_usec,omitempty"`
	StartTag         []byte `protobuf:"bytes,6,opt,name=start_tag" json:"start_tag,omitempty"`
	MaxRows          *int32 `protobuf:"varint,5,opt,name=max_rows,def=1" json:"max_rows,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*TaskQueueQueryTasksRequest) GetAppId 

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

func (*TaskQueueQueryTasksRequest) GetMaxRows 

func (m *TaskQueueQueryTasksRequest) GetMaxRows() int32

func (*TaskQueueQueryTasksRequest) GetQueueName 

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

func (*TaskQueueQueryTasksRequest) GetStartEtaUsec 

func (m *TaskQueueQueryTasksRequest) GetStartEtaUsec() int64

func (*TaskQueueQueryTasksRequest) GetStartTag 

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

func (*TaskQueueQueryTasksRequest) GetStartTaskName 

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

func (*TaskQueueQueryTasksRequest) ProtoMessage 

func (*TaskQueueQueryTasksRequest) ProtoMessage()

func (*TaskQueueQueryTasksRequest) Reset 

func (m *TaskQueueQueryTasksRequest) Reset()

func (*TaskQueueQueryTasksRequest) String 

func (m *TaskQueueQueryTasksRequest) String() string

type TaskQueueQueryTasksResponse 

type TaskQueueQueryTasksResponse struct {
	Task             []*TaskQueueQueryTasksResponse_Task `protobuf:"group,1,rep,name=Task" json:"task,omitempty"`
	XXX_unrecognized []byte                              `json:"-"`
}

func (*TaskQueueQueryTasksResponse) GetTask 

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

func (*TaskQueueQueryTasksResponse) ProtoMessage 

func (*TaskQueueQueryTasksResponse) ProtoMessage()

func (*TaskQueueQueryTasksResponse) Reset 

func (m *TaskQueueQueryTasksResponse) Reset()

func (*TaskQueueQueryTasksResponse) String 

func (m *TaskQueueQueryTasksResponse) String() string

type TaskQueueQueryTasksResponse_Task 

type TaskQueueQueryTasksResponse_Task struct {
	TaskName         []byte                                          `protobuf:"bytes,2,req,name=task_name" json:"task_name,omitempty"`
	EtaUsec          *int64                                          `protobuf:"varint,3,req,name=eta_usec" 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.TaskQueueQueryTasksResponse_Task_RequestMethod" json:"method,omitempty"`
	RetryCount       *int32                                          `protobuf:"varint,6,opt,name=retry_count,def=0" json:"retry_count,omitempty"`
	Header           []*TaskQueueQueryTasksResponse_Task_Header      `protobuf:"group,7,rep,name=Header" json:"header,omitempty"`
	BodySize         *int32                                          `protobuf:"varint,10,opt,name=body_size" 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:"creation_time_usec,omitempty"`
	Crontimetable    *TaskQueueQueryTasksResponse_Task_CronTimetable `protobuf:"group,13,opt,name=CronTimetable" json:"crontimetable,omitempty"`
	Runlog           *TaskQueueQueryTasksResponse_Task_RunLog        `protobuf:"group,16,opt,name=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:"retry_parameters,omitempty"`
	FirstTryUsec     *int64                                          `protobuf:"varint,24,opt,name=first_try_usec" 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,def=0" json:"execution_count,omitempty"`
	XXX_unrecognized []byte                                          `json:"-"`
}

func (*TaskQueueQueryTasksResponse_Task) GetBody 

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

func (*TaskQueueQueryTasksResponse_Task) GetBodySize 

func (m *TaskQueueQueryTasksResponse_Task) GetBodySize() int32

func (*TaskQueueQueryTasksResponse_Task) GetCreationTimeUsec 

func (m *TaskQueueQueryTasksResponse_Task) GetCreationTimeUsec() int64

func (*TaskQueueQueryTasksResponse_Task) GetCrontimetable 

func (m *TaskQueueQueryTasksResponse_Task) GetCrontimetable() *TaskQueueQueryTasksResponse_Task_CronTimetable

func (*TaskQueueQueryTasksResponse_Task) GetDescription 

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

func (*TaskQueueQueryTasksResponse_Task) GetEtaUsec 

func (m *TaskQueueQueryTasksResponse_Task) GetEtaUsec() int64

func (*TaskQueueQueryTasksResponse_Task) GetExecutionCount 

func (m *TaskQueueQueryTasksResponse_Task) GetExecutionCount() int32

func (*TaskQueueQueryTasksResponse_Task) GetFirstTryUsec 

func (m *TaskQueueQueryTasksResponse_Task) GetFirstTryUsec() int64

func (*TaskQueueQueryTasksResponse_Task) GetHeader 

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

func (*TaskQueueQueryTasksResponse_Task) GetMethod 

func (m *TaskQueueQueryTasksResponse_Task) GetMethod() TaskQueueQueryTasksResponse_Task_RequestMethod

func (*TaskQueueQueryTasksResponse_Task) GetPayload 

func (m *TaskQueueQueryTasksResponse_Task) GetPayload() *TaskPayload

func (*TaskQueueQueryTasksResponse_Task) GetRetryCount 

func (m *TaskQueueQueryTasksResponse_Task) GetRetryCount() int32

func (*TaskQueueQueryTasksResponse_Task) GetRetryParameters 

func (m *TaskQueueQueryTasksResponse_Task) GetRetryParameters() *TaskQueueRetryParameters

func (*TaskQueueQueryTasksResponse_Task) GetRunlog 

func (m *TaskQueueQueryTasksResponse_Task) GetRunlog() *TaskQueueQueryTasksResponse_Task_RunLog

func (*TaskQueueQueryTasksResponse_Task) GetTag 

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

func (*TaskQueueQueryTasksResponse_Task) GetTaskName 

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

func (*TaskQueueQueryTasksResponse_Task) GetUrl 

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

func (*TaskQueueQueryTasksResponse_Task) ProtoMessage 

func (*TaskQueueQueryTasksResponse_Task) ProtoMessage()

func (*TaskQueueQueryTasksResponse_Task) Reset 

func (m *TaskQueueQueryTasksResponse_Task) Reset()

func (*TaskQueueQueryTasksResponse_Task) String 

func (m *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"`
	XXX_unrecognized []byte `json:"-"`
}

func (*TaskQueueQueryTasksResponse_Task_CronTimetable) GetSchedule 

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

func (*TaskQueueQueryTasksResponse_Task_CronTimetable) GetTimezone 

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

func (*TaskQueueQueryTasksResponse_Task_CronTimetable) ProtoMessage 

func (*TaskQueueQueryTasksResponse_Task_CronTimetable) ProtoMessage()

func (*TaskQueueQueryTasksResponse_Task_CronTimetable) Reset 

func (m *TaskQueueQueryTasksResponse_Task_CronTimetable) Reset()

func (*TaskQueueQueryTasksResponse_Task_CronTimetable) String 

func (m *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"`
	XXX_unrecognized []byte `json:"-"`
}

func (*TaskQueueQueryTasksResponse_Task_Header) GetKey 

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

func (*TaskQueueQueryTasksResponse_Task_Header) GetValue 

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

func (*TaskQueueQueryTasksResponse_Task_Header) ProtoMessage 

func (*TaskQueueQueryTasksResponse_Task_Header) ProtoMessage()

func (*TaskQueueQueryTasksResponse_Task_Header) Reset 

func (m *TaskQueueQueryTasksResponse_Task_Header) Reset()

func (*TaskQueueQueryTasksResponse_Task_Header) String 

func (m *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) Enum 

func (x TaskQueueQueryTasksResponse_Task_RequestMethod) Enum() *TaskQueueQueryTasksResponse_Task_RequestMethod

func (TaskQueueQueryTasksResponse_Task_RequestMethod) String 

func (x TaskQueueQueryTasksResponse_Task_RequestMethod) String() string

func (*TaskQueueQueryTasksResponse_Task_RequestMethod) UnmarshalJSON 

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

type TaskQueueQueryTasksResponse_Task_RunLog 

type TaskQueueQueryTasksResponse_Task_RunLog struct {
	DispatchedUsec   *int64  `protobuf:"varint,17,req,name=dispatched_usec" json:"dispatched_usec,omitempty"`
	LagUsec          *int64  `protobuf:"varint,18,req,name=lag_usec" json:"lag_usec,omitempty"`
	ElapsedUsec      *int64  `protobuf:"varint,19,req,name=elapsed_usec" json:"elapsed_usec,omitempty"`
	ResponseCode     *int64  `protobuf:"varint,20,opt,name=response_code" json:"response_code,omitempty"`
	RetryReason      *string `protobuf:"bytes,27,opt,name=retry_reason" json:"retry_reason,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*TaskQueueQueryTasksResponse_Task_RunLog) GetDispatchedUsec 

func (m *TaskQueueQueryTasksResponse_Task_RunLog) GetDispatchedUsec() int64

func (*TaskQueueQueryTasksResponse_Task_RunLog) GetElapsedUsec 

func (m *TaskQueueQueryTasksResponse_Task_RunLog) GetElapsedUsec() int64

func (*TaskQueueQueryTasksResponse_Task_RunLog) GetLagUsec 

func (m *TaskQueueQueryTasksResponse_Task_RunLog) GetLagUsec() int64

func (*TaskQueueQueryTasksResponse_Task_RunLog) GetResponseCode 

func (m *TaskQueueQueryTasksResponse_Task_RunLog) GetResponseCode() int64

func (*TaskQueueQueryTasksResponse_Task_RunLog) GetRetryReason 

func (m *TaskQueueQueryTasksResponse_Task_RunLog) GetRetryReason() string

func (*TaskQueueQueryTasksResponse_Task_RunLog) ProtoMessage 

func (*TaskQueueQueryTasksResponse_Task_RunLog) ProtoMessage()

func (*TaskQueueQueryTasksResponse_Task_RunLog) Reset 

func (m *TaskQueueQueryTasksResponse_Task_RunLog) Reset()

func (*TaskQueueQueryTasksResponse_Task_RunLog) String 

func (m *TaskQueueQueryTasksResponse_Task_RunLog) String() string

type TaskQueueRetryParameters 

type TaskQueueRetryParameters struct {
	RetryLimit       *int32   `protobuf:"varint,1,opt,name=retry_limit" json:"retry_limit,omitempty"`
	AgeLimitSec      *int64   `protobuf:"varint,2,opt,name=age_limit_sec" json:"age_limit_sec,omitempty"`
	MinBackoffSec    *float64 `protobuf:"fixed64,3,opt,name=min_backoff_sec,def=0.1" json:"min_backoff_sec,omitempty"`
	MaxBackoffSec    *float64 `protobuf:"fixed64,4,opt,name=max_backoff_sec,def=3600" json:"max_backoff_sec,omitempty"`
	MaxDoublings     *int32   `protobuf:"varint,5,opt,name=max_doublings,def=16" json:"max_doublings,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*TaskQueueRetryParameters) GetAgeLimitSec 

func (m *TaskQueueRetryParameters) GetAgeLimitSec() int64

func (*TaskQueueRetryParameters) GetMaxBackoffSec 

func (m *TaskQueueRetryParameters) GetMaxBackoffSec() float64

func (*TaskQueueRetryParameters) GetMaxDoublings 

func (m *TaskQueueRetryParameters) GetMaxDoublings() int32

func (*TaskQueueRetryParameters) GetMinBackoffSec 

func (m *TaskQueueRetryParameters) GetMinBackoffSec() float64

func (*TaskQueueRetryParameters) GetRetryLimit 

func (m *TaskQueueRetryParameters) GetRetryLimit() int32

func (*TaskQueueRetryParameters) ProtoMessage 

func (*TaskQueueRetryParameters) ProtoMessage()

func (*TaskQueueRetryParameters) Reset 

func (m *TaskQueueRetryParameters) Reset()

func (*TaskQueueRetryParameters) String 

func (m *TaskQueueRetryParameters) String() string

type TaskQueueScannerQueueInfo 

type TaskQueueScannerQueueInfo struct {
	ExecutedLastMinute      *int64   `protobuf:"varint,1,req,name=executed_last_minute" json:"executed_last_minute,omitempty"`
	ExecutedLastHour        *int64   `protobuf:"varint,2,req,name=executed_last_hour" json:"executed_last_hour,omitempty"`
	SamplingDurationSeconds *float64 `protobuf:"fixed64,3,req,name=sampling_duration_seconds" json:"sampling_duration_seconds,omitempty"`
	RequestsInFlight        *int32   `protobuf:"varint,4,opt,name=requests_in_flight" json:"requests_in_flight,omitempty"`
	EnforcedRate            *float64 `protobuf:"fixed64,5,opt,name=enforced_rate" json:"enforced_rate,omitempty"`
	XXX_unrecognized        []byte   `json:"-"`
}

func (*TaskQueueScannerQueueInfo) GetEnforcedRate 

func (m *TaskQueueScannerQueueInfo) GetEnforcedRate() float64

func (*TaskQueueScannerQueueInfo) GetExecutedLastHour 

func (m *TaskQueueScannerQueueInfo) GetExecutedLastHour() int64

func (*TaskQueueScannerQueueInfo) GetExecutedLastMinute 

func (m *TaskQueueScannerQueueInfo) GetExecutedLastMinute() int64

func (*TaskQueueScannerQueueInfo) GetRequestsInFlight 

func (m *TaskQueueScannerQueueInfo) GetRequestsInFlight() int32

func (*TaskQueueScannerQueueInfo) GetSamplingDurationSeconds 

func (m *TaskQueueScannerQueueInfo) GetSamplingDurationSeconds() float64

func (*TaskQueueScannerQueueInfo) ProtoMessage 

func (*TaskQueueScannerQueueInfo) ProtoMessage()

func (*TaskQueueScannerQueueInfo) Reset 

func (m *TaskQueueScannerQueueInfo) Reset()

func (*TaskQueueScannerQueueInfo) String 

func (m *TaskQueueScannerQueueInfo) String() string

type TaskQueueServiceError 

type TaskQueueServiceError struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*TaskQueueServiceError) ProtoMessage 

func (*TaskQueueServiceError) ProtoMessage()

func (*TaskQueueServiceError) Reset 

func (m *TaskQueueServiceError) Reset()

func (*TaskQueueServiceError) String 

func (m *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) Enum 

func (x TaskQueueServiceError_ErrorCode) Enum() *TaskQueueServiceError_ErrorCode

func (TaskQueueServiceError_ErrorCode) String 

func (x TaskQueueServiceError_ErrorCode) String() string

func (*TaskQueueServiceError_ErrorCode) UnmarshalJSON 

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

type TaskQueueUpdateQueueRequest 

type TaskQueueUpdateQueueRequest struct {
	AppId                 []byte                    `protobuf:"bytes,1,opt,name=app_id" json:"app_id,omitempty"`
	QueueName             []byte                    `protobuf:"bytes,2,req,name=queue_name" json:"queue_name,omitempty"`
	BucketRefillPerSecond *float64                  `protobuf:"fixed64,3,req,name=bucket_refill_per_second" json:"bucket_refill_per_second,omitempty"`
	BucketCapacity        *int32                    `protobuf:"varint,4,req,name=bucket_capacity" json:"bucket_capacity,omitempty"`
	UserSpecifiedRate     *string                   `protobuf:"bytes,5,opt,name=user_specified_rate" json:"user_specified_rate,omitempty"`
	RetryParameters       *TaskQueueRetryParameters `protobuf:"bytes,6,opt,name=retry_parameters" json:"retry_parameters,omitempty"`
	MaxConcurrentRequests *int32                    `protobuf:"varint,7,opt,name=max_concurrent_requests" json:"max_concurrent_requests,omitempty"`
	Mode                  *TaskQueueMode_Mode       `protobuf:"varint,8,opt,name=mode,enum=appengine.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:"header_override,omitempty"`
	XXX_unrecognized      []byte                    `json:"-"`
}

func (*TaskQueueUpdateQueueRequest) GetAcl 

func (m *TaskQueueUpdateQueueRequest) GetAcl() *TaskQueueAcl

func (*TaskQueueUpdateQueueRequest) GetAppId 

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

func (*TaskQueueUpdateQueueRequest) GetBucketCapacity 

func (m *TaskQueueUpdateQueueRequest) GetBucketCapacity() int32

func (*TaskQueueUpdateQueueRequest) GetBucketRefillPerSecond 

func (m *TaskQueueUpdateQueueRequest) GetBucketRefillPerSecond() float64

func (*TaskQueueUpdateQueueRequest) GetHeaderOverride 

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

func (*TaskQueueUpdateQueueRequest) GetMaxConcurrentRequests 

func (m *TaskQueueUpdateQueueRequest) GetMaxConcurrentRequests() int32

func (*TaskQueueUpdateQueueRequest) GetMode 

func (m *TaskQueueUpdateQueueRequest) GetMode() TaskQueueMode_Mode

func (*TaskQueueUpdateQueueRequest) GetQueueName 

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

func (*TaskQueueUpdateQueueRequest) GetRetryParameters 

func (m *TaskQueueUpdateQueueRequest) GetRetryParameters() *TaskQueueRetryParameters

func (*TaskQueueUpdateQueueRequest) GetUserSpecifiedRate 

func (m *TaskQueueUpdateQueueRequest) GetUserSpecifiedRate() string

func (*TaskQueueUpdateQueueRequest) ProtoMessage 

func (*TaskQueueUpdateQueueRequest) ProtoMessage()

func (*TaskQueueUpdateQueueRequest) Reset 

func (m *TaskQueueUpdateQueueRequest) Reset()

func (*TaskQueueUpdateQueueRequest) String 

func (m *TaskQueueUpdateQueueRequest) String() string

type TaskQueueUpdateQueueResponse 

type TaskQueueUpdateQueueResponse struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*TaskQueueUpdateQueueResponse) ProtoMessage 

func (*TaskQueueUpdateQueueResponse) ProtoMessage()

func (*TaskQueueUpdateQueueResponse) Reset 

func (m *TaskQueueUpdateQueueResponse) Reset()

func (*TaskQueueUpdateQueueResponse) String 

func (m *TaskQueueUpdateQueueResponse) String() string

type TaskQueueUpdateStorageLimitRequest 

type TaskQueueUpdateStorageLimitRequest struct {
	AppId            []byte `protobuf:"bytes,1,req,name=app_id" json:"app_id,omitempty"`
	Limit            *int64 `protobuf:"varint,2,req,name=limit" json:"limit,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*TaskQueueUpdateStorageLimitRequest) GetAppId 

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

func (*TaskQueueUpdateStorageLimitRequest) GetLimit 

func (m *TaskQueueUpdateStorageLimitRequest) GetLimit() int64

func (*TaskQueueUpdateStorageLimitRequest) ProtoMessage 

func (*TaskQueueUpdateStorageLimitRequest) ProtoMessage()

func (*TaskQueueUpdateStorageLimitRequest) Reset 

func (m *TaskQueueUpdateStorageLimitRequest) Reset()

func (*TaskQueueUpdateStorageLimitRequest) String 

func (m *TaskQueueUpdateStorageLimitRequest) String() string

type TaskQueueUpdateStorageLimitResponse 

type TaskQueueUpdateStorageLimitResponse struct {
	NewLimit         *int64 `protobuf:"varint,1,req,name=new_limit" json:"new_limit,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*TaskQueueUpdateStorageLimitResponse) GetNewLimit 

func (m *TaskQueueUpdateStorageLimitResponse) GetNewLimit() int64

func (*TaskQueueUpdateStorageLimitResponse) ProtoMessage 

func (*TaskQueueUpdateStorageLimitResponse) ProtoMessage()

func (*TaskQueueUpdateStorageLimitResponse) Reset 

func (m *TaskQueueUpdateStorageLimitResponse) Reset()

func (*TaskQueueUpdateStorageLimitResponse) String 

func (m *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.