taskqueue

package

Go to main page

Versions in this module

v2

v2.0.6

Apr 8, 2024

v2.0.5

Aug 30, 2023

v2.0.4

Jul 11, 2023

Changes in this version

+ var File_internal_taskqueue_taskqueue_service_proto protoreflect.FileDescriptor

type TaskPayload

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

type TaskQueueAcl

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

type TaskQueueAddRequest

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

type TaskQueueAddRequest_CronTimetable

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

type TaskQueueAddRequest_Header

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

type TaskQueueAddRequest_RequestMethod

+ func (TaskQueueAddRequest_RequestMethod) Descriptor() protoreflect.EnumDescriptor

+ func (TaskQueueAddRequest_RequestMethod) Type() protoreflect.EnumType

+ func (x TaskQueueAddRequest_RequestMethod) Number() protoreflect.EnumNumber

type TaskQueueAddResponse

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

type TaskQueueBulkAddRequest

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

type TaskQueueBulkAddResponse

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

type TaskQueueBulkAddResponse_TaskResult

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

type TaskQueueDeleteGroupRequest

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

type TaskQueueDeleteGroupResponse

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

type TaskQueueDeleteQueueRequest

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

type TaskQueueDeleteQueueResponse

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

type TaskQueueDeleteRequest

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

type TaskQueueDeleteResponse

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

type TaskQueueFetchQueueStatsRequest

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

type TaskQueueFetchQueueStatsResponse

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

type TaskQueueFetchQueueStatsResponse_QueueStats

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

type TaskQueueFetchQueuesRequest

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

type TaskQueueFetchQueuesResponse

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

type TaskQueueFetchQueuesResponse_Queue

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

type TaskQueueFetchTaskRequest

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

type TaskQueueFetchTaskResponse

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

type TaskQueueForceRunRequest

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

type TaskQueueForceRunResponse

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

type TaskQueueHttpHeader

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

type TaskQueueMode

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

type TaskQueueMode_Mode

+ func (TaskQueueMode_Mode) Descriptor() protoreflect.EnumDescriptor

+ func (TaskQueueMode_Mode) Type() protoreflect.EnumType

+ func (x TaskQueueMode_Mode) Number() protoreflect.EnumNumber

type TaskQueueModifyTaskLeaseRequest

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

type TaskQueueModifyTaskLeaseResponse

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

type TaskQueuePauseQueueRequest

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

type TaskQueuePauseQueueResponse

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

type TaskQueuePurgeQueueRequest

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

type TaskQueuePurgeQueueResponse

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

type TaskQueueQueryAndOwnTasksRequest

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

type TaskQueueQueryAndOwnTasksResponse

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

type TaskQueueQueryAndOwnTasksResponse_Task

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

type TaskQueueQueryTasksRequest

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

type TaskQueueQueryTasksResponse

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

type TaskQueueQueryTasksResponse_Task

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

type TaskQueueQueryTasksResponse_Task_CronTimetable

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

type TaskQueueQueryTasksResponse_Task_Header

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

type TaskQueueQueryTasksResponse_Task_RequestMethod

+ func (TaskQueueQueryTasksResponse_Task_RequestMethod) Descriptor() protoreflect.EnumDescriptor

+ func (TaskQueueQueryTasksResponse_Task_RequestMethod) Type() protoreflect.EnumType

+ func (x TaskQueueQueryTasksResponse_Task_RequestMethod) Number() protoreflect.EnumNumber

type TaskQueueQueryTasksResponse_Task_RunLog

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

type TaskQueueRetryParameters

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

type TaskQueueScannerQueueInfo

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

type TaskQueueServiceError

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

type TaskQueueServiceError_ErrorCode

+ func (TaskQueueServiceError_ErrorCode) Descriptor() protoreflect.EnumDescriptor

+ func (TaskQueueServiceError_ErrorCode) Type() protoreflect.EnumType

+ func (x TaskQueueServiceError_ErrorCode) Number() protoreflect.EnumNumber

type TaskQueueUpdateQueueRequest

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

type TaskQueueUpdateQueueResponse

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

type TaskQueueUpdateStorageLimitRequest

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

type TaskQueueUpdateStorageLimitResponse

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

v2.0.3

Mar 27, 2023

v2.0.2

Aug 5, 2022

v2.0.1

Nov 5, 2021

Changes in this version

+ const Default_TaskQueueFetchQueueStatsRequest_MaxNumTasks

+ const Default_TaskQueueFetchQueuesResponse_Queue_CreatorName

+ const Default_TaskQueueFetchQueuesResponse_Queue_Paused

+ const Default_TaskQueueQueryAndOwnTasksRequest_GroupByTag

+ const Default_TaskQueueQueryAndOwnTasksResponse_Task_RetryCount

+ const Default_TaskQueueQueryTasksRequest_MaxRows

+ const Default_TaskQueueQueryTasksResponse_Task_ExecutionCount

+ const Default_TaskQueueQueryTasksResponse_Task_RetryCount

+ const Default_TaskQueueRetryParameters_MaxBackoffSec

+ const Default_TaskQueueRetryParameters_MaxDoublings

+ const Default_TaskQueueRetryParameters_MinBackoffSec

+ var TaskQueueAddRequest_RequestMethod_name = map[int32]string

+ var TaskQueueAddRequest_RequestMethod_value = map[string]int32

+ var TaskQueueMode_Mode_name = map[int32]string

+ var TaskQueueMode_Mode_value = map[string]int32

