appengine: google.golang.org/appengine/internal/taskqueue Index | Files

package taskqueue

import "google.golang.org/appengine/internal/taskqueue"

Index

Package Files

taskqueue_service.pb.go

Constants

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

Variables

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

type TaskPayload Uses

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 Uses

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

func (*TaskPayload) ExtensionRangeArray Uses

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

func (*TaskPayload) MarshalJSON Uses

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

func (*TaskPayload) ProtoMessage Uses

func (*TaskPayload) ProtoMessage()

func (*TaskPayload) Reset Uses

func (m *TaskPayload) Reset()

func (*TaskPayload) String Uses

func (m *TaskPayload) String() string

func (*TaskPayload) UnmarshalJSON Uses

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

func (*TaskPayload) XXX_DiscardUnknown Uses

func (m *TaskPayload) XXX_DiscardUnknown()

func (*TaskPayload) XXX_Marshal Uses

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

func (*TaskPayload) XXX_Merge Uses

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

func (*TaskPayload) XXX_Size Uses

func (m *TaskPayload) XXX_Size() int

func (*TaskPayload) XXX_Unmarshal Uses

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

type TaskQueueAcl Uses

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 Uses

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

func (*TaskQueueAcl) GetUserEmail Uses

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

func (*TaskQueueAcl) GetWriterEmail Uses

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

func (*TaskQueueAcl) ProtoMessage Uses

func (*TaskQueueAcl) ProtoMessage()

func (*TaskQueueAcl) Reset Uses

func (m *TaskQueueAcl) Reset()

func (*TaskQueueAcl) String Uses

func (m *TaskQueueAcl) String() string

func (*TaskQueueAcl) XXX_DiscardUnknown Uses

func (m *TaskQueueAcl) XXX_DiscardUnknown()

func (*TaskQueueAcl) XXX_Marshal Uses

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

func (*TaskQueueAcl) XXX_Merge Uses

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

func (*TaskQueueAcl) XXX_Size Uses

func (m *TaskQueueAcl) XXX_Size() int

func (*TaskQueueAcl) XXX_Unmarshal Uses

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

type TaskQueueAddRequest Uses

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 Uses

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

func (*TaskQueueAddRequest) GetAppId Uses

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

func (*TaskQueueAddRequest) GetBody Uses

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

func (*TaskQueueAddRequest) GetCrontimetable Uses

func (m *TaskQueueAddRequest) GetCrontimetable() *TaskQueueAddRequest_CronTimetable

func (*TaskQueueAddRequest) GetDescription Uses

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

func (*TaskQueueAddRequest) GetEtaUsec Uses

func (m *TaskQueueAddRequest) GetEtaUsec() int64

func (*TaskQueueAddRequest) GetHeader Uses

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

func (*TaskQueueAddRequest) GetMethod Uses

func (m *TaskQueueAddRequest) GetMethod() TaskQueueAddRequest_RequestMethod

func (*TaskQueueAddRequest) GetMode Uses

func (m *TaskQueueAddRequest) GetMode() TaskQueueMode_Mode

func (*TaskQueueAddRequest) GetPayload Uses

func (m *TaskQueueAddRequest) GetPayload() *TaskPayload

func (*TaskQueueAddRequest) GetQueueName Uses

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

func (*TaskQueueAddRequest) GetRetryParameters Uses

func (m *TaskQueueAddRequest) GetRetryParameters() *TaskQueueRetryParameters

func (*TaskQueueAddRequest) GetTag Uses

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

func (*TaskQueueAddRequest) GetTaskName Uses

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

func (*TaskQueueAddRequest) GetTransaction Uses

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

func (*TaskQueueAddRequest) GetUrl Uses

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

func (*TaskQueueAddRequest) ProtoMessage Uses

func (*TaskQueueAddRequest) ProtoMessage()

func (*TaskQueueAddRequest) Reset Uses

func (m *TaskQueueAddRequest) Reset()

func (*TaskQueueAddRequest) String Uses

func (m *TaskQueueAddRequest) String() string

func (*TaskQueueAddRequest) XXX_DiscardUnknown Uses

func (m *TaskQueueAddRequest) XXX_DiscardUnknown()

func (*TaskQueueAddRequest) XXX_Marshal Uses

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

func (*TaskQueueAddRequest) XXX_Merge Uses

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

func (*TaskQueueAddRequest) XXX_Size Uses

func (m *TaskQueueAddRequest) XXX_Size() int

func (*TaskQueueAddRequest) XXX_Unmarshal Uses

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

type TaskQueueAddRequest_CronTimetable Uses

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 Uses

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

func (*TaskQueueAddRequest_CronTimetable) GetSchedule Uses

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

func (*TaskQueueAddRequest_CronTimetable) GetTimezone Uses

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

func (*TaskQueueAddRequest_CronTimetable) ProtoMessage Uses

func (*TaskQueueAddRequest_CronTimetable) ProtoMessage()

func (*TaskQueueAddRequest_CronTimetable) Reset Uses

func (m *TaskQueueAddRequest_CronTimetable) Reset()

func (*TaskQueueAddRequest_CronTimetable) String Uses

func (m *TaskQueueAddRequest_CronTimetable) String() string

func (*TaskQueueAddRequest_CronTimetable) XXX_DiscardUnknown Uses

func (m *TaskQueueAddRequest_CronTimetable) XXX_DiscardUnknown()

func (*TaskQueueAddRequest_CronTimetable) XXX_Marshal Uses

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

func (*TaskQueueAddRequest_CronTimetable) XXX_Merge Uses

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

func (*TaskQueueAddRequest_CronTimetable) XXX_Size Uses

func (m *TaskQueueAddRequest_CronTimetable) XXX_Size() int

func (*TaskQueueAddRequest_CronTimetable) XXX_Unmarshal Uses

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

type TaskQueueAddRequest_Header Uses

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 Uses

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

func (*TaskQueueAddRequest_Header) GetKey Uses

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

func (*TaskQueueAddRequest_Header) GetValue Uses

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

func (*TaskQueueAddRequest_Header) ProtoMessage Uses

func (*TaskQueueAddRequest_Header) ProtoMessage()

func (*TaskQueueAddRequest_Header) Reset Uses

func (m *TaskQueueAddRequest_Header) Reset()

func (*TaskQueueAddRequest_Header) String Uses

func (m *TaskQueueAddRequest_Header) String() string

func (*TaskQueueAddRequest_Header) XXX_DiscardUnknown Uses

func (m *TaskQueueAddRequest_Header) XXX_DiscardUnknown()

func (*TaskQueueAddRequest_Header) XXX_Marshal Uses

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

func (*TaskQueueAddRequest_Header) XXX_Merge Uses

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

func (*TaskQueueAddRequest_Header) XXX_Size Uses

func (m *TaskQueueAddRequest_Header) XXX_Size() int

func (*TaskQueueAddRequest_Header) XXX_Unmarshal Uses

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

type TaskQueueAddRequest_RequestMethod Uses

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 Uses

func (x TaskQueueAddRequest_RequestMethod) Enum() *TaskQueueAddRequest_RequestMethod

func (TaskQueueAddRequest_RequestMethod) EnumDescriptor Uses

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

func (TaskQueueAddRequest_RequestMethod) String Uses

func (x TaskQueueAddRequest_RequestMethod) String() string

func (*TaskQueueAddRequest_RequestMethod) UnmarshalJSON Uses

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

type TaskQueueAddResponse Uses

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 Uses

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

func (*TaskQueueAddResponse) GetChosenTaskName Uses

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

func (*TaskQueueAddResponse) ProtoMessage Uses

func (*TaskQueueAddResponse) ProtoMessage()

func (*TaskQueueAddResponse) Reset Uses

func (m *TaskQueueAddResponse) Reset()

func (*TaskQueueAddResponse) String Uses

func (m *TaskQueueAddResponse) String() string

func (*TaskQueueAddResponse) XXX_DiscardUnknown Uses

func (m *TaskQueueAddResponse) XXX_DiscardUnknown()

func (*TaskQueueAddResponse) XXX_Marshal Uses

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

func (*TaskQueueAddResponse) XXX_Merge Uses

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

func (*TaskQueueAddResponse) XXX_Size Uses

func (m *TaskQueueAddResponse) XXX_Size() int

func (*TaskQueueAddResponse) XXX_Unmarshal Uses

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

type TaskQueueBulkAddRequest Uses

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 Uses

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

func (*TaskQueueBulkAddRequest) GetAddRequest Uses

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

func (*TaskQueueBulkAddRequest) ProtoMessage Uses

func (*TaskQueueBulkAddRequest) ProtoMessage()

func (*TaskQueueBulkAddRequest) Reset Uses

func (m *TaskQueueBulkAddRequest) Reset()

func (*TaskQueueBulkAddRequest) String Uses

func (m *TaskQueueBulkAddRequest) String() string

func (*TaskQueueBulkAddRequest) XXX_DiscardUnknown Uses

func (m *TaskQueueBulkAddRequest) XXX_DiscardUnknown()

func (*TaskQueueBulkAddRequest) XXX_Marshal Uses

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

