taskqueue

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

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

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

Documentation

Overview

Package taskqueue is a generated protocol buffer package.

It is generated from these files:

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

It has these top-level messages:

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

Index

Constants

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

Variables

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

Functions

This section is empty.

Types

type TaskPayload

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

func (*TaskPayload) ExtensionMap

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

func (*TaskPayload) ExtensionRangeArray

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

func (*TaskPayload) Marshal

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

func (*TaskPayload) MarshalJSON

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

func (*TaskPayload) ProtoMessage

func (*TaskPayload) ProtoMessage()

func (*TaskPayload) Reset

func (m *TaskPayload) Reset()

func (*TaskPayload) String

func (m *TaskPayload) String() string

func (*TaskPayload) Unmarshal

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

func (*TaskPayload) UnmarshalJSON

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

type TaskQueueAcl

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

func (*TaskQueueAcl) GetUserEmail

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

func (*TaskQueueAcl) GetWriterEmail

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

func (*TaskQueueAcl) ProtoMessage

func (*TaskQueueAcl) ProtoMessage()

func (*TaskQueueAcl) Reset

func (m *TaskQueueAcl) Reset()

func (*TaskQueueAcl) String

func (m *TaskQueueAcl) String() string

type TaskQueueAddRequest

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

func (*TaskQueueAddRequest) GetAppId

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

func (*TaskQueueAddRequest) GetBody

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

func (*TaskQueueAddRequest) GetCrontimetable

func (*TaskQueueAddRequest) GetDescription

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

func (*TaskQueueAddRequest) GetEtaUsec

func (m *TaskQueueAddRequest) GetEtaUsec() int64

func (*TaskQueueAddRequest) GetHeader

func (*TaskQueueAddRequest) GetMethod

func (*TaskQueueAddRequest) GetMode

func (*TaskQueueAddRequest) GetPayload

func (m *TaskQueueAddRequest) GetPayload() *TaskPayload

func (*TaskQueueAddRequest) GetQueueName

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

func (*TaskQueueAddRequest) GetRetryParameters

func (m *TaskQueueAddRequest) GetRetryParameters() *TaskQueueRetryParameters

func (*TaskQueueAddRequest) GetTag

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

func (*TaskQueueAddRequest) GetTaskName

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

func (*TaskQueueAddRequest) GetTransaction

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

func (*TaskQueueAddRequest) GetUrl

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

func (*TaskQueueAddRequest) ProtoMessage

func (*TaskQueueAddRequest) ProtoMessage()

func (*TaskQueueAddRequest) Reset

func (m *TaskQueueAddRequest) Reset()

func (*TaskQueueAddRequest) String

func (m *TaskQueueAddRequest) String() string

type TaskQueueAddRequest_CronTimetable