+ var TaskQueueQueryTasksResponse_Task_RequestMethod_name = map[int32]string

+ var TaskQueueQueryTasksResponse_Task_RequestMethod_value = map[string]int32

+ var TaskQueueServiceError_ErrorCode_name = map[int32]string

+ var TaskQueueServiceError_ErrorCode_value = map[string]int32

+ type TaskPayload struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

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

+ func (*TaskPayload) ProtoMessage()

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

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

+ func (m *TaskPayload) Reset()

+ func (m *TaskPayload) String() string

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

+ func (m *TaskPayload) XXX_DiscardUnknown()

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

+ func (m *TaskPayload) XXX_Size() int

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

+ type TaskQueueAcl struct

+ UserEmail [][]byte

+ WriterEmail [][]byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TaskQueueAcl) ProtoMessage()

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

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

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

+ func (m *TaskQueueAcl) Reset()

+ func (m *TaskQueueAcl) String() string

+ func (m *TaskQueueAcl) XXX_DiscardUnknown()

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

+ func (m *TaskQueueAcl) XXX_Size() int

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

+ type TaskQueueAddRequest struct

+ AppId []byte

+ Body []byte

+ Crontimetable *TaskQueueAddRequest_CronTimetable

+ Description []byte

+ EtaUsec *int64

+ Header []*TaskQueueAddRequest_Header

+ Method *TaskQueueAddRequest_RequestMethod

+ Mode *TaskQueueMode_Mode

+ Payload *TaskPayload

+ QueueName []byte

+ RetryParameters *TaskQueueRetryParameters

+ Tag []byte

+ TaskName []byte

+ Transaction *datastore.Transaction

+ Url []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TaskQueueAddRequest) ProtoMessage()

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

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

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

+ func (m *TaskQueueAddRequest) GetCrontimetable() *TaskQueueAddRequest_CronTimetable

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

+ func (m *TaskQueueAddRequest) GetEtaUsec() int64

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

+ func (m *TaskQueueAddRequest) GetMethod() TaskQueueAddRequest_RequestMethod

+ func (m *TaskQueueAddRequest) GetMode() TaskQueueMode_Mode

+ func (m *TaskQueueAddRequest) GetPayload() *TaskPayload

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

+ func (m *TaskQueueAddRequest) GetRetryParameters() *TaskQueueRetryParameters

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

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

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

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

+ func (m *TaskQueueAddRequest) Reset()

+ func (m *TaskQueueAddRequest) String() string

+ func (m *TaskQueueAddRequest) XXX_DiscardUnknown()

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

+ func (m *TaskQueueAddRequest) XXX_Size() int

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

+ type TaskQueueAddRequest_CronTimetable struct

+ Schedule []byte

+ Timezone []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TaskQueueAddRequest_CronTimetable) ProtoMessage()

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

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

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

+ func (m *TaskQueueAddRequest_CronTimetable) Reset()

+ func (m *TaskQueueAddRequest_CronTimetable) String() string

+ func (m *TaskQueueAddRequest_CronTimetable) XXX_DiscardUnknown()

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

+ func (m *TaskQueueAddRequest_CronTimetable) XXX_Size() int

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

+ type TaskQueueAddRequest_Header struct

+ Key []byte

+ Value []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TaskQueueAddRequest_Header) ProtoMessage()

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

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

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

+ func (m *TaskQueueAddRequest_Header) Reset()

+ func (m *TaskQueueAddRequest_Header) String() string

+ func (m *TaskQueueAddRequest_Header) XXX_DiscardUnknown()

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

+ func (m *TaskQueueAddRequest_Header) XXX_Size() int

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

+ type TaskQueueAddRequest_RequestMethod int32

+ const Default_TaskQueueAddRequest_Method

+ const TaskQueueAddRequest_DELETE

+ const TaskQueueAddRequest_GET

+ const TaskQueueAddRequest_HEAD

+ const TaskQueueAddRequest_POST

+ const TaskQueueAddRequest_PUT

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

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

+ func (x TaskQueueAddRequest_RequestMethod) Enum() *TaskQueueAddRequest_RequestMethod

+ func (x TaskQueueAddRequest_RequestMethod) String() string

+ type TaskQueueAddResponse struct

+ ChosenTaskName []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TaskQueueAddResponse) ProtoMessage()

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

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

+ func (m *TaskQueueAddResponse) Reset()

+ func (m *TaskQueueAddResponse) String() string

+ func (m *TaskQueueAddResponse) XXX_DiscardUnknown()

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

+ func (m *TaskQueueAddResponse) XXX_Size() int

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

+ type TaskQueueBulkAddRequest struct

+ AddRequest []*TaskQueueAddRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TaskQueueBulkAddRequest) ProtoMessage()

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

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

+ func (m *TaskQueueBulkAddRequest) Reset()

+ func (m *TaskQueueBulkAddRequest) String() string

+ func (m *TaskQueueBulkAddRequest) XXX_DiscardUnknown()

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

+ func (m *TaskQueueBulkAddRequest) XXX_Size() int

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

+ type TaskQueueBulkAddResponse struct

+ Taskresult []*TaskQueueBulkAddResponse_TaskResult

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TaskQueueBulkAddResponse) ProtoMessage()

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

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

+ func (m *TaskQueueBulkAddResponse) Reset()

+ func (m *TaskQueueBulkAddResponse) String() string

+ func (m *TaskQueueBulkAddResponse) XXX_DiscardUnknown()

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

+ func (m *TaskQueueBulkAddResponse) XXX_Size() int

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

