taskqueue

package
v1.6.8 Latest Latest
Warning

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

 Go to latest Published: Aug 30, 2023 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

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_NoUnkeyedLiteral         struct{} `json:"-"`
	proto.XXX_InternalExtensions `protobuf_messageset:"1" json:"-"`
	XXX_unrecognized             []byte `json:"-"`
	XXX_sizecache                int32  `json:"-"`
}

func (*TaskPayload) Descriptor 

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

func (*TaskPayload) ExtensionRangeArray 

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

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) UnmarshalJSON 

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

func (*TaskPayload) XXX_DiscardUnknown 

func (m *TaskPayload) XXX_DiscardUnknown()

func (*TaskPayload) XXX_Marshal 

func (m *TaskPayload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TaskPayload) XXX_Merge 

func (dst *TaskPayload) XXX_Merge(src proto.Message)

func (*TaskPayload) XXX_Size 

func (m *TaskPayload) XXX_Size() int

func (*TaskPayload) XXX_Unmarshal 

func (m *TaskPayload) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TaskQueueAcl) Descriptor 

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

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

func (*TaskQueueAcl) XXX_DiscardUnknown 

func (m *TaskQueueAcl) XXX_DiscardUnknown()

func (*TaskQueueAcl) XXX_Marshal 

func (m *TaskQueueAcl) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TaskQueueAcl) XXX_Merge 

func (dst *TaskQueueAcl) XXX_Merge(src proto.Message)

func (*TaskQueueAcl) XXX_Size 

func (m *TaskQueueAcl) XXX_Size() int

func (*TaskQueueAcl) XXX_Unmarshal 