func (*TaskQueueBulkAddRequest) XXX_Merge Uses

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

func (*TaskQueueBulkAddRequest) XXX_Size Uses

func (m *TaskQueueBulkAddRequest) XXX_Size() int

func (*TaskQueueBulkAddRequest) XXX_Unmarshal Uses

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

type TaskQueueBulkAddResponse Uses

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 Uses

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

func (*TaskQueueBulkAddResponse) GetTaskresult Uses

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

func (*TaskQueueBulkAddResponse) ProtoMessage Uses

func (*TaskQueueBulkAddResponse) ProtoMessage()

func (*TaskQueueBulkAddResponse) Reset Uses

func (m *TaskQueueBulkAddResponse) Reset()

func (*TaskQueueBulkAddResponse) String Uses

func (m *TaskQueueBulkAddResponse) String() string

func (*TaskQueueBulkAddResponse) XXX_DiscardUnknown Uses

func (m *TaskQueueBulkAddResponse) XXX_DiscardUnknown()

func (*TaskQueueBulkAddResponse) XXX_Marshal Uses

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

func (*TaskQueueBulkAddResponse) XXX_Merge Uses

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

func (*TaskQueueBulkAddResponse) XXX_Size Uses

func (m *TaskQueueBulkAddResponse) XXX_Size() int

func (*TaskQueueBulkAddResponse) XXX_Unmarshal Uses

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

type TaskQueueBulkAddResponse_TaskResult Uses

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 Uses

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

func (*TaskQueueBulkAddResponse_TaskResult) GetChosenTaskName Uses

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

func (*TaskQueueBulkAddResponse_TaskResult) GetResult Uses

func (m *TaskQueueBulkAddResponse_TaskResult) GetResult() TaskQueueServiceError_ErrorCode

func (*TaskQueueBulkAddResponse_TaskResult) ProtoMessage Uses

func (*TaskQueueBulkAddResponse_TaskResult) ProtoMessage()

func (*TaskQueueBulkAddResponse_TaskResult) Reset Uses

func (m *TaskQueueBulkAddResponse_TaskResult) Reset()

func (*TaskQueueBulkAddResponse_TaskResult) String Uses

func (m *TaskQueueBulkAddResponse_TaskResult) String() string

func (*TaskQueueBulkAddResponse_TaskResult) XXX_DiscardUnknown Uses

func (m *TaskQueueBulkAddResponse_TaskResult) XXX_DiscardUnknown()

func (*TaskQueueBulkAddResponse_TaskResult) XXX_Marshal Uses

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

func (*TaskQueueBulkAddResponse_TaskResult) XXX_Merge Uses

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

func (*TaskQueueBulkAddResponse_TaskResult) XXX_Size Uses

func (m *TaskQueueBulkAddResponse_TaskResult) XXX_Size() int

func (*TaskQueueBulkAddResponse_TaskResult) XXX_Unmarshal Uses

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

type TaskQueueDeleteGroupRequest Uses

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 Uses

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

func (*TaskQueueDeleteGroupRequest) GetAppId Uses

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

func (*TaskQueueDeleteGroupRequest) ProtoMessage Uses

func (*TaskQueueDeleteGroupRequest) ProtoMessage()

func (*TaskQueueDeleteGroupRequest) Reset Uses

func (m *TaskQueueDeleteGroupRequest) Reset()

func (*TaskQueueDeleteGroupRequest) String Uses

func (m *TaskQueueDeleteGroupRequest) String() string

func (*TaskQueueDeleteGroupRequest) XXX_DiscardUnknown Uses

func (m *TaskQueueDeleteGroupRequest) XXX_DiscardUnknown()

func (*TaskQueueDeleteGroupRequest) XXX_Marshal Uses

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

func (*TaskQueueDeleteGroupRequest) XXX_Merge Uses

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

func (*TaskQueueDeleteGroupRequest) XXX_Size Uses

func (m *TaskQueueDeleteGroupRequest) XXX_Size() int

func (*TaskQueueDeleteGroupRequest) XXX_Unmarshal Uses

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

type TaskQueueDeleteGroupResponse Uses

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

func (*TaskQueueDeleteGroupResponse) Descriptor Uses

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

func (*TaskQueueDeleteGroupResponse) ProtoMessage Uses

func (*TaskQueueDeleteGroupResponse) ProtoMessage()

func (*TaskQueueDeleteGroupResponse) Reset Uses

func (m *TaskQueueDeleteGroupResponse) Reset()

func (*TaskQueueDeleteGroupResponse) String Uses

func (m *TaskQueueDeleteGroupResponse) String() string

func (*TaskQueueDeleteGroupResponse) XXX_DiscardUnknown Uses

func (m *TaskQueueDeleteGroupResponse) XXX_DiscardUnknown()

func (*TaskQueueDeleteGroupResponse) XXX_Marshal Uses

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

func (*TaskQueueDeleteGroupResponse) XXX_Merge Uses

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

func (*TaskQueueDeleteGroupResponse) XXX_Size Uses

func (m *TaskQueueDeleteGroupResponse) XXX_Size() int

func (*TaskQueueDeleteGroupResponse) XXX_Unmarshal Uses

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

type TaskQueueDeleteQueueRequest Uses

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 Uses

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

func (*TaskQueueDeleteQueueRequest) GetAppId Uses

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

func (*TaskQueueDeleteQueueRequest) GetQueueName Uses

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

func (*TaskQueueDeleteQueueRequest) ProtoMessage Uses

func (*TaskQueueDeleteQueueRequest) ProtoMessage()

func (*TaskQueueDeleteQueueRequest) Reset Uses

func (m *TaskQueueDeleteQueueRequest) Reset()

func (*TaskQueueDeleteQueueRequest) String Uses

func (m *TaskQueueDeleteQueueRequest) String() string

func (*TaskQueueDeleteQueueRequest) XXX_DiscardUnknown Uses

func (m *TaskQueueDeleteQueueRequest) XXX_DiscardUnknown()

func (*TaskQueueDeleteQueueRequest) XXX_Marshal Uses

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

func (*TaskQueueDeleteQueueRequest) XXX_Merge Uses

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

func (*TaskQueueDeleteQueueRequest) XXX_Size Uses

func (m *TaskQueueDeleteQueueRequest) XXX_Size() int

func (*TaskQueueDeleteQueueRequest) XXX_Unmarshal Uses

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

type TaskQueueDeleteQueueResponse Uses

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

func (*TaskQueueDeleteQueueResponse) Descriptor Uses

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

func (*TaskQueueDeleteQueueResponse) ProtoMessage Uses

func (*TaskQueueDeleteQueueResponse) ProtoMessage()

func (*TaskQueueDeleteQueueResponse) Reset Uses

func (m *TaskQueueDeleteQueueResponse) Reset()

func (*TaskQueueDeleteQueueResponse) String Uses

func (m *TaskQueueDeleteQueueResponse) String() string

func (*TaskQueueDeleteQueueResponse) XXX_DiscardUnknown Uses

func (m *TaskQueueDeleteQueueResponse) XXX_DiscardUnknown()

func (*TaskQueueDeleteQueueResponse) XXX_Marshal Uses

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

func (*TaskQueueDeleteQueueResponse) XXX_Merge Uses

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

func (*TaskQueueDeleteQueueResponse) XXX_Size Uses

func (m *TaskQueueDeleteQueueResponse) XXX_Size() int

func (*TaskQueueDeleteQueueResponse) XXX_Unmarshal Uses

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

type TaskQueueDeleteRequest Uses

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 Uses

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

func (*TaskQueueDeleteRequest) GetAppId Uses

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

func (*TaskQueueDeleteRequest) GetQueueName Uses

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

func (*TaskQueueDeleteRequest) GetTaskName Uses

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

func (*TaskQueueDeleteRequest) ProtoMessage Uses

func (*TaskQueueDeleteRequest) ProtoMessage()

func (*TaskQueueDeleteRequest) Reset Uses

func (m *TaskQueueDeleteRequest) Reset()

func (*TaskQueueDeleteRequest) String Uses

func (m *TaskQueueDeleteRequest) String() string

func (*TaskQueueDeleteRequest) XXX_DiscardUnknown Uses

func (m *TaskQueueDeleteRequest) XXX_DiscardUnknown()

func (*TaskQueueDeleteRequest) XXX_Marshal Uses

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

func (*TaskQueueDeleteRequest) XXX_Merge Uses

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

func (*TaskQueueDeleteRequest) XXX_Size Uses

func (m *TaskQueueDeleteRequest) XXX_Size() int

func (*TaskQueueDeleteRequest) XXX_Unmarshal Uses

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

type TaskQueueDeleteResponse Uses

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 Uses

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

func (*TaskQueueDeleteResponse) GetResult Uses

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

func (*TaskQueueDeleteResponse) ProtoMessage Uses

func (*TaskQueueDeleteResponse) ProtoMessage()

func (*TaskQueueDeleteResponse) Reset Uses

func (m *TaskQueueDeleteResponse) Reset()

func (*TaskQueueDeleteResponse) String Uses

func (m *TaskQueueDeleteResponse) String() string