+ type TaskQueueBulkAddResponse_TaskResult struct

+ ChosenTaskName []byte

+ Result *TaskQueueServiceError_ErrorCode

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TaskQueueBulkAddResponse_TaskResult) ProtoMessage()

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

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

+ func (m *TaskQueueBulkAddResponse_TaskResult) GetResult() TaskQueueServiceError_ErrorCode

+ func (m *TaskQueueBulkAddResponse_TaskResult) Reset()

+ func (m *TaskQueueBulkAddResponse_TaskResult) String() string

+ func (m *TaskQueueBulkAddResponse_TaskResult) XXX_DiscardUnknown()

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

+ func (m *TaskQueueBulkAddResponse_TaskResult) XXX_Size() int

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

+ type TaskQueueDeleteGroupRequest struct

+ AppId []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TaskQueueDeleteGroupRequest) ProtoMessage()

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

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

+ func (m *TaskQueueDeleteGroupRequest) Reset()

+ func (m *TaskQueueDeleteGroupRequest) String() string

+ func (m *TaskQueueDeleteGroupRequest) XXX_DiscardUnknown()

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

+ func (m *TaskQueueDeleteGroupRequest) XXX_Size() int

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

+ type TaskQueueDeleteGroupResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TaskQueueDeleteGroupResponse) ProtoMessage()

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

+ func (m *TaskQueueDeleteGroupResponse) Reset()

+ func (m *TaskQueueDeleteGroupResponse) String() string

+ func (m *TaskQueueDeleteGroupResponse) XXX_DiscardUnknown()

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

+ func (m *TaskQueueDeleteGroupResponse) XXX_Size() int

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

+ type TaskQueueDeleteQueueRequest struct

+ AppId []byte

+ QueueName []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TaskQueueDeleteQueueRequest) ProtoMessage()

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

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

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

+ func (m *TaskQueueDeleteQueueRequest) Reset()

+ func (m *TaskQueueDeleteQueueRequest) String() string

+ func (m *TaskQueueDeleteQueueRequest) XXX_DiscardUnknown()

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

+ func (m *TaskQueueDeleteQueueRequest) XXX_Size() int

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

+ type TaskQueueDeleteQueueResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TaskQueueDeleteQueueResponse) ProtoMessage()

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

+ func (m *TaskQueueDeleteQueueResponse) Reset()

+ func (m *TaskQueueDeleteQueueResponse) String() string

+ func (m *TaskQueueDeleteQueueResponse) XXX_DiscardUnknown()

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

+ func (m *TaskQueueDeleteQueueResponse) XXX_Size() int

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

+ type TaskQueueDeleteRequest struct

+ AppId []byte

+ QueueName []byte

+ TaskName [][]byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TaskQueueDeleteRequest) ProtoMessage()

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

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

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

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

+ func (m *TaskQueueDeleteRequest) Reset()

+ func (m *TaskQueueDeleteRequest) String() string

+ func (m *TaskQueueDeleteRequest) XXX_DiscardUnknown()

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

+ func (m *TaskQueueDeleteRequest) XXX_Size() int

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

+ type TaskQueueDeleteResponse struct

+ Result []TaskQueueServiceError_ErrorCode

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TaskQueueDeleteResponse) ProtoMessage()

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

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

+ func (m *TaskQueueDeleteResponse) Reset()

+ func (m *TaskQueueDeleteResponse) String() string

+ func (m *TaskQueueDeleteResponse) XXX_DiscardUnknown()

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

+ func (m *TaskQueueDeleteResponse) XXX_Size() int

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

+ type TaskQueueFetchQueueStatsRequest struct

+ AppId []byte

+ MaxNumTasks *int32

+ QueueName [][]byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TaskQueueFetchQueueStatsRequest) ProtoMessage()

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

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

+ func (m *TaskQueueFetchQueueStatsRequest) GetMaxNumTasks() int32

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

+ func (m *TaskQueueFetchQueueStatsRequest) Reset()

+ func (m *TaskQueueFetchQueueStatsRequest) String() string

+ func (m *TaskQueueFetchQueueStatsRequest) XXX_DiscardUnknown()

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

+ func (m *TaskQueueFetchQueueStatsRequest) XXX_Size() int

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

+ type TaskQueueFetchQueueStatsResponse struct

+ Queuestats []*TaskQueueFetchQueueStatsResponse_QueueStats

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TaskQueueFetchQueueStatsResponse) ProtoMessage()

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

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

+ func (m *TaskQueueFetchQueueStatsResponse) Reset()

+ func (m *TaskQueueFetchQueueStatsResponse) String() string

+ func (m *TaskQueueFetchQueueStatsResponse) XXX_DiscardUnknown()

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

+ func (m *TaskQueueFetchQueueStatsResponse) XXX_Size() int

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

+ type TaskQueueFetchQueueStatsResponse_QueueStats struct

+ NumTasks *int32

+ OldestEtaUsec *int64

+ ScannerInfo *TaskQueueScannerQueueInfo

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TaskQueueFetchQueueStatsResponse_QueueStats) ProtoMessage()

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

+ func (m *TaskQueueFetchQueueStatsResponse_QueueStats) GetNumTasks() int32

+ func (m *TaskQueueFetchQueueStatsResponse_QueueStats) GetOldestEtaUsec() int64

+ func (m *TaskQueueFetchQueueStatsResponse_QueueStats) GetScannerInfo() *TaskQueueScannerQueueInfo