func (m *TaskQueueAcl) XXX_Unmarshal(b []byte) error

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.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.TaskQueueMode_Mode,def=0" json:"mode,omitempty"`
	Tag                  []byte                             `protobuf:"bytes,19,opt,name=tag" json:"tag,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                           `json:"-"`
	XXX_unrecognized     []byte                             `json:"-"`
	XXX_sizecache        int32                              `json:"-"`
}

func (*TaskQueueAddRequest) Descriptor 

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

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() *datastore.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

func (*TaskQueueAddRequest) XXX_DiscardUnknown 

func (m *TaskQueueAddRequest) XXX_DiscardUnknown()

func (*TaskQueueAddRequest) XXX_Marshal 

func (m *TaskQueueAddRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TaskQueueAddRequest) XXX_Merge 

func (dst *TaskQueueAddRequest) XXX_Merge(src proto.Message)

func (*TaskQueueAddRequest) XXX_Size 

func (m *TaskQueueAddRequest) XXX_Size() int

func (*TaskQueueAddRequest) XXX_Unmarshal 

func (m *TaskQueueAddRequest) XXX_Unmarshal(b []byte) error

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_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TaskQueueAddRequest_CronTimetable) Descriptor 

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

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

func (*TaskQueueAddRequest_CronTimetable) XXX_DiscardUnknown 

func (m *TaskQueueAddRequest_CronTimetable) XXX_DiscardUnknown()

func (*TaskQueueAddRequest_CronTimetable) XXX_Marshal 

func (m *TaskQueueAddRequest_CronTimetable) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TaskQueueAddRequest_CronTimetable) XXX_Merge 

func (dst *TaskQueueAddRequest_CronTimetable) XXX_Merge(src proto.Message)

func (*TaskQueueAddRequest_CronTimetable) XXX_Size 

func (m *TaskQueueAddRequest_CronTimetable) XXX_Size() int

func (*TaskQueueAddRequest_CronTimetable) XXX_Unmarshal 

func (m *TaskQueueAddRequest_CronTimetable) XXX_Unmarshal(b []byte) error

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_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TaskQueueAddRequest_Header) Descriptor 

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

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

func (*TaskQueueAddRequest_Header) XXX_DiscardUnknown 

func (m *TaskQueueAddRequest_Header) XXX_DiscardUnknown()

func (*TaskQueueAddRequest_Header) XXX_Marshal 

func (m *TaskQueueAddRequest_Header) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TaskQueueAddRequest_Header) XXX_Merge 

func (dst *TaskQueueAddRequest_Header) XXX_Merge(src proto.Message)

func (*TaskQueueAddRequest_Header) XXX_Size 

func (m *TaskQueueAddRequest_Header) XXX_Size() int

func (*TaskQueueAddRequest_Header) XXX_Unmarshal 

func (m *TaskQueueAddRequest_Header) XXX_Unmarshal(b []byte) error

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) EnumDescriptor 

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

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=chosenTaskName" json:"chosen_task_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TaskQueueAddResponse) Descriptor 

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

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

func (*TaskQueueAddResponse) XXX_DiscardUnknown 

func (m *TaskQueueAddResponse) XXX_DiscardUnknown()

func (*TaskQueueAddResponse) XXX_Marshal 

func (m *TaskQueueAddResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TaskQueueAddResponse) XXX_Merge 

func (dst *TaskQueueAddResponse) XXX_Merge(src proto.Message)

func (*TaskQueueAddResponse) XXX_Size 

func (m *TaskQueueAddResponse) XXX_Size() int

func (*TaskQueueAddResponse) XXX_Unmarshal 

func (m *TaskQueueAddResponse) XXX_Unmarshal(b []byte) error

type TaskQueueBulkAddRequest 

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

func (*TaskQueueBulkAddRequest) Descriptor 

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

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

func (*TaskQueueBulkAddRequest) XXX_DiscardUnknown 

func (m *TaskQueueBulkAddRequest) XXX_DiscardUnknown()

func (*TaskQueueBulkAddRequest) XXX_Marshal 

func (m *TaskQueueBulkAddRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TaskQueueBulkAddRequest) XXX_Merge 

func (dst *TaskQueueBulkAddRequest) XXX_Merge(src proto.Message)

func (*TaskQueueBulkAddRequest) XXX_Size 

func (m *TaskQueueBulkAddRequest) XXX_Size() int

func (*TaskQueueBulkAddRequest) XXX_Unmarshal 

func (m *TaskQueueBulkAddRequest) XXX_Unmarshal(b []byte) error

type TaskQueueBulkAddResponse 

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

func (*TaskQueueBulkAddResponse) Descriptor 

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

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

func (*TaskQueueBulkAddResponse) XXX_DiscardUnknown 

func (m *TaskQueueBulkAddResponse) XXX_DiscardUnknown()

func (*TaskQueueBulkAddResponse) XXX_Marshal 

func (m *TaskQueueBulkAddResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TaskQueueBulkAddResponse) XXX_Merge 

func (dst *TaskQueueBulkAddResponse) XXX_Merge(src proto.Message)

func (*TaskQueueBulkAddResponse) XXX_Size 

func (m *TaskQueueBulkAddResponse) XXX_Size() int

func (*TaskQueueBulkAddResponse) XXX_Unmarshal 

func (m *TaskQueueBulkAddResponse) XXX_Unmarshal(b []byte) error

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=chosenTaskName" json:"chosen_task_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                         `json:"-"`
	XXX_unrecognized     []byte                           `json:"-"`
	XXX_sizecache        int32                            `json:"-"`
}

func (*TaskQueueBulkAddResponse_TaskResult) Descriptor 

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

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

func (*TaskQueueBulkAddResponse_TaskResult) XXX_DiscardUnknown 

func (m *TaskQueueBulkAddResponse_TaskResult) XXX_DiscardUnknown()

func (*TaskQueueBulkAddResponse_TaskResult) XXX_Marshal 

func (m *TaskQueueBulkAddResponse_TaskResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TaskQueueBulkAddResponse_TaskResult) XXX_Merge 

func (dst *TaskQueueBulkAddResponse_TaskResult) XXX_Merge(src proto.Message)

func (*TaskQueueBulkAddResponse_TaskResult) XXX_Size 

func (m *TaskQueueBulkAddResponse_TaskResult) XXX_Size() int

func (*TaskQueueBulkAddResponse_TaskResult) XXX_Unmarshal 

func (m *TaskQueueBulkAddResponse_TaskResult) XXX_Unmarshal(b []byte) error

type TaskQueueDeleteGroupRequest 

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

func (*TaskQueueDeleteGroupRequest) Descriptor 

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

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

func (*TaskQueueDeleteGroupRequest) XXX_DiscardUnknown 

func (m *TaskQueueDeleteGroupRequest) XXX_DiscardUnknown()

func (*TaskQueueDeleteGroupRequest) XXX_Marshal 

func (m *TaskQueueDeleteGroupRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TaskQueueDeleteGroupRequest) XXX_Merge 

func (dst *TaskQueueDeleteGroupRequest) XXX_Merge(src proto.Message)

func (*TaskQueueDeleteGroupRequest) XXX_Size 

func (m *TaskQueueDeleteGroupRequest) XXX_Size() int

func (*TaskQueueDeleteGroupRequest) XXX_Unmarshal 

func (m *TaskQueueDeleteGroupRequest) XXX_Unmarshal(b []byte) error

type TaskQueueDeleteGroupResponse 

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

func (*TaskQueueDeleteGroupResponse) Descriptor 

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

func (*TaskQueueDeleteGroupResponse) ProtoMessage 

func (*TaskQueueDeleteGroupResponse) ProtoMessage()

func (*TaskQueueDeleteGroupResponse) Reset 

func (m *TaskQueueDeleteGroupResponse) Reset()

func (*TaskQueueDeleteGroupResponse) String 

func (m *TaskQueueDeleteGroupResponse) String() string

func (*TaskQueueDeleteGroupResponse) XXX_DiscardUnknown 

func (m *TaskQueueDeleteGroupResponse) XXX_DiscardUnknown()

func (*TaskQueueDeleteGroupResponse) XXX_Marshal 

func (m *TaskQueueDeleteGroupResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TaskQueueDeleteGroupResponse) XXX_Merge 

func (dst *TaskQueueDeleteGroupResponse) XXX_Merge(src proto.Message)

func (*TaskQueueDeleteGroupResponse) XXX_Size 

func (m *TaskQueueDeleteGroupResponse) XXX_Size() int

func (*TaskQueueDeleteGroupResponse) XXX_Unmarshal 

func (m *TaskQueueDeleteGroupResponse) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TaskQueueDeleteQueueRequest) Descriptor 

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

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

func (*TaskQueueDeleteQueueRequest) XXX_DiscardUnknown 

func (m *TaskQueueDeleteQueueRequest) XXX_DiscardUnknown()

func (*TaskQueueDeleteQueueRequest) XXX_Marshal 

func (m *TaskQueueDeleteQueueRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TaskQueueDeleteQueueRequest) XXX_Merge 

func (dst *TaskQueueDeleteQueueRequest) XXX_Merge(src proto.Message)

func (*TaskQueueDeleteQueueRequest) XXX_Size 

func (m *TaskQueueDeleteQueueRequest) XXX_Size() int

func (*TaskQueueDeleteQueueRequest) XXX_Unmarshal 

func (m *TaskQueueDeleteQueueRequest) XXX_Unmarshal(b []byte) error

type TaskQueueDeleteQueueResponse 

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

func (*TaskQueueDeleteQueueResponse) Descriptor 

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

func (*TaskQueueDeleteQueueResponse) ProtoMessage 

func (*TaskQueueDeleteQueueResponse) ProtoMessage()

func (*TaskQueueDeleteQueueResponse) Reset 

func (m *TaskQueueDeleteQueueResponse) Reset()

func (*TaskQueueDeleteQueueResponse) String 

func (m *TaskQueueDeleteQueueResponse) String() string

func (*TaskQueueDeleteQueueResponse) XXX_DiscardUnknown 

func (m *TaskQueueDeleteQueueResponse) XXX_DiscardUnknown()

func (*TaskQueueDeleteQueueResponse) XXX_Marshal 

func (m *TaskQueueDeleteQueueResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TaskQueueDeleteQueueResponse) XXX_Merge 

func (dst *TaskQueueDeleteQueueResponse) XXX_Merge(src proto.Message)

func (*TaskQueueDeleteQueueResponse) XXX_Size 

func (m *TaskQueueDeleteQueueResponse) XXX_Size() int

func (*TaskQueueDeleteQueueResponse) XXX_Unmarshal 

func (m *TaskQueueDeleteQueueResponse) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TaskQueueDeleteRequest) Descriptor 

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

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

func (*TaskQueueDeleteRequest) XXX_DiscardUnknown 

func (m *TaskQueueDeleteRequest) XXX_DiscardUnknown()

func (*TaskQueueDeleteRequest) XXX_Marshal 

func (m *TaskQueueDeleteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TaskQueueDeleteRequest) XXX_Merge 

func (dst *TaskQueueDeleteRequest) XXX_Merge(src proto.Message)

func (*TaskQueueDeleteRequest) XXX_Size 

func (m *TaskQueueDeleteRequest) XXX_Size() int

func (*TaskQueueDeleteRequest) XXX_Unmarshal 

func (m *TaskQueueDeleteRequest) XXX_Unmarshal(b []byte) error

type TaskQueueDeleteResponse 

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

func (*TaskQueueDeleteResponse) Descriptor 

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

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

func (*TaskQueueDeleteResponse) XXX_DiscardUnknown 

func (m *TaskQueueDeleteResponse) XXX_DiscardUnknown()

func (*TaskQueueDeleteResponse) XXX_Marshal 

func (m *TaskQueueDeleteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TaskQueueDeleteResponse) XXX_Merge 

func (dst *TaskQueueDeleteResponse) XXX_Merge(src proto.Message)

func (*TaskQueueDeleteResponse) XXX_Size 

func (m *TaskQueueDeleteResponse) XXX_Size() int

func (*TaskQueueDeleteResponse) XXX_Unmarshal 

func (m *TaskQueueDeleteResponse) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TaskQueueFetchQueueStatsRequest) Descriptor 

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

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

func (*TaskQueueFetchQueueStatsRequest) XXX_DiscardUnknown 

func (m *TaskQueueFetchQueueStatsRequest) XXX_DiscardUnknown()

func (*TaskQueueFetchQueueStatsRequest) XXX_Marshal 

func (m *TaskQueueFetchQueueStatsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TaskQueueFetchQueueStatsRequest) XXX_Merge 

func (dst *TaskQueueFetchQueueStatsRequest) XXX_Merge(src proto.Message)

func (*TaskQueueFetchQueueStatsRequest) XXX_Size 

func (m *TaskQueueFetchQueueStatsRequest) XXX_Size() int

func (*TaskQueueFetchQueueStatsRequest) XXX_Unmarshal 

func (m *TaskQueueFetchQueueStatsRequest) XXX_Unmarshal(b []byte) error

type TaskQueueFetchQueueStatsResponse 

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

func (*TaskQueueFetchQueueStatsResponse) Descriptor 

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

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

func (*TaskQueueFetchQueueStatsResponse) XXX_DiscardUnknown 

func (m *TaskQueueFetchQueueStatsResponse) XXX_DiscardUnknown()

func (*TaskQueueFetchQueueStatsResponse) XXX_Marshal 

func (m *TaskQueueFetchQueueStatsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TaskQueueFetchQueueStatsResponse) XXX_Merge 

func (dst *TaskQueueFetchQueueStatsResponse) XXX_Merge(src proto.Message)

func (*TaskQueueFetchQueueStatsResponse) XXX_Size 

func (m *TaskQueueFetchQueueStatsResponse) XXX_Size() int

func (*TaskQueueFetchQueueStatsResponse) XXX_Unmarshal 

func (m *TaskQueueFetchQueueStatsResponse) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

func (*TaskQueueFetchQueueStatsResponse_QueueStats) Descriptor 

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

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

func (*TaskQueueFetchQueueStatsResponse_QueueStats) XXX_DiscardUnknown 

func (m *TaskQueueFetchQueueStatsResponse_QueueStats) XXX_DiscardUnknown()

func (*TaskQueueFetchQueueStatsResponse_QueueStats) XXX_Marshal 

func (m *TaskQueueFetchQueueStatsResponse_QueueStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TaskQueueFetchQueueStatsResponse_QueueStats) XXX_Merge 

func (dst *TaskQueueFetchQueueStatsResponse_QueueStats) XXX_Merge(src proto.Message)

func (*TaskQueueFetchQueueStatsResponse_QueueStats) XXX_Size 

func (m *TaskQueueFetchQueueStatsResponse_QueueStats) XXX_Size() int

func (*TaskQueueFetchQueueStatsResponse_QueueStats) XXX_Unmarshal 

func (m *TaskQueueFetchQueueStatsResponse_QueueStats) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TaskQueueFetchQueuesRequest) Descriptor 

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

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

func (*TaskQueueFetchQueuesRequest) XXX_DiscardUnknown 

func (m *TaskQueueFetchQueuesRequest) XXX_DiscardUnknown()

func (*TaskQueueFetchQueuesRequest) XXX_Marshal 

func (m *TaskQueueFetchQueuesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TaskQueueFetchQueuesRequest) XXX_Merge 

func (dst *TaskQueueFetchQueuesRequest) XXX_Merge(src proto.Message)

func (*TaskQueueFetchQueuesRequest) XXX_Size 

func (m *TaskQueueFetchQueuesRequest) XXX_Size() int

func (*TaskQueueFetchQueuesRequest) XXX_Unmarshal 

func (m *TaskQueueFetchQueuesRequest) XXX_Unmarshal(b []byte) error

type TaskQueueFetchQueuesResponse 

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

func (*TaskQueueFetchQueuesResponse) Descriptor 

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

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

func (*TaskQueueFetchQueuesResponse) XXX_DiscardUnknown 

func (m *TaskQueueFetchQueuesResponse) XXX_DiscardUnknown()

func (*TaskQueueFetchQueuesResponse) XXX_Marshal 

func (m *TaskQueueFetchQueuesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TaskQueueFetchQueuesResponse) XXX_Merge 

func (dst *TaskQueueFetchQueuesResponse) XXX_Merge(src proto.Message)

func (*TaskQueueFetchQueuesResponse) XXX_Size 

func (m *TaskQueueFetchQueuesResponse) XXX_Size() int

func (*TaskQueueFetchQueuesResponse) XXX_Unmarshal 

func (m *TaskQueueFetchQueuesResponse) XXX_Unmarshal(b []byte) error

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.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"`
	XXX_NoUnkeyedLiteral  struct{}                  `json:"-"`
	XXX_unrecognized      []byte                    `json:"-"`
	XXX_sizecache         int32                     `json:"-"`
}