func (*TaskQueueDeleteResponse) XXX_DiscardUnknown Uses

func (m *TaskQueueDeleteResponse) XXX_DiscardUnknown()

func (*TaskQueueDeleteResponse) XXX_Marshal Uses

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

func (*TaskQueueDeleteResponse) XXX_Merge Uses

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

func (*TaskQueueDeleteResponse) XXX_Size Uses

func (m *TaskQueueDeleteResponse) XXX_Size() int

func (*TaskQueueDeleteResponse) XXX_Unmarshal Uses

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

type TaskQueueFetchQueueStatsRequest Uses

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 Uses

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

func (*TaskQueueFetchQueueStatsRequest) GetAppId Uses

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

func (*TaskQueueFetchQueueStatsRequest) GetMaxNumTasks Uses

func (m *TaskQueueFetchQueueStatsRequest) GetMaxNumTasks() int32

func (*TaskQueueFetchQueueStatsRequest) GetQueueName Uses

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

func (*TaskQueueFetchQueueStatsRequest) ProtoMessage Uses

func (*TaskQueueFetchQueueStatsRequest) ProtoMessage()

func (*TaskQueueFetchQueueStatsRequest) Reset Uses

func (m *TaskQueueFetchQueueStatsRequest) Reset()

func (*TaskQueueFetchQueueStatsRequest) String Uses

func (m *TaskQueueFetchQueueStatsRequest) String() string

func (*TaskQueueFetchQueueStatsRequest) XXX_DiscardUnknown Uses

func (m *TaskQueueFetchQueueStatsRequest) XXX_DiscardUnknown()

func (*TaskQueueFetchQueueStatsRequest) XXX_Marshal Uses

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

func (*TaskQueueFetchQueueStatsRequest) XXX_Merge Uses

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

func (*TaskQueueFetchQueueStatsRequest) XXX_Size Uses

func (m *TaskQueueFetchQueueStatsRequest) XXX_Size() int

func (*TaskQueueFetchQueueStatsRequest) XXX_Unmarshal Uses

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

type TaskQueueFetchQueueStatsResponse Uses

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 Uses

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

func (*TaskQueueFetchQueueStatsResponse) GetQueuestats Uses

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

func (*TaskQueueFetchQueueStatsResponse) ProtoMessage Uses

func (*TaskQueueFetchQueueStatsResponse) ProtoMessage()

func (*TaskQueueFetchQueueStatsResponse) Reset Uses

func (m *TaskQueueFetchQueueStatsResponse) Reset()

func (*TaskQueueFetchQueueStatsResponse) String Uses

func (m *TaskQueueFetchQueueStatsResponse) String() string

func (*TaskQueueFetchQueueStatsResponse) XXX_DiscardUnknown Uses

func (m *TaskQueueFetchQueueStatsResponse) XXX_DiscardUnknown()

func (*TaskQueueFetchQueueStatsResponse) XXX_Marshal Uses

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

func (*TaskQueueFetchQueueStatsResponse) XXX_Merge Uses

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

func (*TaskQueueFetchQueueStatsResponse) XXX_Size Uses

func (m *TaskQueueFetchQueueStatsResponse) XXX_Size() int

func (*TaskQueueFetchQueueStatsResponse) XXX_Unmarshal Uses

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

type TaskQueueFetchQueueStatsResponse_QueueStats Uses

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 Uses

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

func (*TaskQueueFetchQueueStatsResponse_QueueStats) GetNumTasks Uses

func (m *TaskQueueFetchQueueStatsResponse_QueueStats) GetNumTasks() int32

func (*TaskQueueFetchQueueStatsResponse_QueueStats) GetOldestEtaUsec Uses

func (m *TaskQueueFetchQueueStatsResponse_QueueStats) GetOldestEtaUsec() int64

func (*TaskQueueFetchQueueStatsResponse_QueueStats) GetScannerInfo Uses

func (m *TaskQueueFetchQueueStatsResponse_QueueStats) GetScannerInfo() *TaskQueueScannerQueueInfo

func (*TaskQueueFetchQueueStatsResponse_QueueStats) ProtoMessage Uses

func (*TaskQueueFetchQueueStatsResponse_QueueStats) ProtoMessage()

func (*TaskQueueFetchQueueStatsResponse_QueueStats) Reset Uses

func (m *TaskQueueFetchQueueStatsResponse_QueueStats) Reset()

func (*TaskQueueFetchQueueStatsResponse_QueueStats) String Uses

func (m *TaskQueueFetchQueueStatsResponse_QueueStats) String() string

func (*TaskQueueFetchQueueStatsResponse_QueueStats) XXX_DiscardUnknown Uses

func (m *TaskQueueFetchQueueStatsResponse_QueueStats) XXX_DiscardUnknown()

func (*TaskQueueFetchQueueStatsResponse_QueueStats) XXX_Marshal Uses

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

func (*TaskQueueFetchQueueStatsResponse_QueueStats) XXX_Merge Uses

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

func (*TaskQueueFetchQueueStatsResponse_QueueStats) XXX_Size Uses

func (m *TaskQueueFetchQueueStatsResponse_QueueStats) XXX_Size() int

func (*TaskQueueFetchQueueStatsResponse_QueueStats) XXX_Unmarshal Uses

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

type TaskQueueFetchQueuesRequest Uses

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 Uses

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

func (*TaskQueueFetchQueuesRequest) GetAppId Uses

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

func (*TaskQueueFetchQueuesRequest) GetMaxRows Uses

func (m *TaskQueueFetchQueuesRequest) GetMaxRows() int32

func (*TaskQueueFetchQueuesRequest) ProtoMessage Uses

func (*TaskQueueFetchQueuesRequest) ProtoMessage()

func (*TaskQueueFetchQueuesRequest) Reset Uses

func (m *TaskQueueFetchQueuesRequest) Reset()

func (*TaskQueueFetchQueuesRequest) String Uses

func (m *TaskQueueFetchQueuesRequest) String() string

func (*TaskQueueFetchQueuesRequest) XXX_DiscardUnknown Uses

func (m *TaskQueueFetchQueuesRequest) XXX_DiscardUnknown()

func (*TaskQueueFetchQueuesRequest) XXX_Marshal Uses

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

func (*TaskQueueFetchQueuesRequest) XXX_Merge Uses

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

func (*TaskQueueFetchQueuesRequest) XXX_Size Uses

func (m *TaskQueueFetchQueuesRequest) XXX_Size() int

func (*TaskQueueFetchQueuesRequest) XXX_Unmarshal Uses

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

type TaskQueueFetchQueuesResponse Uses

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 Uses

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

func (*TaskQueueFetchQueuesResponse) GetQueue Uses

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

func (*TaskQueueFetchQueuesResponse) ProtoMessage Uses

func (*TaskQueueFetchQueuesResponse) ProtoMessage()

func (*TaskQueueFetchQueuesResponse) Reset Uses

func (m *TaskQueueFetchQueuesResponse) Reset()

func (*TaskQueueFetchQueuesResponse) String Uses

func (m *TaskQueueFetchQueuesResponse) String() string

func (*TaskQueueFetchQueuesResponse) XXX_DiscardUnknown Uses

func (m *TaskQueueFetchQueuesResponse) XXX_DiscardUnknown()

func (*TaskQueueFetchQueuesResponse) XXX_Marshal Uses

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

func (*TaskQueueFetchQueuesResponse) XXX_Merge Uses

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

func (*TaskQueueFetchQueuesResponse) XXX_Size Uses

func (m *TaskQueueFetchQueuesResponse) XXX_Size() int

func (*TaskQueueFetchQueuesResponse) XXX_Unmarshal Uses

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

type TaskQueueFetchQueuesResponse_Queue Uses

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 Uses

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

func (*TaskQueueFetchQueuesResponse_Queue) GetAcl Uses

func (m *TaskQueueFetchQueuesResponse_Queue) GetAcl() *TaskQueueAcl

func (*TaskQueueFetchQueuesResponse_Queue) GetBucketCapacity Uses

func (m *TaskQueueFetchQueuesResponse_Queue) GetBucketCapacity() float64

func (*TaskQueueFetchQueuesResponse_Queue) GetBucketRefillPerSecond Uses

func (m *TaskQueueFetchQueuesResponse_Queue) GetBucketRefillPerSecond() float64

func (*TaskQueueFetchQueuesResponse_Queue) GetCreatorName Uses

func (m *TaskQueueFetchQueuesResponse_Queue) GetCreatorName() string

func (*TaskQueueFetchQueuesResponse_Queue) GetHeaderOverride Uses

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

func (*TaskQueueFetchQueuesResponse_Queue) GetMaxConcurrentRequests Uses

func (m *TaskQueueFetchQueuesResponse_Queue) GetMaxConcurrentRequests() int32

func (*TaskQueueFetchQueuesResponse_Queue) GetMode Uses

func (m *TaskQueueFetchQueuesResponse_Queue) GetMode() TaskQueueMode_Mode

func (*TaskQueueFetchQueuesResponse_Queue) GetPaused Uses

func (m *TaskQueueFetchQueuesResponse_Queue) GetPaused() bool

