appengine

package
v0.0.0-...-456eabd Latest Latest
Warning

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

Go to latest
Published: Nov 5, 2011 License: BSD-3-Clause Imports: 2 Imported by: 0

Documentation

Index

Constants

View Source
const Default_TaskQueueFetchQueuesResponse_Queue_CreatorName string = "apphosting"
View Source
const Default_TaskQueueFetchQueuesResponse_Queue_Paused 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_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
View Source
const Default_Transaction_MarkChanges bool = false

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",
	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,
	"DATASTORE_ERROR":                 10000,
}

Functions

This section is empty.

Types

type TaskPayload

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

func (*TaskPayload) ExtensionMap

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

func (*TaskPayload) ExtensionRangeArray

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

func (*TaskPayload) Marshal

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

func (*TaskPayload) Reset

func (this *TaskPayload) Reset()

func (*TaskPayload) String

func (this *TaskPayload) String() string

func (*TaskPayload) Unmarshal

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

type TaskQueueAcl

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

func (*TaskQueueAcl) Reset

func (this *TaskQueueAcl) Reset()

func (*TaskQueueAcl) String

func (this *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" json:"header,omitempty"`
	Body             []byte                             `protobuf:"bytes,9,opt,name=body" json:"body,omitempty"`
	Transaction      *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"`
	XXX_unrecognized []byte                             `json:",omitempty"`
}

func (*TaskQueueAddRequest) Reset

func (this *TaskQueueAddRequest) Reset()

func (*TaskQueueAddRequest) String

func (this *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:",omitempty"`
}

func (*TaskQueueAddRequest_CronTimetable) Reset

func (this *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:",omitempty"`
}

func (*TaskQueueAddRequest_Header) Reset

func (this *TaskQueueAddRequest_Header) Reset()

func (*TaskQueueAddRequest_Header) String

func (this *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) String

type TaskQueueAddResponse

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

func (*TaskQueueAddResponse) Reset

func (this *TaskQueueAddResponse) Reset()

func (*TaskQueueAddResponse) String

func (this *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:",omitempty"`
}

func (*TaskQueueBulkAddRequest) Reset

func (this *TaskQueueBulkAddRequest) Reset()

func (*TaskQueueBulkAddRequest) String

func (this *TaskQueueBulkAddRequest) String() string

type TaskQueueBulkAddResponse

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

func (*TaskQueueBulkAddResponse) Reset

func (this *TaskQueueBulkAddResponse) Reset()

func (*TaskQueueBulkAddResponse) String

func (this *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:",omitempty"`
}

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:",omitempty"`
}

func (*TaskQueueDeleteGroupRequest) Reset

func (this *TaskQueueDeleteGroupRequest) Reset()

func (*TaskQueueDeleteGroupRequest) String

func (this *TaskQueueDeleteGroupRequest) String() string

type TaskQueueDeleteGroupResponse

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

func (*TaskQueueDeleteGroupResponse) Reset

func (this *TaskQueueDeleteGroupResponse) Reset()

func (*TaskQueueDeleteGroupResponse) String

func (this *TaskQueueDeleteGroupResponse) String() string

type TaskQueueDeleteQueueRequest

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

func (*TaskQueueDeleteQueueRequest) Reset

func (this *TaskQueueDeleteQueueRequest) Reset()

func (*TaskQueueDeleteQueueRequest) String

func (this *TaskQueueDeleteQueueRequest) String() string

type TaskQueueDeleteQueueResponse

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

func (*TaskQueueDeleteQueueResponse) Reset

func (this *TaskQueueDeleteQueueResponse) Reset()

func (*TaskQueueDeleteQueueResponse) String

func (this *TaskQueueDeleteQueueResponse) String() string

type TaskQueueDeleteRequest

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

func (*TaskQueueDeleteRequest) Reset

func (this *TaskQueueDeleteRequest) Reset()

func (*TaskQueueDeleteRequest) String

func (this *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:",omitempty"`
}

func (*TaskQueueDeleteResponse) Reset

func (this *TaskQueueDeleteResponse) Reset()

func (*TaskQueueDeleteResponse) String