func (*TaskQueueFetchQueuesResponse_Queue) Descriptor 

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

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

func (*TaskQueueFetchQueuesResponse_Queue) XXX_DiscardUnknown 

func (m *TaskQueueFetchQueuesResponse_Queue) XXX_DiscardUnknown()

func (*TaskQueueFetchQueuesResponse_Queue) XXX_Marshal 

func (m *TaskQueueFetchQueuesResponse_Queue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TaskQueueFetchQueuesResponse_Queue) XXX_Merge 

func (dst *TaskQueueFetchQueuesResponse_Queue) XXX_Merge(src proto.Message)

func (*TaskQueueFetchQueuesResponse_Queue) XXX_Size 

func (m *TaskQueueFetchQueuesResponse_Queue) XXX_Size() int

func (*TaskQueueFetchQueuesResponse_Queue) XXX_Unmarshal 

func (m *TaskQueueFetchQueuesResponse_Queue) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TaskQueueFetchTaskRequest) Descriptor 

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

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

func (*TaskQueueFetchTaskRequest) XXX_DiscardUnknown 

func (m *TaskQueueFetchTaskRequest) XXX_DiscardUnknown()

func (*TaskQueueFetchTaskRequest) XXX_Marshal 

func (m *TaskQueueFetchTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TaskQueueFetchTaskRequest) XXX_Merge 