func (*TaskQueueFetchQueuesResponse_Queue) GetQueueName Uses

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

func (*TaskQueueFetchQueuesResponse_Queue) GetRetryParameters Uses

func (m *TaskQueueFetchQueuesResponse_Queue) GetRetryParameters() *TaskQueueRetryParameters

func (*TaskQueueFetchQueuesResponse_Queue) GetUserSpecifiedRate Uses

func (m *TaskQueueFetchQueuesResponse_Queue) GetUserSpecifiedRate() string

func (*TaskQueueFetchQueuesResponse_Queue) ProtoMessage Uses

func (*TaskQueueFetchQueuesResponse_Queue) ProtoMessage()

func (*TaskQueueFetchQueuesResponse_Queue) Reset Uses

func (m *TaskQueueFetchQueuesResponse_Queue) Reset()

func (*TaskQueueFetchQueuesResponse_Queue) String Uses

func (m *TaskQueueFetchQueuesResponse_Queue) String() string

func (*TaskQueueFetchQueuesResponse_Queue) XXX_DiscardUnknown Uses

func (m *TaskQueueFetchQueuesResponse_Queue) XXX_DiscardUnknown()

func (*TaskQueueFetchQueuesResponse_Queue) XXX_Marshal Uses

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

func (*TaskQueueFetchQueuesResponse_Queue) XXX_Merge Uses

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

func (*TaskQueueFetchQueuesResponse_Queue) XXX_Size Uses

func (m *TaskQueueFetchQueuesResponse_Queue) XXX_Size() int

func (*TaskQueueFetchQueuesResponse_Queue) XXX_Unmarshal Uses

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

type TaskQueueFetchTaskRequest Uses

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 Uses

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

func (*TaskQueueFetchTaskRequest) GetAppId Uses

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

func (*TaskQueueFetchTaskRequest) GetQueueName Uses

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

func (*TaskQueueFetchTaskRequest) GetTaskName Uses

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

func (*TaskQueueFetchTaskRequest) ProtoMessage Uses

func (*TaskQueueFetchTaskRequest) ProtoMessage()

func (*TaskQueueFetchTaskRequest) Reset Uses

func (m *TaskQueueFetchTaskRequest) Reset()

func (*TaskQueueFetchTaskRequest) String Uses

func (m *TaskQueueFetchTaskRequest) String() string

func (*TaskQueueFetchTaskRequest) XXX_DiscardUnknown Uses

func (m *TaskQueueFetchTaskRequest) XXX_DiscardUnknown()

func (*TaskQueueFetchTaskRequest) XXX_Marshal Uses

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

func (*TaskQueueFetchTaskRequest) XXX_Merge Uses

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

func (*TaskQueueFetchTaskRequest) XXX_Size Uses

func (m *TaskQueueFetchTaskRequest) XXX_Size() int

func (*TaskQueueFetchTaskRequest) XXX_Unmarshal Uses

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

type TaskQueueFetchTaskResponse Uses

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 Uses

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

func (*TaskQueueFetchTaskResponse) GetTask Uses

func (m *TaskQueueFetchTaskResponse) GetTask() *TaskQueueQueryTasksResponse

func (*TaskQueueFetchTaskResponse) ProtoMessage Uses

func (*TaskQueueFetchTaskResponse) ProtoMessage()

func (*TaskQueueFetchTaskResponse) Reset Uses

func (m *TaskQueueFetchTaskResponse) Reset()

func (*TaskQueueFetchTaskResponse) String Uses

func (m *TaskQueueFetchTaskResponse) String() string

func (*TaskQueueFetchTaskResponse) XXX_DiscardUnknown Uses

func (m *TaskQueueFetchTaskResponse) XXX_DiscardUnknown()

func (*TaskQueueFetchTaskResponse) XXX_Marshal Uses

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

func (*TaskQueueFetchTaskResponse) XXX_Merge Uses

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

func (*TaskQueueFetchTaskResponse) XXX_Size Uses

func (m *TaskQueueFetchTaskResponse) XXX_Size() int

func (*TaskQueueFetchTaskResponse) XXX_Unmarshal Uses

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

type TaskQueueForceRunRequest Uses

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 Uses

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

func (*TaskQueueForceRunRequest) GetAppId Uses

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

func (*TaskQueueForceRunRequest) GetQueueName Uses

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

func (*TaskQueueForceRunRequest) GetTaskName Uses

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

func (*TaskQueueForceRunRequest) ProtoMessage Uses

func (*TaskQueueForceRunRequest) ProtoMessage()

func (*TaskQueueForceRunRequest) Reset Uses

func (m *TaskQueueForceRunRequest) Reset()

func (*TaskQueueForceRunRequest) String Uses

func (m *TaskQueueForceRunRequest) String() string

func (*TaskQueueForceRunRequest) XXX_DiscardUnknown Uses

func (m *TaskQueueForceRunRequest) XXX_DiscardUnknown()

func (*TaskQueueForceRunRequest) XXX_Marshal Uses

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

func (*TaskQueueForceRunRequest) XXX_Merge Uses

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

func (*TaskQueueForceRunRequest) XXX_Size Uses

func (m *TaskQueueForceRunRequest) XXX_Size() int

func (*TaskQueueForceRunRequest) XXX_Unmarshal Uses

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

type TaskQueueForceRunResponse Uses

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 Uses

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

func (*TaskQueueForceRunResponse) GetResult Uses

func (m *TaskQueueForceRunResponse) GetResult() TaskQueueServiceError_ErrorCode

func (*TaskQueueForceRunResponse) ProtoMessage Uses

func (*TaskQueueForceRunResponse) ProtoMessage()

func (*TaskQueueForceRunResponse) Reset Uses

func (m *TaskQueueForceRunResponse) Reset()

func (*TaskQueueForceRunResponse) String Uses

func (m *TaskQueueForceRunResponse) String() string

func (*TaskQueueForceRunResponse) XXX_DiscardUnknown Uses

func (m *TaskQueueForceRunResponse) XXX_DiscardUnknown()

func (*TaskQueueForceRunResponse) XXX_Marshal Uses

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

func (*TaskQueueForceRunResponse) XXX_Merge Uses

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

func (*TaskQueueForceRunResponse) XXX_Size Uses

func (m *TaskQueueForceRunResponse) XXX_Size() int

func (*TaskQueueForceRunResponse) XXX_Unmarshal Uses

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

type TaskQueueHttpHeader Uses

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 Uses

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

func (*TaskQueueHttpHeader) GetKey Uses

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

func (*TaskQueueHttpHeader) GetValue Uses

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

func (*TaskQueueHttpHeader) ProtoMessage Uses

func (*TaskQueueHttpHeader) ProtoMessage()

func (*TaskQueueHttpHeader) Reset Uses

func (m *TaskQueueHttpHeader) Reset()

func (*TaskQueueHttpHeader) String Uses

func (m *TaskQueueHttpHeader) String() string

func (*TaskQueueHttpHeader) XXX_DiscardUnknown Uses

func (m *TaskQueueHttpHeader) XXX_DiscardUnknown()

func (*TaskQueueHttpHeader) XXX_Marshal Uses

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

func (*TaskQueueHttpHeader) XXX_Merge Uses

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

func (*TaskQueueHttpHeader) XXX_Size Uses

func (m *TaskQueueHttpHeader) XXX_Size() int

func (*TaskQueueHttpHeader) XXX_Unmarshal Uses

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

type TaskQueueMode Uses

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

func (*TaskQueueMode) Descriptor Uses

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

func (*TaskQueueMode) ProtoMessage Uses

func (*TaskQueueMode) ProtoMessage()

func (*TaskQueueMode) Reset Uses

func (m *TaskQueueMode) Reset()

func (*TaskQueueMode) String Uses

func (m *TaskQueueMode) String() string

func (*TaskQueueMode) XXX_DiscardUnknown Uses

func (m *TaskQueueMode) XXX_DiscardUnknown()

func (*TaskQueueMode) XXX_Marshal Uses

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

func (*TaskQueueMode) XXX_Merge Uses

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

func (*TaskQueueMode) XXX_Size Uses

func (m *TaskQueueMode) XXX_Size() int

func (*TaskQueueMode) XXX_Unmarshal Uses

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

type TaskQueueMode_Mode Uses

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 Uses

func (x TaskQueueMode_Mode) Enum() *TaskQueueMode_Mode

func (TaskQueueMode_Mode) EnumDescriptor Uses

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

func (TaskQueueMode_Mode) String Uses

func (x TaskQueueMode_Mode) String() string

func (*TaskQueueMode_Mode) UnmarshalJSON Uses

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

type TaskQueueModifyTaskLeaseRequest Uses

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 Uses

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

func (*TaskQueueModifyTaskLeaseRequest) GetEtaUsec Uses

func (m *TaskQueueModifyTaskLeaseRequest) GetEtaUsec() int64

func (*TaskQueueModifyTaskLeaseRequest) GetLeaseSeconds Uses

func (m *TaskQueueModifyTaskLeaseRequest) GetLeaseSeconds() float64