func (this *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,req,name=max_num_tasks" json:"max_num_tasks,omitempty"`
	XXX_unrecognized []byte   `json:",omitempty"`
}

func (*TaskQueueFetchQueueStatsRequest) Reset

func (this *TaskQueueFetchQueueStatsRequest) Reset()

func (*TaskQueueFetchQueueStatsRequest) String

func (this *TaskQueueFetchQueueStatsRequest) String() string

type TaskQueueFetchQueueStatsResponse

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

func (*TaskQueueFetchQueueStatsResponse) Reset

func (this *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:",omitempty"`
}

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:",omitempty"`
}

func (*TaskQueueFetchQueuesRequest) Reset

func (this *TaskQueueFetchQueuesRequest) Reset()

func (*TaskQueueFetchQueuesRequest) String

func (this *TaskQueueFetchQueuesRequest) String() string

type TaskQueueFetchQueuesResponse

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

func (*TaskQueueFetchQueuesResponse) Reset

func (this *TaskQueueFetchQueuesResponse) Reset()

func (*TaskQueueFetchQueuesResponse) String

func (this *TaskQueueFetchQueuesResponse) String() string

type TaskQueueFetchQueuesResponse_Queue

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

func (*TaskQueueFetchQueuesResponse_Queue) Reset

func (this *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:",omitempty"`
}

func (*TaskQueueFetchTaskRequest) Reset

func (this *TaskQueueFetchTaskRequest) Reset()

func (*TaskQueueFetchTaskRequest) String

func (this *TaskQueueFetchTaskRequest) String() string

type TaskQueueFetchTaskResponse

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

func (*TaskQueueFetchTaskResponse) Reset

func (this *TaskQueueFetchTaskResponse) Reset()

func (*TaskQueueFetchTaskResponse) String

func (this *TaskQueueFetchTaskResponse) String() string

type TaskQueueForceRunRequest

type TaskQueueForceRunRequest 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"`
	TaskName         []byte `protobuf:"bytes,3,req,name=task_name" json:"task_name,omitempty"`
	XXX_unrecognized []byte `json:",omitempty"`
}

func (*TaskQueueForceRunRequest) Reset

func (this *TaskQueueForceRunRequest) Reset()

func (*TaskQueueForceRunRequest) String

func (this *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:",omitempty"`
}

func (*TaskQueueForceRunResponse) Reset

func (this *TaskQueueForceRunResponse) Reset()

func (*TaskQueueForceRunResponse) String

func (this *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:",omitempty"`
}

func (*TaskQueueHttpHeader) Reset

func (this *TaskQueueHttpHeader) Reset()

func (*TaskQueueHttpHeader) String

func (this *TaskQueueHttpHeader) String() string

type TaskQueueMode

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

func (*TaskQueueMode) Reset

func (this *TaskQueueMode) Reset()

func (*TaskQueueMode) String

func (this *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 NewTaskQueueMode_Mode

func NewTaskQueueMode_Mode(x TaskQueueMode_Mode) *TaskQueueMode_Mode

func (TaskQueueMode_Mode) String

func (x TaskQueueMode_Mode) String() string

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:",omitempty"`
}

func (*TaskQueueModifyTaskLeaseRequest) Reset

func (this *TaskQueueModifyTaskLeaseRequest) Reset()

func (*TaskQueueModifyTaskLeaseRequest) String

func (this *TaskQueueModifyTaskLeaseRequest) String() string

type TaskQueueModifyTaskLeaseResponse

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

func (*TaskQueueModifyTaskLeaseResponse) Reset

func (this *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:",omitempty"`
}

func (*TaskQueuePauseQueueRequest) Reset

func (this *TaskQueuePauseQueueRequest) Reset()

func (*TaskQueuePauseQueueRequest) String

func (this *TaskQueuePauseQueueRequest) String() string

type TaskQueuePauseQueueResponse

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

func (*TaskQueuePauseQueueResponse) Reset

func (this *TaskQueuePauseQueueResponse) Reset()

func (*TaskQueuePauseQueueResponse) String