func (dst *TaskQueueFetchTaskRequest) XXX_Merge(src proto.Message)

func (*TaskQueueFetchTaskRequest) XXX_Size 

func (m *TaskQueueFetchTaskRequest) XXX_Size() int

func (*TaskQueueFetchTaskRequest) XXX_Unmarshal 

func (m *TaskQueueFetchTaskRequest) XXX_Unmarshal(b []byte) error

type TaskQueueFetchTaskResponse 

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

func (*TaskQueueFetchTaskResponse) Descriptor 

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

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

func (*TaskQueueFetchTaskResponse) XXX_DiscardUnknown 

func (m *TaskQueueFetchTaskResponse) XXX_DiscardUnknown()

func (*TaskQueueFetchTaskResponse) XXX_Marshal 

func (m *TaskQueueFetchTaskResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TaskQueueFetchTaskResponse) XXX_Merge 

func (dst *TaskQueueFetchTaskResponse) XXX_Merge(src proto.Message)

func (*TaskQueueFetchTaskResponse) XXX_Size 

func (m *TaskQueueFetchTaskResponse) XXX_Size() int

func (*TaskQueueFetchTaskResponse) XXX_Unmarshal 

func (m *TaskQueueFetchTaskResponse) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TaskQueueForceRunRequest) Descriptor 

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

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

func (*TaskQueueForceRunRequest) XXX_DiscardUnknown 

func (m *TaskQueueForceRunRequest) XXX_DiscardUnknown()

func (*TaskQueueForceRunRequest) XXX_Marshal 

func (m *TaskQueueForceRunRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TaskQueueForceRunRequest) XXX_Merge 

func (dst *TaskQueueForceRunRequest) XXX_Merge(src proto.Message)

func (*TaskQueueForceRunRequest) XXX_Size 

func (m *TaskQueueForceRunRequest) XXX_Size() int

func (*TaskQueueForceRunRequest) XXX_Unmarshal 

func (m *TaskQueueForceRunRequest) XXX_Unmarshal(b []byte) error

type TaskQueueForceRunResponse 

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

func (*TaskQueueForceRunResponse) Descriptor 

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

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

func (*TaskQueueForceRunResponse) XXX_DiscardUnknown 

func (m *TaskQueueForceRunResponse) XXX_DiscardUnknown()

func (*TaskQueueForceRunResponse) XXX_Marshal 

func (m *TaskQueueForceRunResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TaskQueueForceRunResponse) XXX_Merge 

func (dst *TaskQueueForceRunResponse) XXX_Merge(src proto.Message)

func (*TaskQueueForceRunResponse) XXX_Size 

func (m *TaskQueueForceRunResponse) XXX_Size() int

func (*TaskQueueForceRunResponse) XXX_Unmarshal 

func (m *TaskQueueForceRunResponse) XXX_Unmarshal(b []byte) error

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_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TaskQueueHttpHeader) Descriptor 

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

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

func (*TaskQueueHttpHeader) XXX_DiscardUnknown 

func (m *TaskQueueHttpHeader) XXX_DiscardUnknown()

func (*TaskQueueHttpHeader) XXX_Marshal 

func (m *TaskQueueHttpHeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TaskQueueHttpHeader) XXX_Merge 