func (*TaskQueueModifyTaskLeaseRequest) GetQueueName Uses

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

func (*TaskQueueModifyTaskLeaseRequest) GetTaskName Uses

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

func (*TaskQueueModifyTaskLeaseRequest) ProtoMessage Uses

func (*TaskQueueModifyTaskLeaseRequest) ProtoMessage()

func (*TaskQueueModifyTaskLeaseRequest) Reset Uses

func (m *TaskQueueModifyTaskLeaseRequest) Reset()

func (*TaskQueueModifyTaskLeaseRequest) String Uses

func (m *TaskQueueModifyTaskLeaseRequest) String() string

func (*TaskQueueModifyTaskLeaseRequest) XXX_DiscardUnknown Uses

func (m *TaskQueueModifyTaskLeaseRequest) XXX_DiscardUnknown()

func (*TaskQueueModifyTaskLeaseRequest) XXX_Marshal Uses

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

func (*TaskQueueModifyTaskLeaseRequest) XXX_Merge Uses

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

func (*TaskQueueModifyTaskLeaseRequest) XXX_Size Uses

func (m *TaskQueueModifyTaskLeaseRequest) XXX_Size() int

func (*TaskQueueModifyTaskLeaseRequest) XXX_Unmarshal Uses

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

type TaskQueueModifyTaskLeaseResponse Uses

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 Uses

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

func (*TaskQueueModifyTaskLeaseResponse) GetUpdatedEtaUsec Uses

func (m *TaskQueueModifyTaskLeaseResponse) GetUpdatedEtaUsec() int64

func (*TaskQueueModifyTaskLeaseResponse) ProtoMessage Uses

func (*TaskQueueModifyTaskLeaseResponse) ProtoMessage()

func (*TaskQueueModifyTaskLeaseResponse) Reset Uses

func (m *TaskQueueModifyTaskLeaseResponse) Reset()

func (*TaskQueueModifyTaskLeaseResponse) String Uses

func (m *TaskQueueModifyTaskLeaseResponse) String() string

func (*TaskQueueModifyTaskLeaseResponse) XXX_DiscardUnknown Uses

func (m *TaskQueueModifyTaskLeaseResponse) XXX_DiscardUnknown()

func (*TaskQueueModifyTaskLeaseResponse) XXX_Marshal Uses

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

func (*TaskQueueModifyTaskLeaseResponse) XXX_Merge Uses

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

func (*TaskQueueModifyTaskLeaseResponse) XXX_Size Uses

func (m *TaskQueueModifyTaskLeaseResponse) XXX_Size() int

func (*TaskQueueModifyTaskLeaseResponse) XXX_Unmarshal Uses

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

type TaskQueuePauseQueueRequest Uses

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 Uses

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

func (*TaskQueuePauseQueueRequest) GetAppId Uses

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

func (*TaskQueuePauseQueueRequest) GetPause Uses

func (m *TaskQueuePauseQueueRequest) GetPause() bool

func (*TaskQueuePauseQueueRequest) GetQueueName Uses

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

func (*TaskQueuePauseQueueRequest) ProtoMessage Uses

func (*TaskQueuePauseQueueRequest) ProtoMessage()

func (*TaskQueuePauseQueueRequest) Reset Uses

func (m *TaskQueuePauseQueueRequest) Reset()

func (*TaskQueuePauseQueueRequest) String Uses

func (m *TaskQueuePauseQueueRequest) String() string

func (*TaskQueuePauseQueueRequest) XXX_DiscardUnknown Uses

func (m *TaskQueuePauseQueueRequest) XXX_DiscardUnknown()

func (*TaskQueuePauseQueueRequest) XXX_Marshal Uses

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

func (*TaskQueuePauseQueueRequest) XXX_Merge Uses

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

func (*TaskQueuePauseQueueRequest) XXX_Size Uses

func (m *TaskQueuePauseQueueRequest) XXX_Size() int

func (*TaskQueuePauseQueueRequest) XXX_Unmarshal Uses

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

type TaskQueuePauseQueueResponse Uses

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

func (*TaskQueuePauseQueueResponse) Descriptor Uses

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

func (*TaskQueuePauseQueueResponse) ProtoMessage Uses

func (*TaskQueuePauseQueueResponse) ProtoMessage()

func (*TaskQueuePauseQueueResponse) Reset Uses

func (m *TaskQueuePauseQueueResponse) Reset()

func (*TaskQueuePauseQueueResponse) String Uses

func (m *TaskQueuePauseQueueResponse) String() string

func (*TaskQueuePauseQueueResponse) XXX_DiscardUnknown Uses

func (m *TaskQueuePauseQueueResponse) XXX_DiscardUnknown()

func (*TaskQueuePauseQueueResponse) XXX_Marshal Uses

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

func (*TaskQueuePauseQueueResponse) XXX_Merge Uses

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

func (*TaskQueuePauseQueueResponse) XXX_Size Uses

func (m *TaskQueuePauseQueueResponse) XXX_Size() int

func (*TaskQueuePauseQueueResponse) XXX_Unmarshal Uses

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

type TaskQueuePurgeQueueRequest Uses

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 Uses

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

func (*TaskQueuePurgeQueueRequest) GetAppId Uses

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

func (*TaskQueuePurgeQueueRequest) GetQueueName Uses

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

func (*TaskQueuePurgeQueueRequest) ProtoMessage Uses

func (*TaskQueuePurgeQueueRequest) ProtoMessage()

func (*TaskQueuePurgeQueueRequest) Reset Uses

func (m *TaskQueuePurgeQueueRequest) Reset()

func (*TaskQueuePurgeQueueRequest) String Uses

func (m *TaskQueuePurgeQueueRequest) String() string

func (*TaskQueuePurgeQueueRequest) XXX_DiscardUnknown Uses

func (m *TaskQueuePurgeQueueRequest) XXX_DiscardUnknown()

func (*TaskQueuePurgeQueueRequest) XXX_Marshal Uses

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

func (*TaskQueuePurgeQueueRequest) XXX_Merge Uses

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

func (*TaskQueuePurgeQueueRequest) XXX_Size Uses

func (m *TaskQueuePurgeQueueRequest) XXX_Size() int

func (*TaskQueuePurgeQueueRequest) XXX_Unmarshal Uses

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

type TaskQueuePurgeQueueResponse Uses

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

func (*TaskQueuePurgeQueueResponse) Descriptor Uses

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

func (*TaskQueuePurgeQueueResponse) ProtoMessage Uses

func (*TaskQueuePurgeQueueResponse) ProtoMessage()

func (*TaskQueuePurgeQueueResponse) Reset Uses

func (m *TaskQueuePurgeQueueResponse) Reset()

func (*TaskQueuePurgeQueueResponse) String Uses

func (m *TaskQueuePurgeQueueResponse) String() string

func (*TaskQueuePurgeQueueResponse) XXX_DiscardUnknown Uses

func (m *TaskQueuePurgeQueueResponse) XXX_DiscardUnknown()

func (*TaskQueuePurgeQueueResponse) XXX_Marshal Uses

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

func (*TaskQueuePurgeQueueResponse) XXX_Merge Uses

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

func (*TaskQueuePurgeQueueResponse) XXX_Size Uses

func (m *TaskQueuePurgeQueueResponse) XXX_Size() int

func (*TaskQueuePurgeQueueResponse) XXX_Unmarshal Uses

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

type TaskQueueQueryAndOwnTasksRequest Uses

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 Uses

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

func (*TaskQueueQueryAndOwnTasksRequest) GetGroupByTag Uses

func (m *TaskQueueQueryAndOwnTasksRequest) GetGroupByTag() bool

func (*TaskQueueQueryAndOwnTasksRequest) GetLeaseSeconds Uses

func (m *TaskQueueQueryAndOwnTasksRequest) GetLeaseSeconds() float64

func (*TaskQueueQueryAndOwnTasksRequest) GetMaxTasks Uses

func (m *TaskQueueQueryAndOwnTasksRequest) GetMaxTasks() int64

func (*TaskQueueQueryAndOwnTasksRequest) GetQueueName Uses

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

func (*TaskQueueQueryAndOwnTasksRequest) GetTag Uses

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

func (*TaskQueueQueryAndOwnTasksRequest) ProtoMessage Uses

func (*TaskQueueQueryAndOwnTasksRequest) ProtoMessage()

func (*TaskQueueQueryAndOwnTasksRequest) Reset Uses

func (m *TaskQueueQueryAndOwnTasksRequest) Reset()

func (*TaskQueueQueryAndOwnTasksRequest) String Uses

func (m *TaskQueueQueryAndOwnTasksRequest) String() string

func (*TaskQueueQueryAndOwnTasksRequest) XXX_DiscardUnknown Uses

func (m *TaskQueueQueryAndOwnTasksRequest) XXX_DiscardUnknown()

func (*TaskQueueQueryAndOwnTasksRequest) XXX_Marshal Uses

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

func (*TaskQueueQueryAndOwnTasksRequest) XXX_Merge Uses

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

func (*TaskQueueQueryAndOwnTasksRequest) XXX_Size Uses

func (m *TaskQueueQueryAndOwnTasksRequest) XXX_Size() int