+ func (m *TaskQueueFetchQueueStatsResponse_QueueStats) Reset()

+ func (m *TaskQueueFetchQueueStatsResponse_QueueStats) String() string

+ func (m *TaskQueueFetchQueueStatsResponse_QueueStats) XXX_DiscardUnknown()

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

+ func (m *TaskQueueFetchQueueStatsResponse_QueueStats) XXX_Size() int

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

+ type TaskQueueFetchQueuesRequest struct

+ AppId []byte

+ MaxRows *int32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TaskQueueFetchQueuesRequest) ProtoMessage()

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

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

+ func (m *TaskQueueFetchQueuesRequest) GetMaxRows() int32

+ func (m *TaskQueueFetchQueuesRequest) Reset()

+ func (m *TaskQueueFetchQueuesRequest) String() string

+ func (m *TaskQueueFetchQueuesRequest) XXX_DiscardUnknown()

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

+ func (m *TaskQueueFetchQueuesRequest) XXX_Size() int

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

+ type TaskQueueFetchQueuesResponse struct

+ Queue []*TaskQueueFetchQueuesResponse_Queue

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TaskQueueFetchQueuesResponse) ProtoMessage()

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

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

+ func (m *TaskQueueFetchQueuesResponse) Reset()

+ func (m *TaskQueueFetchQueuesResponse) String() string

+ func (m *TaskQueueFetchQueuesResponse) XXX_DiscardUnknown()

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

+ func (m *TaskQueueFetchQueuesResponse) XXX_Size() int

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

+ type TaskQueueFetchQueuesResponse_Queue struct

+ Acl *TaskQueueAcl

+ BucketCapacity *float64

+ BucketRefillPerSecond *float64

+ CreatorName *string

+ HeaderOverride []*TaskQueueHttpHeader

+ MaxConcurrentRequests *int32

+ Mode *TaskQueueMode_Mode

+ Paused *bool

+ QueueName []byte

+ RetryParameters *TaskQueueRetryParameters

+ UserSpecifiedRate *string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TaskQueueFetchQueuesResponse_Queue) ProtoMessage()

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

+ func (m *TaskQueueFetchQueuesResponse_Queue) GetAcl() *TaskQueueAcl

+ func (m *TaskQueueFetchQueuesResponse_Queue) GetBucketCapacity() float64

+ func (m *TaskQueueFetchQueuesResponse_Queue) GetBucketRefillPerSecond() float64

+ func (m *TaskQueueFetchQueuesResponse_Queue) GetCreatorName() string

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

+ func (m *TaskQueueFetchQueuesResponse_Queue) GetMaxConcurrentRequests() int32

+ func (m *TaskQueueFetchQueuesResponse_Queue) GetMode() TaskQueueMode_Mode

+ func (m *TaskQueueFetchQueuesResponse_Queue) GetPaused() bool

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

+ func (m *TaskQueueFetchQueuesResponse_Queue) GetRetryParameters() *TaskQueueRetryParameters

+ func (m *TaskQueueFetchQueuesResponse_Queue) GetUserSpecifiedRate() string

+ func (m *TaskQueueFetchQueuesResponse_Queue) Reset()

+ func (m *TaskQueueFetchQueuesResponse_Queue) String() string

+ func (m *TaskQueueFetchQueuesResponse_Queue) XXX_DiscardUnknown()

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

+ func (m *TaskQueueFetchQueuesResponse_Queue) XXX_Size() int

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

+ type TaskQueueFetchTaskRequest struct

+ AppId []byte

+ QueueName []byte

+ TaskName []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TaskQueueFetchTaskRequest) ProtoMessage()

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

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

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

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

+ func (m *TaskQueueFetchTaskRequest) Reset()

+ func (m *TaskQueueFetchTaskRequest) String() string

+ func (m *TaskQueueFetchTaskRequest) XXX_DiscardUnknown()

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

+ func (m *TaskQueueFetchTaskRequest) XXX_Size() int

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

+ type TaskQueueFetchTaskResponse struct

+ Task *TaskQueueQueryTasksResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TaskQueueFetchTaskResponse) ProtoMessage()

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

+ func (m *TaskQueueFetchTaskResponse) GetTask() *TaskQueueQueryTasksResponse

+ func (m *TaskQueueFetchTaskResponse) Reset()

+ func (m *TaskQueueFetchTaskResponse) String() string

+ func (m *TaskQueueFetchTaskResponse) XXX_DiscardUnknown()

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

+ func (m *TaskQueueFetchTaskResponse) XXX_Size() int

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

+ type TaskQueueForceRunRequest struct

+ AppId []byte

+ QueueName []byte

+ TaskName []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TaskQueueForceRunRequest) ProtoMessage()

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

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

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

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

+ func (m *TaskQueueForceRunRequest) Reset()

+ func (m *TaskQueueForceRunRequest) String() string

+ func (m *TaskQueueForceRunRequest) XXX_DiscardUnknown()

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

+ func (m *TaskQueueForceRunRequest) XXX_Size() int

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

+ type TaskQueueForceRunResponse struct

+ Result *TaskQueueServiceError_ErrorCode

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TaskQueueForceRunResponse) ProtoMessage()

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

+ func (m *TaskQueueForceRunResponse) GetResult() TaskQueueServiceError_ErrorCode

+ func (m *TaskQueueForceRunResponse) Reset()

+ func (m *TaskQueueForceRunResponse) String() string

+ func (m *TaskQueueForceRunResponse) XXX_DiscardUnknown()

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