func (dst *TaskQueueHttpHeader) XXX_Merge(src proto.Message)

func (*TaskQueueHttpHeader) XXX_Size 

func (m *TaskQueueHttpHeader) XXX_Size() int

func (*TaskQueueHttpHeader) XXX_Unmarshal 

func (m *TaskQueueHttpHeader) XXX_Unmarshal(b []byte) error

type TaskQueueMode 

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

func (*TaskQueueMode) Descriptor 

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

func (*TaskQueueMode) ProtoMessage 

func (*TaskQueueMode) ProtoMessage()

func (*TaskQueueMode) Reset 

func (m *TaskQueueMode) Reset()

func (*TaskQueueMode) String 

func (m *TaskQueueMode) String() string

func (*TaskQueueMode) XXX_DiscardUnknown 

func (m *TaskQueueMode) XXX_DiscardUnknown()

func (*TaskQueueMode) XXX_Marshal 

func (m *TaskQueueMode) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TaskQueueMode) XXX_Merge 

func (dst *TaskQueueMode) XXX_Merge(src proto.Message)

func (*TaskQueueMode) XXX_Size 

func (m *TaskQueueMode) XXX_Size() int

func (*TaskQueueMode) XXX_Unmarshal 

func (m *TaskQueueMode) XXX_Unmarshal(b []byte) error

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) EnumDescriptor 

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

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=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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TaskQueueModifyTaskLeaseRequest) Descriptor 

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

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

func (*TaskQueueModifyTaskLeaseRequest) XXX_DiscardUnknown 

func (m *TaskQueueModifyTaskLeaseRequest) XXX_DiscardUnknown()

func (*TaskQueueModifyTaskLeaseRequest) XXX_Marshal 

func (m *TaskQueueModifyTaskLeaseRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TaskQueueModifyTaskLeaseRequest) XXX_Merge 

func (dst *TaskQueueModifyTaskLeaseRequest) XXX_Merge(src proto.Message)

func (*TaskQueueModifyTaskLeaseRequest) XXX_Size 

func (m *TaskQueueModifyTaskLeaseRequest) XXX_Size() int

func (*TaskQueueModifyTaskLeaseRequest) XXX_Unmarshal 

func (m *TaskQueueModifyTaskLeaseRequest) XXX_Unmarshal(b []byte) error

type TaskQueueModifyTaskLeaseResponse 

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

func (*TaskQueueModifyTaskLeaseResponse) Descriptor 

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

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

func (*TaskQueueModifyTaskLeaseResponse) XXX_DiscardUnknown 

func (m *TaskQueueModifyTaskLeaseResponse) XXX_DiscardUnknown()

func (*TaskQueueModifyTaskLeaseResponse) XXX_Marshal 

func (m *TaskQueueModifyTaskLeaseResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TaskQueueModifyTaskLeaseResponse) XXX_Merge 

func (dst *TaskQueueModifyTaskLeaseResponse) XXX_Merge(src proto.Message)

func (*TaskQueueModifyTaskLeaseResponse) XXX_Size 

func (m *TaskQueueModifyTaskLeaseResponse) XXX_Size() int

func (*TaskQueueModifyTaskLeaseResponse) XXX_Unmarshal 

func (m *TaskQueueModifyTaskLeaseResponse) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TaskQueuePauseQueueRequest) Descriptor 

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

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

func (*TaskQueuePauseQueueRequest) XXX_DiscardUnknown 

func (m *TaskQueuePauseQueueRequest) XXX_DiscardUnknown()

func (*TaskQueuePauseQueueRequest) XXX_Marshal 

func (m *TaskQueuePauseQueueRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TaskQueuePauseQueueRequest) XXX_Merge 

func (dst *TaskQueuePauseQueueRequest) XXX_Merge(src proto.Message)

func (*TaskQueuePauseQueueRequest) XXX_Size 

func (m *TaskQueuePauseQueueRequest) XXX_Size() int

func (*TaskQueuePauseQueueRequest) XXX_Unmarshal 

func (m *TaskQueuePauseQueueRequest) XXX_Unmarshal(b []byte) error

type TaskQueuePauseQueueResponse 

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

func (*TaskQueuePauseQueueResponse) Descriptor 

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

func (*TaskQueuePauseQueueResponse) ProtoMessage 

func (*TaskQueuePauseQueueResponse) ProtoMessage()

func (*TaskQueuePauseQueueResponse) Reset 

func (m *TaskQueuePauseQueueResponse) Reset()

func (*TaskQueuePauseQueueResponse) String 

func (m *TaskQueuePauseQueueResponse) String() string

func (*TaskQueuePauseQueueResponse) XXX_DiscardUnknown 

func (m *TaskQueuePauseQueueResponse) XXX_DiscardUnknown()

func (*TaskQueuePauseQueueResponse) XXX_Marshal 

func (m *TaskQueuePauseQueueResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TaskQueuePauseQueueResponse) XXX_Merge 

func (dst *TaskQueuePauseQueueResponse) XXX_Merge(src proto.Message)

func (*TaskQueuePauseQueueResponse) XXX_Size 

func (m *TaskQueuePauseQueueResponse) XXX_Size() int

func (*TaskQueuePauseQueueResponse) XXX_Unmarshal 

func (m *TaskQueuePauseQueueResponse) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TaskQueuePurgeQueueRequest) Descriptor 

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

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

func (*TaskQueuePurgeQueueRequest) XXX_DiscardUnknown 

func (m *TaskQueuePurgeQueueRequest) XXX_DiscardUnknown()

func (*TaskQueuePurgeQueueRequest) XXX_Marshal 

func (m *TaskQueuePurgeQueueRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TaskQueuePurgeQueueRequest) XXX_Merge 

func (dst *TaskQueuePurgeQueueRequest) XXX_Merge(src proto.Message)

func (*TaskQueuePurgeQueueRequest) XXX_Size 