func (*TaskQueueQueryAndOwnTasksRequest) XXX_Unmarshal Uses

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

type TaskQueueQueryAndOwnTasksResponse Uses

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 Uses

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

func (*TaskQueueQueryAndOwnTasksResponse) GetTask Uses

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

func (*TaskQueueQueryAndOwnTasksResponse) ProtoMessage Uses

func (*TaskQueueQueryAndOwnTasksResponse) ProtoMessage()

func (*TaskQueueQueryAndOwnTasksResponse) Reset Uses

func (m *TaskQueueQueryAndOwnTasksResponse) Reset()

func (*TaskQueueQueryAndOwnTasksResponse) String Uses

func (m *TaskQueueQueryAndOwnTasksResponse) String() string

func (*TaskQueueQueryAndOwnTasksResponse) XXX_DiscardUnknown Uses

func (m *TaskQueueQueryAndOwnTasksResponse) XXX_DiscardUnknown()

func (*TaskQueueQueryAndOwnTasksResponse) XXX_Marshal Uses

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

func (*TaskQueueQueryAndOwnTasksResponse) XXX_Merge Uses

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

func (*TaskQueueQueryAndOwnTasksResponse) XXX_Size Uses

func (m *TaskQueueQueryAndOwnTasksResponse) XXX_Size() int

func (*TaskQueueQueryAndOwnTasksResponse) XXX_Unmarshal Uses

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

type TaskQueueQueryAndOwnTasksResponse_Task Uses

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 Uses

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

func (*TaskQueueQueryAndOwnTasksResponse_Task) GetBody Uses

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

func (*TaskQueueQueryAndOwnTasksResponse_Task) GetEtaUsec Uses

func (m *TaskQueueQueryAndOwnTasksResponse_Task) GetEtaUsec() int64

func (*TaskQueueQueryAndOwnTasksResponse_Task) GetRetryCount Uses

func (m *TaskQueueQueryAndOwnTasksResponse_Task) GetRetryCount() int32

func (*TaskQueueQueryAndOwnTasksResponse_Task) GetTag Uses

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

func (*TaskQueueQueryAndOwnTasksResponse_Task) GetTaskName Uses

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

func (*TaskQueueQueryAndOwnTasksResponse_Task) ProtoMessage Uses

func (*TaskQueueQueryAndOwnTasksResponse_Task) ProtoMessage()

func (*TaskQueueQueryAndOwnTasksResponse_Task) Reset Uses

func (m *TaskQueueQueryAndOwnTasksResponse_Task) Reset()

func (*TaskQueueQueryAndOwnTasksResponse_Task) String Uses

func (m *TaskQueueQueryAndOwnTasksResponse_Task) String() string

func (*TaskQueueQueryAndOwnTasksResponse_Task) XXX_DiscardUnknown Uses

func (m *TaskQueueQueryAndOwnTasksResponse_Task) XXX_DiscardUnknown()

func (*TaskQueueQueryAndOwnTasksResponse_Task) XXX_Marshal Uses

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

func (*TaskQueueQueryAndOwnTasksResponse_Task) XXX_Merge Uses

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

func (*TaskQueueQueryAndOwnTasksResponse_Task) XXX_Size Uses

func (m *TaskQueueQueryAndOwnTasksResponse_Task) XXX_Size() int

func (*TaskQueueQueryAndOwnTasksResponse_Task) XXX_Unmarshal Uses

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

type TaskQueueQueryTasksRequest Uses

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 Uses

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

func (*TaskQueueQueryTasksRequest) GetAppId Uses

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

func (*TaskQueueQueryTasksRequest) GetMaxRows Uses

func (m *TaskQueueQueryTasksRequest) GetMaxRows() int32

func (*TaskQueueQueryTasksRequest) GetQueueName Uses

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

func (*TaskQueueQueryTasksRequest) GetStartEtaUsec Uses

func (m *TaskQueueQueryTasksRequest) GetStartEtaUsec() int64

func (*TaskQueueQueryTasksRequest) GetStartTag Uses

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

func (*TaskQueueQueryTasksRequest) GetStartTaskName Uses

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

func (*TaskQueueQueryTasksRequest) ProtoMessage Uses

func (*TaskQueueQueryTasksRequest) ProtoMessage()

func (*TaskQueueQueryTasksRequest) Reset Uses

func (m *TaskQueueQueryTasksRequest) Reset()

func (*TaskQueueQueryTasksRequest) String Uses

func (m *TaskQueueQueryTasksRequest) String() string

func (*TaskQueueQueryTasksRequest) XXX_DiscardUnknown Uses

func (m *TaskQueueQueryTasksRequest) XXX_DiscardUnknown()

func (*TaskQueueQueryTasksRequest) XXX_Marshal Uses

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

func (*TaskQueueQueryTasksRequest) XXX_Merge Uses

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

func (*TaskQueueQueryTasksRequest) XXX_Size Uses

func (m *TaskQueueQueryTasksRequest) XXX_Size() int

func (*TaskQueueQueryTasksRequest) XXX_Unmarshal Uses

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

type TaskQueueQueryTasksResponse Uses

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 Uses

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

func (*TaskQueueQueryTasksResponse) GetTask Uses

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

func (*TaskQueueQueryTasksResponse) ProtoMessage Uses

func (*TaskQueueQueryTasksResponse) ProtoMessage()

func (*TaskQueueQueryTasksResponse) Reset Uses

func (m *TaskQueueQueryTasksResponse) Reset()

func (*TaskQueueQueryTasksResponse) String Uses

func (m *TaskQueueQueryTasksResponse) String() string

func (*TaskQueueQueryTasksResponse) XXX_DiscardUnknown Uses

func (m *TaskQueueQueryTasksResponse) XXX_DiscardUnknown()

func (*TaskQueueQueryTasksResponse) XXX_Marshal Uses

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

func (*TaskQueueQueryTasksResponse) XXX_Merge Uses

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

func (*TaskQueueQueryTasksResponse) XXX_Size Uses

func (m *TaskQueueQueryTasksResponse) XXX_Size() int

func (*TaskQueueQueryTasksResponse) XXX_Unmarshal Uses

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

type TaskQueueQueryTasksResponse_Task Uses

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 Uses

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

func (*TaskQueueQueryTasksResponse_Task) GetBody Uses

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

func (*TaskQueueQueryTasksResponse_Task) GetBodySize Uses

func (m *TaskQueueQueryTasksResponse_Task) GetBodySize() int32

func (*TaskQueueQueryTasksResponse_Task) GetCreationTimeUsec Uses

func (m *TaskQueueQueryTasksResponse_Task) GetCreationTimeUsec() int64

func (*TaskQueueQueryTasksResponse_Task) GetCrontimetable Uses

func (m *TaskQueueQueryTasksResponse_Task) GetCrontimetable() *TaskQueueQueryTasksResponse_Task_CronTimetable

func (*TaskQueueQueryTasksResponse_Task) GetDescription Uses

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

func (*TaskQueueQueryTasksResponse_Task) GetEtaUsec Uses

func (m *TaskQueueQueryTasksResponse_Task) GetEtaUsec() int64

func (*TaskQueueQueryTasksResponse_Task) GetExecutionCount Uses

func (m *TaskQueueQueryTasksResponse_Task) GetExecutionCount() int32

func (*TaskQueueQueryTasksResponse_Task) GetFirstTryUsec Uses

func (m *TaskQueueQueryTasksResponse_Task) GetFirstTryUsec() int64

func (*TaskQueueQueryTasksResponse_Task) GetHeader Uses

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

func (*TaskQueueQueryTasksResponse_Task) GetMethod Uses

func (m *TaskQueueQueryTasksResponse_Task) GetMethod() TaskQueueQueryTasksResponse_Task_RequestMethod

func (*TaskQueueQueryTasksResponse_Task) GetPayload Uses

func (m *TaskQueueQueryTasksResponse_Task) GetPayload() *TaskPayload

func (*TaskQueueQueryTasksResponse_Task) GetRetryCount Uses

func (m *TaskQueueQueryTasksResponse_Task) GetRetryCount() int32

func (*TaskQueueQueryTasksResponse_Task) GetRetryParameters Uses

func (m *TaskQueueQueryTasksResponse_Task) GetRetryParameters() *TaskQueueRetryParameters

func (*TaskQueueQueryTasksResponse_Task) GetRunlog Uses

func (m *TaskQueueQueryTasksResponse_Task) GetRunlog() *TaskQueueQueryTasksResponse_Task_RunLog

func (*TaskQueueQueryTasksResponse_Task) GetTag Uses

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

func (*TaskQueueQueryTasksResponse_Task) GetTaskName Uses

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

func (*TaskQueueQueryTasksResponse_Task) GetUrl Uses

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

func (*TaskQueueQueryTasksResponse_Task) ProtoMessage Uses

func (*TaskQueueQueryTasksResponse_Task) ProtoMessage()

func (*TaskQueueQueryTasksResponse_Task) Reset Uses

func (m *TaskQueueQueryTasksResponse_Task) Reset()

func (*TaskQueueQueryTasksResponse_Task) String Uses