+ func (m *TaskQueueForceRunResponse) XXX_Size() int

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

+ type TaskQueueHttpHeader struct

+ Key []byte

+ Value []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TaskQueueHttpHeader) ProtoMessage()

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

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

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

+ func (m *TaskQueueHttpHeader) Reset()

+ func (m *TaskQueueHttpHeader) String() string

+ func (m *TaskQueueHttpHeader) XXX_DiscardUnknown()

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

+ func (m *TaskQueueHttpHeader) XXX_Size() int

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

+ type TaskQueueMode struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TaskQueueMode) ProtoMessage()

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

+ func (m *TaskQueueMode) Reset()

+ func (m *TaskQueueMode) String() string

+ func (m *TaskQueueMode) XXX_DiscardUnknown()

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

+ func (m *TaskQueueMode) XXX_Size() int

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

+ type TaskQueueMode_Mode int32

+ const Default_TaskQueueAddRequest_Mode

+ const Default_TaskQueueFetchQueuesResponse_Queue_Mode

+ const Default_TaskQueueUpdateQueueRequest_Mode

+ const TaskQueueMode_PULL

+ const TaskQueueMode_PUSH

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

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

+ func (x TaskQueueMode_Mode) Enum() *TaskQueueMode_Mode

+ func (x TaskQueueMode_Mode) String() string

+ type TaskQueueModifyTaskLeaseRequest struct

+ EtaUsec *int64

+ LeaseSeconds *float64

+ QueueName []byte

+ TaskName []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TaskQueueModifyTaskLeaseRequest) ProtoMessage()

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

+ func (m *TaskQueueModifyTaskLeaseRequest) GetEtaUsec() int64

+ func (m *TaskQueueModifyTaskLeaseRequest) GetLeaseSeconds() float64

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

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

+ func (m *TaskQueueModifyTaskLeaseRequest) Reset()

+ func (m *TaskQueueModifyTaskLeaseRequest) String() string

+ func (m *TaskQueueModifyTaskLeaseRequest) XXX_DiscardUnknown()

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

+ func (m *TaskQueueModifyTaskLeaseRequest) XXX_Size() int

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

+ type TaskQueueModifyTaskLeaseResponse struct

+ UpdatedEtaUsec *int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TaskQueueModifyTaskLeaseResponse) ProtoMessage()

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

+ func (m *TaskQueueModifyTaskLeaseResponse) GetUpdatedEtaUsec() int64

+ func (m *TaskQueueModifyTaskLeaseResponse) Reset()

+ func (m *TaskQueueModifyTaskLeaseResponse) String() string

+ func (m *TaskQueueModifyTaskLeaseResponse) XXX_DiscardUnknown()

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

+ func (m *TaskQueueModifyTaskLeaseResponse) XXX_Size() int

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

+ type TaskQueuePauseQueueRequest struct

+ AppId []byte

+ Pause *bool

+ QueueName []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TaskQueuePauseQueueRequest) ProtoMessage()

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

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

+ func (m *TaskQueuePauseQueueRequest) GetPause() bool

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

+ func (m *TaskQueuePauseQueueRequest) Reset()

+ func (m *TaskQueuePauseQueueRequest) String() string

+ func (m *TaskQueuePauseQueueRequest) XXX_DiscardUnknown()

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

+ func (m *TaskQueuePauseQueueRequest) XXX_Size() int

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

+ type TaskQueuePauseQueueResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TaskQueuePauseQueueResponse) ProtoMessage()

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

+ func (m *TaskQueuePauseQueueResponse) Reset()

+ func (m *TaskQueuePauseQueueResponse) String() string

+ func (m *TaskQueuePauseQueueResponse) XXX_DiscardUnknown()

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

+ func (m *TaskQueuePauseQueueResponse) XXX_Size() int

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

+ type TaskQueuePurgeQueueRequest struct

+ AppId []byte

+ QueueName []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TaskQueuePurgeQueueRequest) ProtoMessage()

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

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

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

+ func (m *TaskQueuePurgeQueueRequest) Reset()

+ func (m *TaskQueuePurgeQueueRequest) String() string

+ func (m *TaskQueuePurgeQueueRequest) XXX_DiscardUnknown()

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

+ func (m *TaskQueuePurgeQueueRequest) XXX_Size() int

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

+ type TaskQueuePurgeQueueResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TaskQueuePurgeQueueResponse) ProtoMessage()

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

+ func (m *TaskQueuePurgeQueueResponse) Reset()

+ func (m *TaskQueuePurgeQueueResponse) String() string

+ func (m *TaskQueuePurgeQueueResponse) XXX_DiscardUnknown()

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

+ func (m *TaskQueuePurgeQueueResponse) XXX_Size() int

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

+ type TaskQueueQueryAndOwnTasksRequest struct

+ GroupByTag *bool

+ LeaseSeconds *float64

+ MaxTasks *int64

+ QueueName []byte

+ Tag []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TaskQueueQueryAndOwnTasksRequest) ProtoMessage()

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

+ func (m *TaskQueueQueryAndOwnTasksRequest) GetGroupByTag() bool

+ func (m *TaskQueueQueryAndOwnTasksRequest) GetLeaseSeconds() float64

+ func (m *TaskQueueQueryAndOwnTasksRequest) GetMaxTasks() int64

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

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

+ func (m *TaskQueueQueryAndOwnTasksRequest) Reset()

+ func (m *TaskQueueQueryAndOwnTasksRequest) String() string

+ func (m *TaskQueueQueryAndOwnTasksRequest) XXX_DiscardUnknown()

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