func (m *TaskQueuePurgeQueueRequest) XXX_Size() int

func (*TaskQueuePurgeQueueRequest) XXX_Unmarshal 

func (m *TaskQueuePurgeQueueRequest) XXX_Unmarshal(b []byte) error

type TaskQueuePurgeQueueResponse 

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

func (*TaskQueuePurgeQueueResponse) Descriptor 

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

func (*TaskQueuePurgeQueueResponse) ProtoMessage 

func (*TaskQueuePurgeQueueResponse) ProtoMessage()

func (*TaskQueuePurgeQueueResponse) Reset 

func (m *TaskQueuePurgeQueueResponse) Reset()

func (*TaskQueuePurgeQueueResponse) String 

func (m *TaskQueuePurgeQueueResponse) String() string

func (*TaskQueuePurgeQueueResponse) XXX_DiscardUnknown 

func (m *TaskQueuePurgeQueueResponse) XXX_DiscardUnknown()

func (*TaskQueuePurgeQueueResponse) XXX_Marshal 

func (m *TaskQueuePurgeQueueResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TaskQueuePurgeQueueResponse) XXX_Merge 

func (dst *TaskQueuePurgeQueueResponse) XXX_Merge(src proto.Message)

func (*TaskQueuePurgeQueueResponse) XXX_Size 

func (m *TaskQueuePurgeQueueResponse) XXX_Size() int

func (*TaskQueuePurgeQueueResponse) XXX_Unmarshal 

func (m *TaskQueuePurgeQueueResponse) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TaskQueueQueryAndOwnTasksRequest) Descriptor 

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

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

func (*TaskQueueQueryAndOwnTasksRequest) XXX_DiscardUnknown 

func (m *TaskQueueQueryAndOwnTasksRequest) XXX_DiscardUnknown()

func (*TaskQueueQueryAndOwnTasksRequest) XXX_Marshal 

func (m *TaskQueueQueryAndOwnTasksRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TaskQueueQueryAndOwnTasksRequest) XXX_Merge 

func (dst *TaskQueueQueryAndOwnTasksRequest) XXX_Merge(src proto.Message)

func (*TaskQueueQueryAndOwnTasksRequest) XXX_Size 

func (m *TaskQueueQueryAndOwnTasksRequest) XXX_Size() int

func (*TaskQueueQueryAndOwnTasksRequest) XXX_Unmarshal 

func (m *TaskQueueQueryAndOwnTasksRequest) XXX_Unmarshal(b []byte) error

type TaskQueueQueryAndOwnTasksResponse 

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

func (*TaskQueueQueryAndOwnTasksResponse) Descriptor 

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

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

func (*TaskQueueQueryAndOwnTasksResponse) XXX_DiscardUnknown 

func (m *TaskQueueQueryAndOwnTasksResponse) XXX_DiscardUnknown()

func (*TaskQueueQueryAndOwnTasksResponse) XXX_Marshal 

func (m *TaskQueueQueryAndOwnTasksResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TaskQueueQueryAndOwnTasksResponse) XXX_Merge 

func (dst *TaskQueueQueryAndOwnTasksResponse) XXX_Merge(src proto.Message)

func (*TaskQueueQueryAndOwnTasksResponse) XXX_Size 

func (m *TaskQueueQueryAndOwnTasksResponse) XXX_Size() int

func (*TaskQueueQueryAndOwnTasksResponse) XXX_Unmarshal 

func (m *TaskQueueQueryAndOwnTasksResponse) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TaskQueueQueryAndOwnTasksResponse_Task) Descriptor 

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

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

func (*TaskQueueQueryAndOwnTasksResponse_Task) XXX_DiscardUnknown 

func (m *TaskQueueQueryAndOwnTasksResponse_Task) XXX_DiscardUnknown()

func (*TaskQueueQueryAndOwnTasksResponse_Task) XXX_Marshal 

func (m *TaskQueueQueryAndOwnTasksResponse_Task) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TaskQueueQueryAndOwnTasksResponse_Task) XXX_Merge 

func (dst *TaskQueueQueryAndOwnTasksResponse_Task) XXX_Merge(src proto.Message)

func (*TaskQueueQueryAndOwnTasksResponse_Task) XXX_Size 

func (m *TaskQueueQueryAndOwnTasksResponse_Task) XXX_Size() int

func (*TaskQueueQueryAndOwnTasksResponse_Task) XXX_Unmarshal 

func (m *TaskQueueQueryAndOwnTasksResponse_Task) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TaskQueueQueryTasksRequest) Descriptor 

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

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

func (*TaskQueueQueryTasksRequest) XXX_DiscardUnknown 

func (m *TaskQueueQueryTasksRequest) XXX_DiscardUnknown()

func (*TaskQueueQueryTasksRequest) XXX_Marshal 

func (m *TaskQueueQueryTasksRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TaskQueueQueryTasksRequest) XXX_Merge 

func (dst *TaskQueueQueryTasksRequest) XXX_Merge(src proto.Message)

func (*TaskQueueQueryTasksRequest) XXX_Size 

func (m *TaskQueueQueryTasksRequest) XXX_Size() int

func (*TaskQueueQueryTasksRequest) XXX_Unmarshal 

func (m *TaskQueueQueryTasksRequest) XXX_Unmarshal(b []byte) error

type TaskQueueQueryTasksResponse 

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

func (*TaskQueueQueryTasksResponse) Descriptor 

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

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

func (*TaskQueueQueryTasksResponse) XXX_DiscardUnknown 

func (m *TaskQueueQueryTasksResponse) XXX_DiscardUnknown()

func (*TaskQueueQueryTasksResponse) XXX_Marshal 

func (m *TaskQueueQueryTasksResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TaskQueueQueryTasksResponse) XXX_Merge 

func (dst *TaskQueueQueryTasksResponse) XXX_Merge(src proto.Message)