func (this *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:",omitempty"`
}

func (*TaskQueuePurgeQueueRequest) Reset

func (this *TaskQueuePurgeQueueRequest) Reset()

func (*TaskQueuePurgeQueueRequest) String

func (this *TaskQueuePurgeQueueRequest) String() string

type TaskQueuePurgeQueueResponse

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

func (*TaskQueuePurgeQueueResponse) Reset

func (this *TaskQueuePurgeQueueResponse) Reset()

func (*TaskQueuePurgeQueueResponse) String

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

func (*TaskQueueQueryAndOwnTasksRequest) Reset

func (this *TaskQueueQueryAndOwnTasksRequest) Reset()

func (*TaskQueueQueryAndOwnTasksRequest) String

type TaskQueueQueryAndOwnTasksResponse

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

func (*TaskQueueQueryAndOwnTasksResponse) Reset

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

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"`
	MaxRows          *int32 `protobuf:"varint,5,opt,name=max_rows,def=1" json:"max_rows,omitempty"`
	XXX_unrecognized []byte `json:",omitempty"`
}

func (*TaskQueueQueryTasksRequest) Reset

func (this *TaskQueueQueryTasksRequest) Reset()

func (*TaskQueueQueryTasksRequest) String

func (this *TaskQueueQueryTasksRequest) String() string

type TaskQueueQueryTasksResponse

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

func (*TaskQueueQueryTasksResponse) Reset

func (this *TaskQueueQueryTasksResponse) Reset()

func (*TaskQueueQueryTasksResponse) String

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

func (*TaskQueueQueryTasksResponse_Task) Reset

func (this *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:",omitempty"`
}

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:",omitempty"`
}

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

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"`
	XXX_unrecognized []byte `json:",omitempty"`
}

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:",omitempty"`
}

func (*TaskQueueRetryParameters) Reset

func (this *TaskQueueRetryParameters) Reset()

func (*TaskQueueRetryParameters) String

func (this *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:",omitempty"`
}

func (*TaskQueueScannerQueueInfo) Reset

func (this *TaskQueueScannerQueueInfo) Reset()

func (*TaskQueueScannerQueueInfo) String

func (this *TaskQueueScannerQueueInfo) String() string

type TaskQueueServiceError

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

func (*TaskQueueServiceError) Error

func (this *TaskQueueServiceError) Error() string

func (*TaskQueueServiceError) Reset

func (this *TaskQueueServiceError) Reset()

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_DATASTORE_ERROR                 TaskQueueServiceError_ErrorCode = 10000
)

func (TaskQueueServiceError_ErrorCode) String

type TaskQueueUpdateQueueRequest

type TaskQueueUpdateQueueRequest 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"`
	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:",omitempty"`
}

func (*TaskQueueUpdateQueueRequest) Reset

func (this *TaskQueueUpdateQueueRequest) Reset()

func (*TaskQueueUpdateQueueRequest) String

func (this *TaskQueueUpdateQueueRequest) String() string

type TaskQueueUpdateQueueResponse

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

func (*TaskQueueUpdateQueueResponse) Reset

func (this *TaskQueueUpdateQueueResponse) Reset()

func (*TaskQueueUpdateQueueResponse) String

func (this *TaskQueueUpdateQueueResponse) String() string

type TaskQueueUpdateStorageLimitRequest

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

func (*TaskQueueUpdateStorageLimitRequest) Reset

func (this *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:",omitempty"`
}

func (*TaskQueueUpdateStorageLimitResponse) Reset

func (*TaskQueueUpdateStorageLimitResponse) String

type Transaction

type Transaction struct {
	Handle           *uint64 `protobuf:"fixed64,1,req,name=handle" json:"handle,omitempty"`
	App              *string `protobuf:"bytes,2,req,name=app" json:"app,omitempty"`
	MarkChanges      *bool   `protobuf:"varint,3,opt,name=mark_changes,def=0" json:"mark_changes,omitempty"`
	XXX_unrecognized []byte  `json:",omitempty"`
}

func (*Transaction) Reset

func (this *Transaction) Reset()

func (*Transaction) String

func (this *Transaction) String() string

Jump to

Keyboard shortcuts

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