+ func (m *TaskQueueQueryAndOwnTasksRequest) XXX_Size() int

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

+ type TaskQueueQueryAndOwnTasksResponse struct

+ Task []*TaskQueueQueryAndOwnTasksResponse_Task

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TaskQueueQueryAndOwnTasksResponse) ProtoMessage()

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

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

+ func (m *TaskQueueQueryAndOwnTasksResponse) Reset()

+ func (m *TaskQueueQueryAndOwnTasksResponse) String() string

+ func (m *TaskQueueQueryAndOwnTasksResponse) XXX_DiscardUnknown()

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

+ func (m *TaskQueueQueryAndOwnTasksResponse) XXX_Size() int

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

+ type TaskQueueQueryAndOwnTasksResponse_Task struct

+ Body []byte

+ EtaUsec *int64

+ RetryCount *int32

+ Tag []byte

+ TaskName []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TaskQueueQueryAndOwnTasksResponse_Task) ProtoMessage()

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

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

+ func (m *TaskQueueQueryAndOwnTasksResponse_Task) GetEtaUsec() int64

+ func (m *TaskQueueQueryAndOwnTasksResponse_Task) GetRetryCount() int32

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

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

+ func (m *TaskQueueQueryAndOwnTasksResponse_Task) Reset()

+ func (m *TaskQueueQueryAndOwnTasksResponse_Task) String() string

+ func (m *TaskQueueQueryAndOwnTasksResponse_Task) XXX_DiscardUnknown()

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

+ func (m *TaskQueueQueryAndOwnTasksResponse_Task) XXX_Size() int

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

+ type TaskQueueQueryTasksRequest struct

+ AppId []byte

+ MaxRows *int32

+ QueueName []byte

+ StartEtaUsec *int64

+ StartTag []byte

+ StartTaskName []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TaskQueueQueryTasksRequest) ProtoMessage()

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

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

+ func (m *TaskQueueQueryTasksRequest) GetMaxRows() int32

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

+ func (m *TaskQueueQueryTasksRequest) GetStartEtaUsec() int64

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

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

+ func (m *TaskQueueQueryTasksRequest) Reset()

+ func (m *TaskQueueQueryTasksRequest) String() string

+ func (m *TaskQueueQueryTasksRequest) XXX_DiscardUnknown()

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

+ func (m *TaskQueueQueryTasksRequest) XXX_Size() int

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

+ type TaskQueueQueryTasksResponse struct

+ Task []*TaskQueueQueryTasksResponse_Task

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TaskQueueQueryTasksResponse) ProtoMessage()

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

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

+ func (m *TaskQueueQueryTasksResponse) Reset()

+ func (m *TaskQueueQueryTasksResponse) String() string

+ func (m *TaskQueueQueryTasksResponse) XXX_DiscardUnknown()

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

+ func (m *TaskQueueQueryTasksResponse) XXX_Size() int

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

+ type TaskQueueQueryTasksResponse_Task struct

+ Body []byte

+ BodySize *int32

+ CreationTimeUsec *int64

+ Crontimetable *TaskQueueQueryTasksResponse_Task_CronTimetable

+ Description []byte

+ EtaUsec *int64

+ ExecutionCount *int32

+ FirstTryUsec *int64

+ Header []*TaskQueueQueryTasksResponse_Task_Header

+ Method *TaskQueueQueryTasksResponse_Task_RequestMethod

+ Payload *TaskPayload

+ RetryCount *int32

+ RetryParameters *TaskQueueRetryParameters

+ Runlog *TaskQueueQueryTasksResponse_Task_RunLog

+ Tag []byte

+ TaskName []byte

+ Url []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TaskQueueQueryTasksResponse_Task) ProtoMessage()

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

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

+ func (m *TaskQueueQueryTasksResponse_Task) GetBodySize() int32

+ func (m *TaskQueueQueryTasksResponse_Task) GetCreationTimeUsec() int64

+ func (m *TaskQueueQueryTasksResponse_Task) GetCrontimetable() *TaskQueueQueryTasksResponse_Task_CronTimetable

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

+ func (m *TaskQueueQueryTasksResponse_Task) GetEtaUsec() int64

+ func (m *TaskQueueQueryTasksResponse_Task) GetExecutionCount() int32

+ func (m *TaskQueueQueryTasksResponse_Task) GetFirstTryUsec() int64

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

+ func (m *TaskQueueQueryTasksResponse_Task) GetMethod() TaskQueueQueryTasksResponse_Task_RequestMethod

+ func (m *TaskQueueQueryTasksResponse_Task) GetPayload() *TaskPayload

+ func (m *TaskQueueQueryTasksResponse_Task) GetRetryCount() int32

+ func (m *TaskQueueQueryTasksResponse_Task) GetRetryParameters() *TaskQueueRetryParameters

+ func (m *TaskQueueQueryTasksResponse_Task) GetRunlog() *TaskQueueQueryTasksResponse_Task_RunLog

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

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

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

+ func (m *TaskQueueQueryTasksResponse_Task) Reset()

+ func (m *TaskQueueQueryTasksResponse_Task) String() string

+ func (m *TaskQueueQueryTasksResponse_Task) XXX_DiscardUnknown()

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

+ func (m *TaskQueueQueryTasksResponse_Task) XXX_Size() int

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

+ type TaskQueueQueryTasksResponse_Task_CronTimetable struct

+ Schedule []byte