func (m *TaskQueueQueryTasksResponse_Task) String() string

func (*TaskQueueQueryTasksResponse_Task) XXX_DiscardUnknown Uses

func (m *TaskQueueQueryTasksResponse_Task) XXX_DiscardUnknown()

func (*TaskQueueQueryTasksResponse_Task) XXX_Marshal Uses

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

func (*TaskQueueQueryTasksResponse_Task) XXX_Merge Uses

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

func (*TaskQueueQueryTasksResponse_Task) XXX_Size Uses

func (m *TaskQueueQueryTasksResponse_Task) XXX_Size() int

func (*TaskQueueQueryTasksResponse_Task) XXX_Unmarshal Uses

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

type TaskQueueQueryTasksResponse_Task_CronTimetable Uses

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 Uses

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

func (*TaskQueueQueryTasksResponse_Task_CronTimetable) GetSchedule Uses

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

func (*TaskQueueQueryTasksResponse_Task_CronTimetable) GetTimezone Uses

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

func (*TaskQueueQueryTasksResponse_Task_CronTimetable) ProtoMessage Uses

func (*TaskQueueQueryTasksResponse_Task_CronTimetable) ProtoMessage()

func (*TaskQueueQueryTasksResponse_Task_CronTimetable) Reset Uses

func (m *TaskQueueQueryTasksResponse_Task_CronTimetable) Reset()

func (*TaskQueueQueryTasksResponse_Task_CronTimetable) String Uses

func (m *TaskQueueQueryTasksResponse_Task_CronTimetable) String() string

func (*TaskQueueQueryTasksResponse_Task_CronTimetable) XXX_DiscardUnknown Uses

func (m *TaskQueueQueryTasksResponse_Task_CronTimetable) XXX_DiscardUnknown()

func (*TaskQueueQueryTasksResponse_Task_CronTimetable) XXX_Marshal Uses

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

func (*TaskQueueQueryTasksResponse_Task_CronTimetable) XXX_Merge Uses

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

func (*TaskQueueQueryTasksResponse_Task_CronTimetable) XXX_Size Uses

func (m *TaskQueueQueryTasksResponse_Task_CronTimetable) XXX_Size() int

func (*TaskQueueQueryTasksResponse_Task_CronTimetable) XXX_Unmarshal Uses

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

type TaskQueueQueryTasksResponse_Task_Header Uses

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 Uses

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

func (*TaskQueueQueryTasksResponse_Task_Header) GetKey Uses

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

func (*TaskQueueQueryTasksResponse_Task_Header) GetValue Uses

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

func (*TaskQueueQueryTasksResponse_Task_Header) ProtoMessage Uses

func (*TaskQueueQueryTasksResponse_Task_Header) ProtoMessage()

func (*TaskQueueQueryTasksResponse_Task_Header) Reset Uses

func (m *TaskQueueQueryTasksResponse_Task_Header) Reset()

func (*TaskQueueQueryTasksResponse_Task_Header) String Uses

func (m *TaskQueueQueryTasksResponse_Task_Header) String() string

func (*TaskQueueQueryTasksResponse_Task_Header) XXX_DiscardUnknown Uses

func (m *TaskQueueQueryTasksResponse_Task_Header) XXX_DiscardUnknown()

func (*TaskQueueQueryTasksResponse_Task_Header) XXX_Marshal Uses

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

func (*TaskQueueQueryTasksResponse_Task_Header) XXX_Merge Uses

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

func (*TaskQueueQueryTasksResponse_Task_Header) XXX_Size Uses

func (m *TaskQueueQueryTasksResponse_Task_Header) XXX_Size() int

func (*TaskQueueQueryTasksResponse_Task_Header) XXX_Unmarshal Uses

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

type TaskQueueQueryTasksResponse_Task_RequestMethod Uses

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 Uses

func (x TaskQueueQueryTasksResponse_Task_RequestMethod) Enum() *TaskQueueQueryTasksResponse_Task_RequestMethod

func (TaskQueueQueryTasksResponse_Task_RequestMethod) EnumDescriptor Uses

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

func (TaskQueueQueryTasksResponse_Task_RequestMethod) String Uses

func (x TaskQueueQueryTasksResponse_Task_RequestMethod) String() string

func (*TaskQueueQueryTasksResponse_Task_RequestMethod) UnmarshalJSON Uses

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

type TaskQueueQueryTasksResponse_Task_RunLog Uses

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 Uses

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

func (*TaskQueueQueryTasksResponse_Task_RunLog) GetDispatchedUsec Uses

func (m *TaskQueueQueryTasksResponse_Task_RunLog) GetDispatchedUsec() int64

func (*TaskQueueQueryTasksResponse_Task_RunLog) GetElapsedUsec Uses

func (m *TaskQueueQueryTasksResponse_Task_RunLog) GetElapsedUsec() int64

func (*TaskQueueQueryTasksResponse_Task_RunLog) GetLagUsec Uses

func (m *TaskQueueQueryTasksResponse_Task_RunLog) GetLagUsec() int64

func (*TaskQueueQueryTasksResponse_Task_RunLog) GetResponseCode Uses

func (m *TaskQueueQueryTasksResponse_Task_RunLog) GetResponseCode() int64

func (*TaskQueueQueryTasksResponse_Task_RunLog) GetRetryReason Uses

func (m *TaskQueueQueryTasksResponse_Task_RunLog) GetRetryReason() string

func (*TaskQueueQueryTasksResponse_Task_RunLog) ProtoMessage Uses

func (*TaskQueueQueryTasksResponse_Task_RunLog) ProtoMessage()

func (*TaskQueueQueryTasksResponse_Task_RunLog) Reset Uses

func (m *TaskQueueQueryTasksResponse_Task_RunLog) Reset()

func (*TaskQueueQueryTasksResponse_Task_RunLog) String Uses

func (m *TaskQueueQueryTasksResponse_Task_RunLog) String() string

func (*TaskQueueQueryTasksResponse_Task_RunLog) XXX_DiscardUnknown Uses

func (m *TaskQueueQueryTasksResponse_Task_RunLog) XXX_DiscardUnknown()

func (*TaskQueueQueryTasksResponse_Task_RunLog) XXX_Marshal Uses

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

func (*TaskQueueQueryTasksResponse_Task_RunLog) XXX_Merge Uses

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

func (*TaskQueueQueryTasksResponse_Task_RunLog) XXX_Size Uses

func (m *TaskQueueQueryTasksResponse_Task_RunLog) XXX_Size() int

func (*TaskQueueQueryTasksResponse_Task_RunLog) XXX_Unmarshal Uses

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

type TaskQueueRetryParameters Uses

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 Uses

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

func (*TaskQueueRetryParameters) GetAgeLimitSec Uses

func (m *TaskQueueRetryParameters) GetAgeLimitSec() int64

func (*TaskQueueRetryParameters) GetMaxBackoffSec Uses

func (m *TaskQueueRetryParameters) GetMaxBackoffSec() float64

func (*TaskQueueRetryParameters) GetMaxDoublings Uses

func (m *TaskQueueRetryParameters) GetMaxDoublings() int32

func (*TaskQueueRetryParameters) GetMinBackoffSec Uses

func (m *TaskQueueRetryParameters) GetMinBackoffSec() float64

func (*TaskQueueRetryParameters) GetRetryLimit Uses

func (m *TaskQueueRetryParameters) GetRetryLimit() int32

func (*TaskQueueRetryParameters) ProtoMessage Uses

func (*TaskQueueRetryParameters) ProtoMessage()

func (*TaskQueueRetryParameters) Reset Uses

func (m *TaskQueueRetryParameters) Reset()

func (*TaskQueueRetryParameters) String Uses

func (m *TaskQueueRetryParameters) String() string

func (*TaskQueueRetryParameters) XXX_DiscardUnknown Uses

func (m *TaskQueueRetryParameters) XXX_DiscardUnknown()

func (*TaskQueueRetryParameters) XXX_Marshal Uses

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

func (*TaskQueueRetryParameters) XXX_Merge Uses

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

func (*TaskQueueRetryParameters) XXX_Size Uses

func (m *TaskQueueRetryParameters) XXX_Size() int

func (*TaskQueueRetryParameters) XXX_Unmarshal Uses

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

type TaskQueueScannerQueueInfo Uses

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 `protobuf:"fixed64,3,req,name=sampling_duration_seconds,json=samplingDurationSeconds" json:"sampling_duration_seconds,omitempty"`
    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 Uses

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

func (*TaskQueueScannerQueueInfo) GetEnforcedRate Uses

func (m *TaskQueueScannerQueueInfo) GetEnforcedRate() float64

func (*TaskQueueScannerQueueInfo) GetExecutedLastHour Uses

func (m *TaskQueueScannerQueueInfo) GetExecutedLastHour() int64

func (*TaskQueueScannerQueueInfo) GetExecutedLastMinute Uses

func (m *TaskQueueScannerQueueInfo) GetExecutedLastMinute() int64

func (*TaskQueueScannerQueueInfo) GetRequestsInFlight Uses