type TaskQueueAddRequest_CronTimetable struct {
	Schedule         []byte `protobuf:"bytes,13,req,name=schedule" json:"schedule,omitempty"`
	Timezone         []byte `protobuf:"bytes,14,req,name=timezone" json:"timezone,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*TaskQueueAddRequest_CronTimetable) GetSchedule

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

func (*TaskQueueAddRequest_CronTimetable) GetTimezone

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

func (*TaskQueueAddRequest_CronTimetable) ProtoMessage

func (*TaskQueueAddRequest_CronTimetable) ProtoMessage()

func (*TaskQueueAddRequest_CronTimetable) Reset

func (*TaskQueueAddRequest_CronTimetable) String

type TaskQueueAddRequest_Header

type TaskQueueAddRequest_Header struct {
	Key              []byte `protobuf:"bytes,7,req,name=key" json:"key,omitempty"`
	Value            []byte `protobuf:"bytes,8,req,name=value" json:"value,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*TaskQueueAddRequest_Header) GetKey

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

func (*TaskQueueAddRequest_Header) GetValue

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

func (*TaskQueueAddRequest_Header) ProtoMessage

func (*TaskQueueAddRequest_Header) ProtoMessage()

func (*TaskQueueAddRequest_Header) Reset

func (m *TaskQueueAddRequest_Header) Reset()

func (*TaskQueueAddRequest_Header) String

func (m *TaskQueueAddRequest_Header) String() string

type TaskQueueAddRequest_RequestMethod

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

func (TaskQueueAddRequest_RequestMethod) Enum

func (TaskQueueAddRequest_RequestMethod) String

func (*TaskQueueAddRequest_RequestMethod) UnmarshalJSON

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

type TaskQueueAddResponse

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

func (*TaskQueueAddResponse) GetChosenTaskName

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

func (*TaskQueueAddResponse) ProtoMessage

func (*TaskQueueAddResponse) ProtoMessage()

func (*TaskQueueAddResponse) Reset

func (m *TaskQueueAddResponse) Reset()

func (*TaskQueueAddResponse) String

func (m *TaskQueueAddResponse) String() string

type TaskQueueBulkAddRequest

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

func (*TaskQueueBulkAddRequest) GetAddRequest

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

func (*TaskQueueBulkAddRequest) ProtoMessage

func (*TaskQueueBulkAddRequest) ProtoMessage()

func (*TaskQueueBulkAddRequest) Reset

func (m *TaskQueueBulkAddRequest) Reset()

func (*TaskQueueBulkAddRequest) String

func (m *TaskQueueBulkAddRequest) String() string

type TaskQueueBulkAddResponse

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

func (*TaskQueueBulkAddResponse) GetTaskresult

func (*TaskQueueBulkAddResponse) ProtoMessage

func (*TaskQueueBulkAddResponse) ProtoMessage()

func (*TaskQueueBulkAddResponse) Reset

func (m *TaskQueueBulkAddResponse) Reset()

func (*TaskQueueBulkAddResponse) String

func (m *TaskQueueBulkAddResponse) String() string

type TaskQueueBulkAddResponse_TaskResult

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

func (*TaskQueueBulkAddResponse_TaskResult) GetChosenTaskName

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

func (*TaskQueueBulkAddResponse_TaskResult) GetResult

func (*TaskQueueBulkAddResponse_TaskResult) ProtoMessage

func (*TaskQueueBulkAddResponse_TaskResult) ProtoMessage()

func (*TaskQueueBulkAddResponse_TaskResult) Reset

func (*TaskQueueBulkAddResponse_TaskResult) String

type TaskQueueDeleteGroupRequest

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

func (*TaskQueueDeleteGroupRequest) GetAppId

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

func (*TaskQueueDeleteGroupRequest) ProtoMessage

func (*TaskQueueDeleteGroupRequest) ProtoMessage()

func (*TaskQueueDeleteGroupRequest) Reset

func (m *TaskQueueDeleteGroupRequest) Reset()

func (*TaskQueueDeleteGroupRequest) String

func (m *TaskQueueDeleteGroupRequest) String() string

type TaskQueueDeleteGroupResponse

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

func (*TaskQueueDeleteGroupResponse) ProtoMessage

func (*TaskQueueDeleteGroupResponse) ProtoMessage()

func (*TaskQueueDeleteGroupResponse) Reset

func (m *TaskQueueDeleteGroupResponse) Reset()

func (*TaskQueueDeleteGroupResponse) String

type TaskQueueDeleteQueueRequest

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

func (*TaskQueueDeleteQueueRequest) GetAppId

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

func (*TaskQueueDeleteQueueRequest) GetQueueName

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

func (*TaskQueueDeleteQueueRequest) ProtoMessage

func (*TaskQueueDeleteQueueRequest) ProtoMessage()

func (*TaskQueueDeleteQueueRequest) Reset

func (m *TaskQueueDeleteQueueRequest) Reset()

func (*TaskQueueDeleteQueueRequest) String

func (m *TaskQueueDeleteQueueRequest) String() string

type TaskQueueDeleteQueueResponse

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

func (*TaskQueueDeleteQueueResponse) ProtoMessage

func (*TaskQueueDeleteQueueResponse) ProtoMessage()

func (*TaskQueueDeleteQueueResponse) Reset

func (m *TaskQueueDeleteQueueResponse) Reset()

func (*TaskQueueDeleteQueueResponse) String

type TaskQueueDeleteRequest

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

func (*TaskQueueDeleteRequest) GetAppId

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

func (*TaskQueueDeleteRequest) GetQueueName

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

func (*TaskQueueDeleteRequest) GetTaskName

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

func (*TaskQueueDeleteRequest) ProtoMessage

func (*TaskQueueDeleteRequest) ProtoMessage()

func (*TaskQueueDeleteRequest) Reset

func (m *TaskQueueDeleteRequest) Reset()

func (*TaskQueueDeleteRequest) String

func (m *TaskQueueDeleteRequest) String() string

type TaskQueueDeleteResponse

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

func (*TaskQueueDeleteResponse) GetResult

func (*TaskQueueDeleteResponse) ProtoMessage

func (*TaskQueueDeleteResponse) ProtoMessage()

func (*TaskQueueDeleteResponse) Reset

func (m *TaskQueueDeleteResponse) Reset()

func (*TaskQueueDeleteResponse) String

func (m *TaskQueueDeleteResponse) String() string

type TaskQueueFetchQueueStatsRequest

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

func (*TaskQueueFetchQueueStatsRequest) GetAppId

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

func (*TaskQueueFetchQueueStatsRequest) GetMaxNumTasks

func (m *TaskQueueFetchQueueStatsRequest) GetMaxNumTasks() int32

func (*TaskQueueFetchQueueStatsRequest) GetQueueName

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

func (*TaskQueueFetchQueueStatsRequest) ProtoMessage

func (*TaskQueueFetchQueueStatsRequest) ProtoMessage()

func (*TaskQueueFetchQueueStatsRequest) Reset

func (*TaskQueueFetchQueueStatsRequest) String

type TaskQueueFetchQueueStatsResponse

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

func (*TaskQueueFetchQueueStatsResponse) GetQueuestats

func (*TaskQueueFetchQueueStatsResponse) ProtoMessage

func (*TaskQueueFetchQueueStatsResponse) ProtoMessage()

func (*TaskQueueFetchQueueStatsResponse) Reset

func (*TaskQueueFetchQueueStatsResponse) String

type TaskQueueFetchQueueStatsResponse_QueueStats

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

func (*TaskQueueFetchQueueStatsResponse_QueueStats) GetNumTasks

func (*TaskQueueFetchQueueStatsResponse_QueueStats) GetOldestEtaUsec

func (m *TaskQueueFetchQueueStatsResponse_QueueStats) GetOldestEtaUsec() int64

func (*TaskQueueFetchQueueStatsResponse_QueueStats) GetScannerInfo

func (*TaskQueueFetchQueueStatsResponse_QueueStats) ProtoMessage

func (*TaskQueueFetchQueueStatsResponse_QueueStats) Reset

func (*TaskQueueFetchQueueStatsResponse_QueueStats) String

type TaskQueueFetchQueuesRequest

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

func (*TaskQueueFetchQueuesRequest) GetAppId

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

func (*TaskQueueFetchQueuesRequest) GetMaxRows

func (m *TaskQueueFetchQueuesRequest) GetMaxRows() int32

func (*TaskQueueFetchQueuesRequest) ProtoMessage

func (*TaskQueueFetchQueuesRequest) ProtoMessage()

func (*TaskQueueFetchQueuesRequest) Reset

func (m *TaskQueueFetchQueuesRequest) Reset()

func (*TaskQueueFetchQueuesRequest) String

func (m *TaskQueueFetchQueuesRequest) String() string

type TaskQueueFetchQueuesResponse

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

func (*TaskQueueFetchQueuesResponse) GetQueue

func (*TaskQueueFetchQueuesResponse) ProtoMessage

func (*TaskQueueFetchQueuesResponse) ProtoMessage()

func (*TaskQueueFetchQueuesResponse) Reset

func (m *TaskQueueFetchQueuesResponse) Reset()

func (*TaskQueueFetchQueuesResponse) String

type TaskQueueFetchQueuesResponse_Queue

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

func (*TaskQueueFetchQueuesResponse_Queue) GetAcl

func (*TaskQueueFetchQueuesResponse_Queue) GetBucketCapacity

func (m *TaskQueueFetchQueuesResponse_Queue) GetBucketCapacity() float64

func (*TaskQueueFetchQueuesResponse_Queue) GetBucketRefillPerSecond

func (m *TaskQueueFetchQueuesResponse_Queue) GetBucketRefillPerSecond() float64

func (*TaskQueueFetchQueuesResponse_Queue) GetCreatorName

func (m *TaskQueueFetchQueuesResponse_Queue) GetCreatorName() string

func (*TaskQueueFetchQueuesResponse_Queue) GetHeaderOverride

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

func (*TaskQueueFetchQueuesResponse_Queue) GetMaxConcurrentRequests

func (m *TaskQueueFetchQueuesResponse_Queue) GetMaxConcurrentRequests() int32

func (*TaskQueueFetchQueuesResponse_Queue) GetMode

func (*TaskQueueFetchQueuesResponse_Queue) GetPaused

func (*TaskQueueFetchQueuesResponse_Queue) GetQueueName

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

func (*TaskQueueFetchQueuesResponse_Queue) GetRetryParameters

func (*TaskQueueFetchQueuesResponse_Queue) GetUserSpecifiedRate

func (m *TaskQueueFetchQueuesResponse_Queue) GetUserSpecifiedRate() string

func (*TaskQueueFetchQueuesResponse_Queue) ProtoMessage

func (*TaskQueueFetchQueuesResponse_Queue) ProtoMessage()

func (*TaskQueueFetchQueuesResponse_Queue) Reset

func (*TaskQueueFetchQueuesResponse_Queue) String

type TaskQueueFetchTaskRequest

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

func (*TaskQueueFetchTaskRequest) GetAppId

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

func (*TaskQueueFetchTaskRequest) GetQueueName

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

func (*TaskQueueFetchTaskRequest) GetTaskName

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

func (*TaskQueueFetchTaskRequest) ProtoMessage

func (*TaskQueueFetchTaskRequest) ProtoMessage()

func (*TaskQueueFetchTaskRequest) Reset

func (m *TaskQueueFetchTaskRequest) Reset()

func (*TaskQueueFetchTaskRequest) String

func (m *TaskQueueFetchTaskRequest) String() string

type TaskQueueFetchTaskResponse

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

func (*TaskQueueFetchTaskResponse) GetTask

func (*TaskQueueFetchTaskResponse) ProtoMessage

func (*TaskQueueFetchTaskResponse) ProtoMessage()

func (*TaskQueueFetchTaskResponse) Reset

func (m *TaskQueueFetchTaskResponse) Reset()

func (*TaskQueueFetchTaskResponse) String

func (m *TaskQueueFetchTaskResponse) String() string

type TaskQueueForceRunRequest

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

func (*TaskQueueForceRunRequest) GetAppId

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

func (*TaskQueueForceRunRequest) GetQueueName

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

func (*TaskQueueForceRunRequest) GetTaskName

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

func (*TaskQueueForceRunRequest) ProtoMessage

func (*TaskQueueForceRunRequest) ProtoMessage()

func (*TaskQueueForceRunRequest) Reset

func (m *TaskQueueForceRunRequest) Reset()

func (*TaskQueueForceRunRequest) String

func (m *TaskQueueForceRunRequest) String() string

type TaskQueueForceRunResponse

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

func (*TaskQueueForceRunResponse) GetResult

func (*TaskQueueForceRunResponse) ProtoMessage

func (*TaskQueueForceRunResponse) ProtoMessage()

func (*TaskQueueForceRunResponse) Reset

func (m *TaskQueueForceRunResponse) Reset()

func (*TaskQueueForceRunResponse) String

func (m *TaskQueueForceRunResponse) String() string

type TaskQueueHttpHeader

type TaskQueueHttpHeader struct {
	Key              []byte `protobuf:"bytes,1,req,name=key" json:"key,omitempty"`
	Value            []byte `protobuf:"bytes,2,req,name=value" json:"value,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*TaskQueueHttpHeader) GetKey

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

func (*TaskQueueHttpHeader) GetValue

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

func (*TaskQueueHttpHeader) ProtoMessage

func (*TaskQueueHttpHeader) ProtoMessage()

func (*TaskQueueHttpHeader) Reset

func (m *TaskQueueHttpHeader) Reset()

func (*TaskQueueHttpHeader) String

func (m *TaskQueueHttpHeader) String() string

type TaskQueueMode

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

func (*TaskQueueMode) ProtoMessage

func (*TaskQueueMode) ProtoMessage()

func (*TaskQueueMode) Reset

func (m *TaskQueueMode) Reset()

func (*TaskQueueMode) String

func (m *TaskQueueMode) String() string

type TaskQueueMode_Mode

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

func (TaskQueueMode_Mode) Enum

func (TaskQueueMode_Mode) String

func (x TaskQueueMode_Mode) String() string

func (*TaskQueueMode_Mode) UnmarshalJSON

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

type TaskQueueModifyTaskLeaseRequest

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

func (*TaskQueueModifyTaskLeaseRequest) GetEtaUsec

func (m *TaskQueueModifyTaskLeaseRequest) GetEtaUsec() int64

func (*TaskQueueModifyTaskLeaseRequest) GetLeaseSeconds

func (m *TaskQueueModifyTaskLeaseRequest) GetLeaseSeconds() float64

func (*TaskQueueModifyTaskLeaseRequest) GetQueueName

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

func (*TaskQueueModifyTaskLeaseRequest) GetTaskName

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

func (*TaskQueueModifyTaskLeaseRequest) ProtoMessage

func (*TaskQueueModifyTaskLeaseRequest) ProtoMessage()

func (*TaskQueueModifyTaskLeaseRequest) Reset

func (*TaskQueueModifyTaskLeaseRequest) String

type TaskQueueModifyTaskLeaseResponse

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

func (*TaskQueueModifyTaskLeaseResponse) GetUpdatedEtaUsec

func (m *TaskQueueModifyTaskLeaseResponse) GetUpdatedEtaUsec() int64

func (*TaskQueueModifyTaskLeaseResponse) ProtoMessage

func (*TaskQueueModifyTaskLeaseResponse) ProtoMessage()

func (*TaskQueueModifyTaskLeaseResponse) Reset

func (*TaskQueueModifyTaskLeaseResponse) String

type TaskQueuePauseQueueRequest

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

func (*TaskQueuePauseQueueRequest) GetAppId

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

func (*TaskQueuePauseQueueRequest) GetPause

func (m *TaskQueuePauseQueueRequest) GetPause() bool

func (*TaskQueuePauseQueueRequest) GetQueueName

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

func (*TaskQueuePauseQueueRequest) ProtoMessage

func (*TaskQueuePauseQueueRequest) ProtoMessage()

func (*TaskQueuePauseQueueRequest) Reset

func (m *TaskQueuePauseQueueRequest) Reset()

func (*TaskQueuePauseQueueRequest) String

func (m *TaskQueuePauseQueueRequest) String() string

type TaskQueuePauseQueueResponse

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

func (*TaskQueuePauseQueueResponse) ProtoMessage

func (*TaskQueuePauseQueueResponse) ProtoMessage()

func (*TaskQueuePauseQueueResponse) Reset

func (m *TaskQueuePauseQueueResponse) Reset()

func (*TaskQueuePauseQueueResponse) String

func (m *TaskQueuePauseQueueResponse) String() string

type TaskQueuePurgeQueueRequest

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

func (*TaskQueuePurgeQueueRequest) GetAppId

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

func (*TaskQueuePurgeQueueRequest) GetQueueName

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

func (*TaskQueuePurgeQueueRequest) ProtoMessage

func (*TaskQueuePurgeQueueRequest) ProtoMessage()

func (*TaskQueuePurgeQueueRequest) Reset

func (m *TaskQueuePurgeQueueRequest) Reset()

func (*TaskQueuePurgeQueueRequest) String

func (m *TaskQueuePurgeQueueRequest) String() string

type TaskQueuePurgeQueueResponse

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

func (*TaskQueuePurgeQueueResponse) ProtoMessage

func (*TaskQueuePurgeQueueResponse) ProtoMessage()

func (*TaskQueuePurgeQueueResponse) Reset

func (m *TaskQueuePurgeQueueResponse) Reset()

func (*TaskQueuePurgeQueueResponse) String

func (m *TaskQueuePurgeQueueResponse) String() string

type TaskQueueQueryAndOwnTasksRequest

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

func (*TaskQueueQueryAndOwnTasksRequest) GetGroupByTag

func (m *TaskQueueQueryAndOwnTasksRequest) GetGroupByTag() bool

func (*TaskQueueQueryAndOwnTasksRequest) GetLeaseSeconds

func (m *TaskQueueQueryAndOwnTasksRequest) GetLeaseSeconds() float64

func (*TaskQueueQueryAndOwnTasksRequest) GetMaxTasks

func (m *TaskQueueQueryAndOwnTasksRequest) GetMaxTasks() int64

func (*TaskQueueQueryAndOwnTasksRequest) GetQueueName

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

func (*TaskQueueQueryAndOwnTasksRequest) GetTag

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

func (*TaskQueueQueryAndOwnTasksRequest) ProtoMessage

func (*TaskQueueQueryAndOwnTasksRequest) ProtoMessage()

func (*TaskQueueQueryAndOwnTasksRequest) Reset

func (*TaskQueueQueryAndOwnTasksRequest) String

type TaskQueueQueryAndOwnTasksResponse

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

func (*TaskQueueQueryAndOwnTasksResponse) GetTask

func (*TaskQueueQueryAndOwnTasksResponse) ProtoMessage

func (*TaskQueueQueryAndOwnTasksResponse) ProtoMessage()

func (*TaskQueueQueryAndOwnTasksResponse) Reset

func (*TaskQueueQueryAndOwnTasksResponse) String

type TaskQueueQueryAndOwnTasksResponse_Task

type TaskQueueQueryAndOwnTasksResponse_Task struct {
	TaskName         []byte `protobuf:"bytes,2,req,name=task_name" json:"task_name,omitempty"`
	EtaUsec          *int64 `protobuf:"varint,3,req,name=eta_usec" json:"eta_usec,omitempty"`
	RetryCount       *int32 `protobuf:"varint,4,opt,name=retry_count,def=0" json:"retry_count,omitempty"`
	Body             []byte `protobuf:"bytes,5,opt,name=body" json:"body,omitempty"`
	Tag              []byte `protobuf:"bytes,6,opt,name=tag" json:"tag,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*TaskQueueQueryAndOwnTasksResponse_Task) GetBody

func (*TaskQueueQueryAndOwnTasksResponse_Task) GetEtaUsec

func (*TaskQueueQueryAndOwnTasksResponse_Task) GetRetryCount

func (m *TaskQueueQueryAndOwnTasksResponse_Task) GetRetryCount() int32

func (*TaskQueueQueryAndOwnTasksResponse_Task) GetTag

func (*TaskQueueQueryAndOwnTasksResponse_Task) GetTaskName

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

func (*TaskQueueQueryAndOwnTasksResponse_Task) ProtoMessage

func (*TaskQueueQueryAndOwnTasksResponse_Task) Reset

func (*TaskQueueQueryAndOwnTasksResponse_Task) String

type TaskQueueQueryTasksRequest

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

func (*TaskQueueQueryTasksRequest) GetAppId

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

func (*TaskQueueQueryTasksRequest) GetMaxRows

func (m *TaskQueueQueryTasksRequest) GetMaxRows() int32

func (*TaskQueueQueryTasksRequest) GetQueueName

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

func (*TaskQueueQueryTasksRequest) GetStartEtaUsec

func (m *TaskQueueQueryTasksRequest) GetStartEtaUsec() int64

func (*TaskQueueQueryTasksRequest) GetStartTag

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

func (*TaskQueueQueryTasksRequest) GetStartTaskName

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

func (*TaskQueueQueryTasksRequest) ProtoMessage

func (*TaskQueueQueryTasksRequest) ProtoMessage()

func (*TaskQueueQueryTasksRequest) Reset

func (m *TaskQueueQueryTasksRequest) Reset()

func (*TaskQueueQueryTasksRequest) String

func (m *TaskQueueQueryTasksRequest) String() string

type TaskQueueQueryTasksResponse

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

func (*TaskQueueQueryTasksResponse) GetTask

func (*TaskQueueQueryTasksResponse) ProtoMessage

func (*TaskQueueQueryTasksResponse) ProtoMessage()

func (*TaskQueueQueryTasksResponse) Reset

func (m *TaskQueueQueryTasksResponse) Reset()

func (*TaskQueueQueryTasksResponse) String

func (m *TaskQueueQueryTasksResponse) String() string

type TaskQueueQueryTasksResponse_Task

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

func (*TaskQueueQueryTasksResponse_Task) GetBody

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

func (*TaskQueueQueryTasksResponse_Task) GetBodySize

func (m *TaskQueueQueryTasksResponse_Task) GetBodySize() int32

func (*TaskQueueQueryTasksResponse_Task) GetCreationTimeUsec

func (m *TaskQueueQueryTasksResponse_Task) GetCreationTimeUsec() int64

func (*TaskQueueQueryTasksResponse_Task) GetCrontimetable

func (*TaskQueueQueryTasksResponse_Task) GetDescription

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

func (*TaskQueueQueryTasksResponse_Task) GetEtaUsec

func (m *TaskQueueQueryTasksResponse_Task) GetEtaUsec() int64

func (*TaskQueueQueryTasksResponse_Task) GetExecutionCount

func (m *TaskQueueQueryTasksResponse_Task) GetExecutionCount() int32

func (*TaskQueueQueryTasksResponse_Task) GetFirstTryUsec

func (m *TaskQueueQueryTasksResponse_Task) GetFirstTryUsec() int64

func (*TaskQueueQueryTasksResponse_Task) GetHeader

func (*TaskQueueQueryTasksResponse_Task) GetMethod

func (*TaskQueueQueryTasksResponse_Task) GetPayload

func (*TaskQueueQueryTasksResponse_Task) GetRetryCount

func (m *TaskQueueQueryTasksResponse_Task) GetRetryCount() int32

func (*TaskQueueQueryTasksResponse_Task) GetRetryParameters

func (*TaskQueueQueryTasksResponse_Task) GetRunlog

func (*TaskQueueQueryTasksResponse_Task) GetTag

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

func (*TaskQueueQueryTasksResponse_Task) GetTaskName

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

func (*TaskQueueQueryTasksResponse_Task) GetUrl

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

func (*TaskQueueQueryTasksResponse_Task) ProtoMessage

func (*TaskQueueQueryTasksResponse_Task) ProtoMessage()

func (*TaskQueueQueryTasksResponse_Task) Reset

func (*TaskQueueQueryTasksResponse_Task) String

type TaskQueueQueryTasksResponse_Task_CronTimetable

type TaskQueueQueryTasksResponse_Task_CronTimetable struct {
	Schedule         []byte `protobuf:"bytes,14,req,name=schedule" json:"schedule,omitempty"`
	Timezone         []byte `protobuf:"bytes,15,req,name=timezone" json:"timezone,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*TaskQueueQueryTasksResponse_Task_CronTimetable) GetSchedule

func (*TaskQueueQueryTasksResponse_Task_CronTimetable) GetTimezone

func (*TaskQueueQueryTasksResponse_Task_CronTimetable) ProtoMessage

func (*TaskQueueQueryTasksResponse_Task_CronTimetable) Reset

func (*TaskQueueQueryTasksResponse_Task_CronTimetable) String

type TaskQueueQueryTasksResponse_Task_Header

type TaskQueueQueryTasksResponse_Task_Header struct {
	Key              []byte `protobuf:"bytes,8,req,name=key" json:"key,omitempty"`
	Value            []byte `protobuf:"bytes,9,req,name=value" json:"value,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*TaskQueueQueryTasksResponse_Task_Header) GetKey

func (*TaskQueueQueryTasksResponse_Task_Header) GetValue

func (*TaskQueueQueryTasksResponse_Task_Header) ProtoMessage

func (*TaskQueueQueryTasksResponse_Task_Header) Reset

func (*TaskQueueQueryTasksResponse_Task_Header) String

type TaskQueueQueryTasksResponse_Task_RequestMethod

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

func (TaskQueueQueryTasksResponse_Task_RequestMethod) Enum

func (TaskQueueQueryTasksResponse_Task_RequestMethod) String

func (*TaskQueueQueryTasksResponse_Task_RequestMethod) UnmarshalJSON

type TaskQueueQueryTasksResponse_Task_RunLog

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

func (*TaskQueueQueryTasksResponse_Task_RunLog) GetDispatchedUsec

func (m *TaskQueueQueryTasksResponse_Task_RunLog) GetDispatchedUsec() int64

func (*TaskQueueQueryTasksResponse_Task_RunLog) GetElapsedUsec

func (m *TaskQueueQueryTasksResponse_Task_RunLog) GetElapsedUsec() int64

func (*TaskQueueQueryTasksResponse_Task_RunLog) GetLagUsec

func (*TaskQueueQueryTasksResponse_Task_RunLog) GetResponseCode

func (m *TaskQueueQueryTasksResponse_Task_RunLog) GetResponseCode() int64

func (*TaskQueueQueryTasksResponse_Task_RunLog) GetRetryReason

func (m *TaskQueueQueryTasksResponse_Task_RunLog) GetRetryReason() string

func (*TaskQueueQueryTasksResponse_Task_RunLog) ProtoMessage

func (*TaskQueueQueryTasksResponse_Task_RunLog) Reset

func (*TaskQueueQueryTasksResponse_Task_RunLog) String

type TaskQueueRetryParameters

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

func (*TaskQueueRetryParameters) GetAgeLimitSec

func (m *TaskQueueRetryParameters) GetAgeLimitSec() int64

func (*TaskQueueRetryParameters) GetMaxBackoffSec

func (m *TaskQueueRetryParameters) GetMaxBackoffSec() float64

func (*TaskQueueRetryParameters) GetMaxDoublings

func (m *TaskQueueRetryParameters) GetMaxDoublings() int32

func (*TaskQueueRetryParameters) GetMinBackoffSec

func (m *TaskQueueRetryParameters) GetMinBackoffSec() float64

func (*TaskQueueRetryParameters) GetRetryLimit

func (m *TaskQueueRetryParameters) GetRetryLimit() int32

func (*TaskQueueRetryParameters) ProtoMessage

func (*TaskQueueRetryParameters) ProtoMessage()

func (*TaskQueueRetryParameters) Reset

func (m *TaskQueueRetryParameters) Reset()

func (*TaskQueueRetryParameters) String

func (m *TaskQueueRetryParameters) String() string

type TaskQueueScannerQueueInfo

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

func (*TaskQueueScannerQueueInfo) GetEnforcedRate

func (m *TaskQueueScannerQueueInfo) GetEnforcedRate() float64

func (*TaskQueueScannerQueueInfo) GetExecutedLastHour

func (m *TaskQueueScannerQueueInfo) GetExecutedLastHour() int64

func (*TaskQueueScannerQueueInfo) GetExecutedLastMinute

func (m *TaskQueueScannerQueueInfo) GetExecutedLastMinute() int64

func (*TaskQueueScannerQueueInfo) GetRequestsInFlight

func (m *TaskQueueScannerQueueInfo) GetRequestsInFlight() int32

func (*TaskQueueScannerQueueInfo) GetSamplingDurationSeconds

func (m *TaskQueueScannerQueueInfo) GetSamplingDurationSeconds() float64

func (*TaskQueueScannerQueueInfo) ProtoMessage

func (*TaskQueueScannerQueueInfo) ProtoMessage()

func (*TaskQueueScannerQueueInfo) Reset

func (m *TaskQueueScannerQueueInfo) Reset()

func (*TaskQueueScannerQueueInfo) String

func (m *TaskQueueScannerQueueInfo) String() string

type TaskQueueServiceError

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

func (*TaskQueueServiceError) ProtoMessage

func (*TaskQueueServiceError) ProtoMessage()

func (*TaskQueueServiceError) Reset

func (m *TaskQueueServiceError) Reset()

func (*TaskQueueServiceError) String

func (m *TaskQueueServiceError) String() string

type TaskQueueServiceError_ErrorCode

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

func (TaskQueueServiceError_ErrorCode) Enum

func (TaskQueueServiceError_ErrorCode) String

func (*TaskQueueServiceError_ErrorCode) UnmarshalJSON

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

type TaskQueueUpdateQueueRequest

type TaskQueueUpdateQueueRequest struct {
	AppId                 []byte                    `protobuf:"bytes,1,opt,name=app_id" json:"app_id,omitempty"`
	QueueName             []byte                    `protobuf:"bytes,2,req,name=queue_name" json:"queue_name,omitempty"`
	BucketRefillPerSecond *float64                  `protobuf:"fixed64,3,req,name=bucket_refill_per_second" json:"bucket_refill_per_second,omitempty"`
	BucketCapacity        *int32                    `protobuf:"varint,4,req,name=bucket_capacity" json:"bucket_capacity,omitempty"`
	UserSpecifiedRate     *string                   `protobuf:"bytes,5,opt,name=user_specified_rate" json:"user_specified_rate,omitempty"`
	RetryParameters       *TaskQueueRetryParameters `protobuf:"bytes,6,opt,name=retry_parameters" json:"retry_parameters,omitempty"`
	MaxConcurrentRequests *int32                    `protobuf:"varint,7,opt,name=max_concurrent_requests" json:"max_concurrent_requests,omitempty"`
	Mode                  *TaskQueueMode_Mode       `protobuf:"varint,8,opt,name=mode,enum=appengine.TaskQueueMode_Mode,def=0" json:"mode,omitempty"`
	Acl                   *TaskQueueAcl             `protobuf:"bytes,9,opt,name=acl" json:"acl,omitempty"`
	HeaderOverride        []*TaskQueueHttpHeader    `protobuf:"bytes,10,rep,name=header_override" json:"header_override,omitempty"`
	XXX_unrecognized      []byte                    `json:"-"`
}

func (*TaskQueueUpdateQueueRequest) GetAcl

func (*TaskQueueUpdateQueueRequest) GetAppId

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

func (*TaskQueueUpdateQueueRequest) GetBucketCapacity

func (m *TaskQueueUpdateQueueRequest) GetBucketCapacity() int32

func (*TaskQueueUpdateQueueRequest) GetBucketRefillPerSecond

func (m *TaskQueueUpdateQueueRequest) GetBucketRefillPerSecond() float64

func (*TaskQueueUpdateQueueRequest) GetHeaderOverride

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

func (*TaskQueueUpdateQueueRequest) GetMaxConcurrentRequests

func (m *TaskQueueUpdateQueueRequest) GetMaxConcurrentRequests() int32

func (*TaskQueueUpdateQueueRequest) GetMode

func (*TaskQueueUpdateQueueRequest) GetQueueName

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

func (*TaskQueueUpdateQueueRequest) GetRetryParameters

func (m *TaskQueueUpdateQueueRequest) GetRetryParameters() *TaskQueueRetryParameters

func (*TaskQueueUpdateQueueRequest) GetUserSpecifiedRate

func (m *TaskQueueUpdateQueueRequest) GetUserSpecifiedRate() string

func (*TaskQueueUpdateQueueRequest) ProtoMessage

func (*TaskQueueUpdateQueueRequest) ProtoMessage()

func (*TaskQueueUpdateQueueRequest) Reset

func (m *TaskQueueUpdateQueueRequest) Reset()

func (*TaskQueueUpdateQueueRequest) String

func (m *TaskQueueUpdateQueueRequest) String() string

type TaskQueueUpdateQueueResponse

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

func (*TaskQueueUpdateQueueResponse) ProtoMessage

func (*TaskQueueUpdateQueueResponse) ProtoMessage()

func (*TaskQueueUpdateQueueResponse) Reset

func (m *TaskQueueUpdateQueueResponse) Reset()

func (*TaskQueueUpdateQueueResponse) String

type TaskQueueUpdateStorageLimitRequest

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

func (*TaskQueueUpdateStorageLimitRequest) GetAppId

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

func (*TaskQueueUpdateStorageLimitRequest) GetLimit

func (*TaskQueueUpdateStorageLimitRequest) ProtoMessage

func (*TaskQueueUpdateStorageLimitRequest) ProtoMessage()

func (*TaskQueueUpdateStorageLimitRequest) Reset

func (*TaskQueueUpdateStorageLimitRequest) String

type TaskQueueUpdateStorageLimitResponse

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

func (*TaskQueueUpdateStorageLimitResponse) GetNewLimit

func (m *TaskQueueUpdateStorageLimitResponse) GetNewLimit() int64

func (*TaskQueueUpdateStorageLimitResponse) ProtoMessage

func (*TaskQueueUpdateStorageLimitResponse) ProtoMessage()

func (*TaskQueueUpdateStorageLimitResponse) Reset

func (*TaskQueueUpdateStorageLimitResponse) String

Jump to

Keyboard shortcuts

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