+ Timezone []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TaskQueueQueryTasksResponse_Task_CronTimetable) ProtoMessage()

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

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

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

+ func (m *TaskQueueQueryTasksResponse_Task_CronTimetable) Reset()

+ func (m *TaskQueueQueryTasksResponse_Task_CronTimetable) String() string

+ func (m *TaskQueueQueryTasksResponse_Task_CronTimetable) XXX_DiscardUnknown()

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

+ func (m *TaskQueueQueryTasksResponse_Task_CronTimetable) XXX_Size() int

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

+ type TaskQueueQueryTasksResponse_Task_Header struct

+ Key []byte

+ Value []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TaskQueueQueryTasksResponse_Task_Header) ProtoMessage()

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

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

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

+ func (m *TaskQueueQueryTasksResponse_Task_Header) Reset()

+ func (m *TaskQueueQueryTasksResponse_Task_Header) String() string

+ func (m *TaskQueueQueryTasksResponse_Task_Header) XXX_DiscardUnknown()

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

+ func (m *TaskQueueQueryTasksResponse_Task_Header) XXX_Size() int

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

+ type TaskQueueQueryTasksResponse_Task_RequestMethod int32

+ const TaskQueueQueryTasksResponse_Task_DELETE

+ const TaskQueueQueryTasksResponse_Task_GET

+ const TaskQueueQueryTasksResponse_Task_HEAD

+ const TaskQueueQueryTasksResponse_Task_POST

+ const TaskQueueQueryTasksResponse_Task_PUT

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

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

+ func (x TaskQueueQueryTasksResponse_Task_RequestMethod) Enum() *TaskQueueQueryTasksResponse_Task_RequestMethod

+ func (x TaskQueueQueryTasksResponse_Task_RequestMethod) String() string

+ type TaskQueueQueryTasksResponse_Task_RunLog struct

+ DispatchedUsec *int64

+ ElapsedUsec *int64

+ LagUsec *int64

+ ResponseCode *int64

+ RetryReason *string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TaskQueueQueryTasksResponse_Task_RunLog) ProtoMessage()

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

+ func (m *TaskQueueQueryTasksResponse_Task_RunLog) GetDispatchedUsec() int64

+ func (m *TaskQueueQueryTasksResponse_Task_RunLog) GetElapsedUsec() int64

+ func (m *TaskQueueQueryTasksResponse_Task_RunLog) GetLagUsec() int64

+ func (m *TaskQueueQueryTasksResponse_Task_RunLog) GetResponseCode() int64

+ func (m *TaskQueueQueryTasksResponse_Task_RunLog) GetRetryReason() string

+ func (m *TaskQueueQueryTasksResponse_Task_RunLog) Reset()

+ func (m *TaskQueueQueryTasksResponse_Task_RunLog) String() string

+ func (m *TaskQueueQueryTasksResponse_Task_RunLog) XXX_DiscardUnknown()

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

+ func (m *TaskQueueQueryTasksResponse_Task_RunLog) XXX_Size() int

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

+ type TaskQueueRetryParameters struct

+ AgeLimitSec *int64

+ MaxBackoffSec *float64

+ MaxDoublings *int32

+ MinBackoffSec *float64

+ RetryLimit *int32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TaskQueueRetryParameters) ProtoMessage()

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

+ func (m *TaskQueueRetryParameters) GetAgeLimitSec() int64

+ func (m *TaskQueueRetryParameters) GetMaxBackoffSec() float64

+ func (m *TaskQueueRetryParameters) GetMaxDoublings() int32

+ func (m *TaskQueueRetryParameters) GetMinBackoffSec() float64

+ func (m *TaskQueueRetryParameters) GetRetryLimit() int32

+ func (m *TaskQueueRetryParameters) Reset()

+ func (m *TaskQueueRetryParameters) String() string

+ func (m *TaskQueueRetryParameters) XXX_DiscardUnknown()

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

+ func (m *TaskQueueRetryParameters) XXX_Size() int

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

+ type TaskQueueScannerQueueInfo struct

+ EnforcedRate *float64

+ ExecutedLastHour *int64

+ ExecutedLastMinute *int64

+ RequestsInFlight *int32

+ SamplingDurationSeconds *float64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TaskQueueScannerQueueInfo) ProtoMessage()

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

+ func (m *TaskQueueScannerQueueInfo) GetEnforcedRate() float64

+ func (m *TaskQueueScannerQueueInfo) GetExecutedLastHour() int64

+ func (m *TaskQueueScannerQueueInfo) GetExecutedLastMinute() int64

+ func (m *TaskQueueScannerQueueInfo) GetRequestsInFlight() int32

+ func (m *TaskQueueScannerQueueInfo) GetSamplingDurationSeconds() float64

+ func (m *TaskQueueScannerQueueInfo) Reset()

+ func (m *TaskQueueScannerQueueInfo) String() string

+ func (m *TaskQueueScannerQueueInfo) XXX_DiscardUnknown()

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

+ func (m *TaskQueueScannerQueueInfo) XXX_Size() int

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

+ type TaskQueueServiceError struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TaskQueueServiceError) ProtoMessage()

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

+ func (m *TaskQueueServiceError) Reset()

+ func (m *TaskQueueServiceError) String() string

+ func (m *TaskQueueServiceError) XXX_DiscardUnknown()

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

+ func (m *TaskQueueServiceError) XXX_Size() int

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

+ type TaskQueueServiceError_ErrorCode int32

+ const TaskQueueServiceError_ACL_LOOKUP_ERROR