func (m *TaskQueueScannerQueueInfo) GetRequestsInFlight() int32

func (*TaskQueueScannerQueueInfo) GetSamplingDurationSeconds Uses

func (m *TaskQueueScannerQueueInfo) GetSamplingDurationSeconds() float64

func (*TaskQueueScannerQueueInfo) ProtoMessage Uses

func (*TaskQueueScannerQueueInfo) ProtoMessage()

func (*TaskQueueScannerQueueInfo) Reset Uses

func (m *TaskQueueScannerQueueInfo) Reset()

func (*TaskQueueScannerQueueInfo) String Uses

func (m *TaskQueueScannerQueueInfo) String() string

func (*TaskQueueScannerQueueInfo) XXX_DiscardUnknown Uses

func (m *TaskQueueScannerQueueInfo) XXX_DiscardUnknown()

func (*TaskQueueScannerQueueInfo) XXX_Marshal Uses

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

func (*TaskQueueScannerQueueInfo) XXX_Merge Uses

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

func (*TaskQueueScannerQueueInfo) XXX_Size Uses

func (m *TaskQueueScannerQueueInfo) XXX_Size() int

func (*TaskQueueScannerQueueInfo) XXX_Unmarshal Uses

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

type TaskQueueServiceError Uses

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

func (*TaskQueueServiceError) Descriptor Uses

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

func (*TaskQueueServiceError) ProtoMessage Uses

func (*TaskQueueServiceError) ProtoMessage()

func (*TaskQueueServiceError) Reset Uses

func (m *TaskQueueServiceError) Reset()

func (*TaskQueueServiceError) String Uses

func (m *TaskQueueServiceError) String() string

func (*TaskQueueServiceError) XXX_DiscardUnknown Uses

func (m *TaskQueueServiceError) XXX_DiscardUnknown()

func (*TaskQueueServiceError) XXX_Marshal Uses

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

func (*TaskQueueServiceError) XXX_Merge Uses

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

func (*TaskQueueServiceError) XXX_Size Uses

func (m *TaskQueueServiceError) XXX_Size() int

func (*TaskQueueServiceError) XXX_Unmarshal Uses

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

type TaskQueueServiceError_ErrorCode Uses

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 Uses

func (x TaskQueueServiceError_ErrorCode) Enum() *TaskQueueServiceError_ErrorCode

func (TaskQueueServiceError_ErrorCode) EnumDescriptor Uses

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

func (TaskQueueServiceError_ErrorCode) String Uses

func (x TaskQueueServiceError_ErrorCode) String() string

func (*TaskQueueServiceError_ErrorCode) UnmarshalJSON Uses

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

type TaskQueueUpdateQueueRequest Uses

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 Uses

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

func (*TaskQueueUpdateQueueRequest) GetAcl Uses

func (m *TaskQueueUpdateQueueRequest) GetAcl() *TaskQueueAcl

func (*TaskQueueUpdateQueueRequest) GetAppId Uses

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

func (*TaskQueueUpdateQueueRequest) GetBucketCapacity Uses

func (m *TaskQueueUpdateQueueRequest) GetBucketCapacity() int32

func (*TaskQueueUpdateQueueRequest) GetBucketRefillPerSecond Uses

func (m *TaskQueueUpdateQueueRequest) GetBucketRefillPerSecond() float64

func (*TaskQueueUpdateQueueRequest) GetHeaderOverride Uses

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

func (*TaskQueueUpdateQueueRequest) GetMaxConcurrentRequests Uses

func (m *TaskQueueUpdateQueueRequest) GetMaxConcurrentRequests() int32

func (*TaskQueueUpdateQueueRequest) GetMode Uses

func (m *TaskQueueUpdateQueueRequest) GetMode() TaskQueueMode_Mode

func (*TaskQueueUpdateQueueRequest) GetQueueName Uses

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

func (*TaskQueueUpdateQueueRequest) GetRetryParameters Uses

func (m *TaskQueueUpdateQueueRequest) GetRetryParameters() *TaskQueueRetryParameters

func (*TaskQueueUpdateQueueRequest) GetUserSpecifiedRate Uses

func (m *TaskQueueUpdateQueueRequest) GetUserSpecifiedRate() string

func (*TaskQueueUpdateQueueRequest) ProtoMessage Uses

func (*TaskQueueUpdateQueueRequest) ProtoMessage()

func (*TaskQueueUpdateQueueRequest) Reset Uses

func (m *TaskQueueUpdateQueueRequest) Reset()

func (*TaskQueueUpdateQueueRequest) String Uses

func (m *TaskQueueUpdateQueueRequest) String() string

func (*TaskQueueUpdateQueueRequest) XXX_DiscardUnknown Uses

func (m *TaskQueueUpdateQueueRequest) XXX_DiscardUnknown()

func (*TaskQueueUpdateQueueRequest) XXX_Marshal Uses

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

func (*TaskQueueUpdateQueueRequest) XXX_Merge Uses

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

func (*TaskQueueUpdateQueueRequest) XXX_Size Uses

func (m *TaskQueueUpdateQueueRequest) XXX_Size() int

func (*TaskQueueUpdateQueueRequest) XXX_Unmarshal Uses

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

type TaskQueueUpdateQueueResponse Uses

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

func (*TaskQueueUpdateQueueResponse) Descriptor Uses

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

func (*TaskQueueUpdateQueueResponse) ProtoMessage Uses

func (*TaskQueueUpdateQueueResponse) ProtoMessage()

func (*TaskQueueUpdateQueueResponse) Reset Uses

func (m *TaskQueueUpdateQueueResponse) Reset()

func (*TaskQueueUpdateQueueResponse) String Uses

func (m *TaskQueueUpdateQueueResponse) String() string

func (*TaskQueueUpdateQueueResponse) XXX_DiscardUnknown Uses

func (m *TaskQueueUpdateQueueResponse) XXX_DiscardUnknown()

func (*TaskQueueUpdateQueueResponse) XXX_Marshal Uses

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

func (*TaskQueueUpdateQueueResponse) XXX_Merge Uses

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

func (*TaskQueueUpdateQueueResponse) XXX_Size Uses

func (m *TaskQueueUpdateQueueResponse) XXX_Size() int

func (*TaskQueueUpdateQueueResponse) XXX_Unmarshal Uses

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

type TaskQueueUpdateStorageLimitRequest Uses

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 Uses

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

func (*TaskQueueUpdateStorageLimitRequest) GetAppId Uses

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

func (*TaskQueueUpdateStorageLimitRequest) GetLimit Uses

func (m *TaskQueueUpdateStorageLimitRequest) GetLimit() int64

func (*TaskQueueUpdateStorageLimitRequest) ProtoMessage Uses

func (*TaskQueueUpdateStorageLimitRequest) ProtoMessage()

func (*TaskQueueUpdateStorageLimitRequest) Reset Uses

func (m *TaskQueueUpdateStorageLimitRequest) Reset()

func (*TaskQueueUpdateStorageLimitRequest) String Uses

func (m *TaskQueueUpdateStorageLimitRequest) String() string

func (*TaskQueueUpdateStorageLimitRequest) XXX_DiscardUnknown Uses

func (m *TaskQueueUpdateStorageLimitRequest) XXX_DiscardUnknown()

func (*TaskQueueUpdateStorageLimitRequest) XXX_Marshal Uses

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

func (*TaskQueueUpdateStorageLimitRequest) XXX_Merge Uses

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

func (*TaskQueueUpdateStorageLimitRequest) XXX_Size Uses

func (m *TaskQueueUpdateStorageLimitRequest) XXX_Size() int

func (*TaskQueueUpdateStorageLimitRequest) XXX_Unmarshal Uses

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

type TaskQueueUpdateStorageLimitResponse Uses

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 Uses

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

func (*TaskQueueUpdateStorageLimitResponse) GetNewLimit Uses

func (m *TaskQueueUpdateStorageLimitResponse) GetNewLimit() int64

func (*TaskQueueUpdateStorageLimitResponse) ProtoMessage Uses

func (*TaskQueueUpdateStorageLimitResponse) ProtoMessage()

func (*TaskQueueUpdateStorageLimitResponse) Reset Uses

func (m *TaskQueueUpdateStorageLimitResponse) Reset()

func (*TaskQueueUpdateStorageLimitResponse) String Uses

func (m *TaskQueueUpdateStorageLimitResponse) String() string

func (*TaskQueueUpdateStorageLimitResponse) XXX_DiscardUnknown Uses

func (m *TaskQueueUpdateStorageLimitResponse) XXX_DiscardUnknown()

func (*TaskQueueUpdateStorageLimitResponse) XXX_Marshal Uses

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

func (*TaskQueueUpdateStorageLimitResponse) XXX_Merge Uses

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

func (*TaskQueueUpdateStorageLimitResponse) XXX_Size Uses

func (m *TaskQueueUpdateStorageLimitResponse) XXX_Size() int

func (*TaskQueueUpdateStorageLimitResponse) XXX_Unmarshal Uses

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

Package taskqueue imports 4 packages (graph) and is imported by 5 packages. Updated 2018-08-06. Refresh now. Tools for package owners.