func (*TaskQueueQueryTasksResponse) XXX_Size 

func (m *TaskQueueQueryTasksResponse) XXX_Size() int

func (*TaskQueueQueryTasksResponse) XXX_Unmarshal 

func (m *TaskQueueQueryTasksResponse) XXX_Unmarshal(b []byte) error

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.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"`
	XXX_NoUnkeyedLiteral struct{}                                        `json:"-"`
	XXX_unrecognized     []byte                                          `json:"-"`
	XXX_sizecache        int32                                           `json:"-"`
}

func (*TaskQueueQueryTasksResponse_Task) Descriptor 

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

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

func (*TaskQueueQueryTasksResponse_Task) XXX_DiscardUnknown 

func (m *TaskQueueQueryTasksResponse_Task) XXX_DiscardUnknown()

func (*TaskQueueQueryTasksResponse_Task) XXX_Marshal 

func (m *TaskQueueQueryTasksResponse_Task) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TaskQueueQueryTasksResponse_Task) XXX_Merge 

func (dst *TaskQueueQueryTasksResponse_Task) XXX_Merge(src proto.Message)

func (*TaskQueueQueryTasksResponse_Task) XXX_Size 

func (m *TaskQueueQueryTasksResponse_Task) XXX_Size() int

func (*TaskQueueQueryTasksResponse_Task) XXX_Unmarshal 

func (m *TaskQueueQueryTasksResponse_Task) XXX_Unmarshal(b []byte) error

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_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TaskQueueQueryTasksResponse_Task_CronTimetable) Descriptor 

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

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

func (*TaskQueueQueryTasksResponse_Task_CronTimetable) XXX_DiscardUnknown 

func (m *TaskQueueQueryTasksResponse_Task_CronTimetable) XXX_DiscardUnknown()

func (*TaskQueueQueryTasksResponse_Task_CronTimetable) XXX_Marshal 

func (m *TaskQueueQueryTasksResponse_Task_CronTimetable) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TaskQueueQueryTasksResponse_Task_CronTimetable) XXX_Merge 

func (dst *TaskQueueQueryTasksResponse_Task_CronTimetable) XXX_Merge(src proto.Message)

func (*TaskQueueQueryTasksResponse_Task_CronTimetable) XXX_Size 

func (m *TaskQueueQueryTasksResponse_Task_CronTimetable) XXX_Size() int

func (*TaskQueueQueryTasksResponse_Task_CronTimetable) XXX_Unmarshal 

func (m *TaskQueueQueryTasksResponse_Task_CronTimetable) XXX_Unmarshal(b []byte) error

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_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TaskQueueQueryTasksResponse_Task_Header) Descriptor 

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

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

func (*TaskQueueQueryTasksResponse_Task_Header) XXX_DiscardUnknown 

func (m *TaskQueueQueryTasksResponse_Task_Header) XXX_DiscardUnknown()

func (*TaskQueueQueryTasksResponse_Task_Header) XXX_Marshal 

func (m *TaskQueueQueryTasksResponse_Task_Header) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TaskQueueQueryTasksResponse_Task_Header) XXX_Merge 

func (dst *TaskQueueQueryTasksResponse_Task_Header) XXX_Merge(src proto.Message)

func (*TaskQueueQueryTasksResponse_Task_Header) XXX_Size 

func (m *TaskQueueQueryTasksResponse_Task_Header) XXX_Size() int

func (*TaskQueueQueryTasksResponse_Task_Header) XXX_Unmarshal 

func (m *TaskQueueQueryTasksResponse_Task_Header) XXX_Unmarshal(b []byte) error

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) EnumDescriptor 

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

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=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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TaskQueueQueryTasksResponse_Task_RunLog) Descriptor 

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

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

func (*TaskQueueQueryTasksResponse_Task_RunLog) XXX_DiscardUnknown 

func (m *TaskQueueQueryTasksResponse_Task_RunLog) XXX_DiscardUnknown()

func (*TaskQueueQueryTasksResponse_Task_RunLog) XXX_Marshal 

func (m *TaskQueueQueryTasksResponse_Task_RunLog) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TaskQueueQueryTasksResponse_Task_RunLog) XXX_Merge 

func (dst *TaskQueueQueryTasksResponse_Task_RunLog) XXX_Merge(src proto.Message)

func (*TaskQueueQueryTasksResponse_Task_RunLog) XXX_Size 

func (m *TaskQueueQueryTasksResponse_Task_RunLog) XXX_Size() int

func (*TaskQueueQueryTasksResponse_Task_RunLog) XXX_Unmarshal 

func (m *TaskQueueQueryTasksResponse_Task_RunLog) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TaskQueueRetryParameters) Descriptor 

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

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

func (*TaskQueueRetryParameters) XXX_DiscardUnknown 

func (m *TaskQueueRetryParameters) XXX_DiscardUnknown()

func (*TaskQueueRetryParameters) XXX_Marshal 

func (m *TaskQueueRetryParameters) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TaskQueueRetryParameters) XXX_Merge 

func (dst *TaskQueueRetryParameters) XXX_Merge(src proto.Message)

func (*TaskQueueRetryParameters) XXX_Size 

func (m *TaskQueueRetryParameters) XXX_Size() int

func (*TaskQueueRetryParameters) XXX_Unmarshal 

func (m *TaskQueueRetryParameters) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral    struct{} `json:"-"`
	XXX_unrecognized        []byte   `json:"-"`
	XXX_sizecache           int32    `json:"-"`
}

func (*TaskQueueScannerQueueInfo) Descriptor 

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

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

func (*TaskQueueScannerQueueInfo) XXX_DiscardUnknown 

func (m *TaskQueueScannerQueueInfo) XXX_DiscardUnknown()

func (*TaskQueueScannerQueueInfo) XXX_Marshal 

func (m *TaskQueueScannerQueueInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TaskQueueScannerQueueInfo) XXX_Merge 

func (dst *TaskQueueScannerQueueInfo) XXX_Merge(src proto.Message)

func (*TaskQueueScannerQueueInfo) XXX_Size 

func (m *TaskQueueScannerQueueInfo) XXX_Size() int

func (*TaskQueueScannerQueueInfo) XXX_Unmarshal 

func (m *TaskQueueScannerQueueInfo) XXX_Unmarshal(b []byte) error

type TaskQueueServiceError 

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

func (*TaskQueueServiceError) Descriptor 

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

func (*TaskQueueServiceError) ProtoMessage 

func (*TaskQueueServiceError) ProtoMessage()

func (*TaskQueueServiceError) Reset 

func (m *TaskQueueServiceError) Reset()

func (*TaskQueueServiceError) String 

func (m *TaskQueueServiceError) String() string

func (*TaskQueueServiceError) XXX_DiscardUnknown 

func (m *TaskQueueServiceError) XXX_DiscardUnknown()

func (*TaskQueueServiceError) XXX_Marshal 

func (m *TaskQueueServiceError) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TaskQueueServiceError) XXX_Merge 

func (dst *TaskQueueServiceError) XXX_Merge(src proto.Message)

func (*TaskQueueServiceError) XXX_Size 

func (m *TaskQueueServiceError) XXX_Size() int

func (*TaskQueueServiceError) XXX_Unmarshal 

func (m *TaskQueueServiceError) XXX_Unmarshal(b []byte) error

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) EnumDescriptor 

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

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=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.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"`
	XXX_NoUnkeyedLiteral  struct{}                  `json:"-"`
	XXX_unrecognized      []byte                    `json:"-"`
	XXX_sizecache         int32                     `json:"-"`
}

func (*TaskQueueUpdateQueueRequest) Descriptor 

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

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

func (*TaskQueueUpdateQueueRequest) XXX_DiscardUnknown 

func (m *TaskQueueUpdateQueueRequest) XXX_DiscardUnknown()

func (*TaskQueueUpdateQueueRequest) XXX_Marshal 

func (m *TaskQueueUpdateQueueRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TaskQueueUpdateQueueRequest) XXX_Merge 

func (dst *TaskQueueUpdateQueueRequest) XXX_Merge(src proto.Message)

func (*TaskQueueUpdateQueueRequest) XXX_Size 

func (m *TaskQueueUpdateQueueRequest) XXX_Size() int

func (*TaskQueueUpdateQueueRequest) XXX_Unmarshal 

func (m *TaskQueueUpdateQueueRequest) XXX_Unmarshal(b []byte) error

type TaskQueueUpdateQueueResponse 

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

func (*TaskQueueUpdateQueueResponse) Descriptor 

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

func (*TaskQueueUpdateQueueResponse) ProtoMessage 

func (*TaskQueueUpdateQueueResponse) ProtoMessage()

func (*TaskQueueUpdateQueueResponse) Reset 

func (m *TaskQueueUpdateQueueResponse) Reset()

func (*TaskQueueUpdateQueueResponse) String 

func (m *TaskQueueUpdateQueueResponse) String() string

func (*TaskQueueUpdateQueueResponse) XXX_DiscardUnknown 

func (m *TaskQueueUpdateQueueResponse) XXX_DiscardUnknown()

func (*TaskQueueUpdateQueueResponse) XXX_Marshal 

func (m *TaskQueueUpdateQueueResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TaskQueueUpdateQueueResponse) XXX_Merge 

func (dst *TaskQueueUpdateQueueResponse) XXX_Merge(src proto.Message)

func (*TaskQueueUpdateQueueResponse) XXX_Size 

func (m *TaskQueueUpdateQueueResponse) XXX_Size() int

func (*TaskQueueUpdateQueueResponse) XXX_Unmarshal 

func (m *TaskQueueUpdateQueueResponse) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TaskQueueUpdateStorageLimitRequest) Descriptor 

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

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

func (*TaskQueueUpdateStorageLimitRequest) XXX_DiscardUnknown 

func (m *TaskQueueUpdateStorageLimitRequest) XXX_DiscardUnknown()

func (*TaskQueueUpdateStorageLimitRequest) XXX_Marshal 

func (m *TaskQueueUpdateStorageLimitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TaskQueueUpdateStorageLimitRequest) XXX_Merge 

func (dst *TaskQueueUpdateStorageLimitRequest) XXX_Merge(src proto.Message)

func (*TaskQueueUpdateStorageLimitRequest) XXX_Size 

func (m *TaskQueueUpdateStorageLimitRequest) XXX_Size() int

func (*TaskQueueUpdateStorageLimitRequest) XXX_Unmarshal 

func (m *TaskQueueUpdateStorageLimitRequest) XXX_Unmarshal(b []byte) error

type TaskQueueUpdateStorageLimitResponse 

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

func (*TaskQueueUpdateStorageLimitResponse) Descriptor 

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

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

func (*TaskQueueUpdateStorageLimitResponse) XXX_DiscardUnknown 

func (m *TaskQueueUpdateStorageLimitResponse) XXX_DiscardUnknown()

func (*TaskQueueUpdateStorageLimitResponse) XXX_Marshal 

func (m *TaskQueueUpdateStorageLimitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TaskQueueUpdateStorageLimitResponse) XXX_Merge 

func (dst *TaskQueueUpdateStorageLimitResponse) XXX_Merge(src proto.Message)

func (*TaskQueueUpdateStorageLimitResponse) XXX_Size 

func (m *TaskQueueUpdateStorageLimitResponse) XXX_Size() int

func (*TaskQueueUpdateStorageLimitResponse) XXX_Unmarshal 

func (m *TaskQueueUpdateStorageLimitResponse) XXX_Unmarshal(b []byte) error

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.