+ const TaskQueueServiceError_DATASTORE_ERROR

+ const TaskQueueServiceError_DUPLICATE_TASK_NAME

+ const TaskQueueServiceError_INCORRECT_CREATOR_NAME

+ const TaskQueueServiceError_INTERNAL_ERROR

+ const TaskQueueServiceError_INVALID_ETA

+ const TaskQueueServiceError_INVALID_PAYLOAD

+ const TaskQueueServiceError_INVALID_QUEUE_MODE

+ const TaskQueueServiceError_INVALID_QUEUE_NAME

+ const TaskQueueServiceError_INVALID_QUEUE_RATE

+ const TaskQueueServiceError_INVALID_REQUEST

+ const TaskQueueServiceError_INVALID_RETRY_PARAMETERS

+ const TaskQueueServiceError_INVALID_TAG

+ const TaskQueueServiceError_INVALID_TASK_NAME

+ const TaskQueueServiceError_INVALID_URL

+ const TaskQueueServiceError_OK

+ const TaskQueueServiceError_PERMISSION_DENIED

+ const TaskQueueServiceError_QUEUE_PAUSED

+ const TaskQueueServiceError_SKIPPED

+ const TaskQueueServiceError_TASK_ALREADY_EXISTS

+ const TaskQueueServiceError_TASK_LEASE_EXPIRED

+ const TaskQueueServiceError_TASK_TOO_LARGE

+ const TaskQueueServiceError_TOMBSTONED_QUEUE

+ const TaskQueueServiceError_TOMBSTONED_TASK

+ const TaskQueueServiceError_TOO_MANY_TASKS

+ const TaskQueueServiceError_TRANSACTIONAL_REQUEST_TOO_LARGE

+ const TaskQueueServiceError_TRANSIENT_ERROR

+ const TaskQueueServiceError_UNKNOWN_QUEUE

+ const TaskQueueServiceError_UNKNOWN_TASK

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

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

+ func (x TaskQueueServiceError_ErrorCode) Enum() *TaskQueueServiceError_ErrorCode

+ func (x TaskQueueServiceError_ErrorCode) String() string

+ type TaskQueueUpdateQueueRequest struct

+ Acl *TaskQueueAcl

+ AppId []byte

+ BucketCapacity *int32

+ BucketRefillPerSecond *float64

+ HeaderOverride []*TaskQueueHttpHeader

+ MaxConcurrentRequests *int32

+ Mode *TaskQueueMode_Mode

+ QueueName []byte

+ RetryParameters *TaskQueueRetryParameters

+ UserSpecifiedRate *string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TaskQueueUpdateQueueRequest) ProtoMessage()

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

+ func (m *TaskQueueUpdateQueueRequest) GetAcl() *TaskQueueAcl

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

+ func (m *TaskQueueUpdateQueueRequest) GetBucketCapacity() int32

+ func (m *TaskQueueUpdateQueueRequest) GetBucketRefillPerSecond() float64

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

+ func (m *TaskQueueUpdateQueueRequest) GetMaxConcurrentRequests() int32

+ func (m *TaskQueueUpdateQueueRequest) GetMode() TaskQueueMode_Mode

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

+ func (m *TaskQueueUpdateQueueRequest) GetRetryParameters() *TaskQueueRetryParameters

+ func (m *TaskQueueUpdateQueueRequest) GetUserSpecifiedRate() string

+ func (m *TaskQueueUpdateQueueRequest) Reset()

+ func (m *TaskQueueUpdateQueueRequest) String() string

+ func (m *TaskQueueUpdateQueueRequest) XXX_DiscardUnknown()

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

+ func (m *TaskQueueUpdateQueueRequest) XXX_Size() int

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

+ type TaskQueueUpdateQueueResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TaskQueueUpdateQueueResponse) ProtoMessage()

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

+ func (m *TaskQueueUpdateQueueResponse) Reset()

+ func (m *TaskQueueUpdateQueueResponse) String() string

+ func (m *TaskQueueUpdateQueueResponse) XXX_DiscardUnknown()

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

+ func (m *TaskQueueUpdateQueueResponse) XXX_Size() int

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

+ type TaskQueueUpdateStorageLimitRequest struct

+ AppId []byte

+ Limit *int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TaskQueueUpdateStorageLimitRequest) ProtoMessage()

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

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

+ func (m *TaskQueueUpdateStorageLimitRequest) GetLimit() int64

+ func (m *TaskQueueUpdateStorageLimitRequest) Reset()

+ func (m *TaskQueueUpdateStorageLimitRequest) String() string

+ func (m *TaskQueueUpdateStorageLimitRequest) XXX_DiscardUnknown()

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

+ func (m *TaskQueueUpdateStorageLimitRequest) XXX_Size() int

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

+ type TaskQueueUpdateStorageLimitResponse struct

+ NewLimit *int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TaskQueueUpdateStorageLimitResponse) ProtoMessage()

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

+ func (m *TaskQueueUpdateStorageLimitResponse) GetNewLimit() int64

+ func (m *TaskQueueUpdateStorageLimitResponse) Reset()

+ func (m *TaskQueueUpdateStorageLimitResponse) String() string

+ func (m *TaskQueueUpdateStorageLimitResponse) XXX_DiscardUnknown()

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

+ func (m *TaskQueueUpdateStorageLimitResponse) XXX_Size() int

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

v2.0.0-rc2

Jun 3, 2021

v2.0.0-rc1

Jun 2, 2021

Other modules containing this package

google.golang.org/appengine

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL