Documentation ¶
Index ¶
- Constants
- Variables
- type TaskPayload
- func (this *TaskPayload) ExtensionMap() map[int32]proto.Extension
- func (*TaskPayload) ExtensionRangeArray() []proto.ExtensionRange
- func (this *TaskPayload) Marshal() ([]byte, error)
- func (this *TaskPayload) Reset()
- func (this *TaskPayload) String() string
- func (this *TaskPayload) Unmarshal(buf []byte) error
- type TaskQueueAcl
- type TaskQueueAddRequest
- type TaskQueueAddRequest_CronTimetable
- type TaskQueueAddRequest_Header
- type TaskQueueAddRequest_RequestMethod
- type TaskQueueAddResponse
- type TaskQueueBulkAddRequest
- type TaskQueueBulkAddResponse
- type TaskQueueBulkAddResponse_TaskResult
- type TaskQueueDeleteGroupRequest
- type TaskQueueDeleteGroupResponse
- type TaskQueueDeleteQueueRequest
- type TaskQueueDeleteQueueResponse
- type TaskQueueDeleteRequest
- type TaskQueueDeleteResponse
- type TaskQueueFetchQueueStatsRequest
- type TaskQueueFetchQueueStatsResponse
- type TaskQueueFetchQueueStatsResponse_QueueStats
- type TaskQueueFetchQueuesRequest
- type TaskQueueFetchQueuesResponse
- type TaskQueueFetchQueuesResponse_Queue
- type TaskQueueFetchTaskRequest
- type TaskQueueFetchTaskResponse
- type TaskQueueForceRunRequest
- type TaskQueueForceRunResponse
- type TaskQueueHttpHeader
- type TaskQueueMode
- type TaskQueueMode_Mode
- type TaskQueueModifyTaskLeaseRequest
- type TaskQueueModifyTaskLeaseResponse
- type TaskQueuePauseQueueRequest
- type TaskQueuePauseQueueResponse
- type TaskQueuePurgeQueueRequest
- type TaskQueuePurgeQueueResponse
- type TaskQueueQueryAndOwnTasksRequest
- type TaskQueueQueryAndOwnTasksResponse
- type TaskQueueQueryAndOwnTasksResponse_Task
- type TaskQueueQueryTasksRequest
- type TaskQueueQueryTasksResponse
- type TaskQueueQueryTasksResponse_Task
- type TaskQueueQueryTasksResponse_Task_CronTimetable
- type TaskQueueQueryTasksResponse_Task_Header
- type TaskQueueQueryTasksResponse_Task_RequestMethod
- type TaskQueueQueryTasksResponse_Task_RunLog
- type TaskQueueRetryParameters
- type TaskQueueScannerQueueInfo
- type TaskQueueServiceError
- type TaskQueueServiceError_ErrorCode
- type TaskQueueUpdateQueueRequest
- type TaskQueueUpdateQueueResponse
- type TaskQueueUpdateStorageLimitRequest
- type TaskQueueUpdateStorageLimitResponse
- type Transaction
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 ¶
func (this *TaskQueueAddRequest_CronTimetable) String() 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 NewTaskQueueAddRequest_RequestMethod ¶
func NewTaskQueueAddRequest_RequestMethod(x TaskQueueAddRequest_RequestMethod) *TaskQueueAddRequest_RequestMethod
func (TaskQueueAddRequest_RequestMethod) String ¶
func (x TaskQueueAddRequest_RequestMethod) String() 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 (this *TaskQueueBulkAddResponse_TaskResult) Reset()
func (*TaskQueueBulkAddResponse_TaskResult) String ¶
func (this *TaskQueueBulkAddResponse_TaskResult) String() 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 ¶
func (this *TaskQueueFetchQueueStatsResponse) String() 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 (this *TaskQueueFetchQueueStatsResponse_QueueStats) Reset()
func (*TaskQueueFetchQueueStatsResponse_QueueStats) String ¶
func (this *TaskQueueFetchQueueStatsResponse_QueueStats) String() 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 ¶
func (this *TaskQueueFetchQueuesResponse_Queue) String() 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 ¶
func (this *TaskQueueModifyTaskLeaseResponse) String() 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 ¶
func (this *TaskQueueQueryAndOwnTasksRequest) String() 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 ¶
func (this *TaskQueueQueryAndOwnTasksResponse) String() 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 (this *TaskQueueQueryAndOwnTasksResponse_Task) Reset()
func (*TaskQueueQueryAndOwnTasksResponse_Task) String ¶
func (this *TaskQueueQueryAndOwnTasksResponse_Task) String() 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 ¶
func (this *TaskQueueQueryTasksResponse_Task) String() 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 (this *TaskQueueQueryTasksResponse_Task_CronTimetable) Reset()
func (*TaskQueueQueryTasksResponse_Task_CronTimetable) String ¶
func (this *TaskQueueQueryTasksResponse_Task_CronTimetable) String() 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 (this *TaskQueueQueryTasksResponse_Task_Header) Reset()
func (*TaskQueueQueryTasksResponse_Task_Header) String ¶
func (this *TaskQueueQueryTasksResponse_Task_Header) String() 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 NewTaskQueueQueryTasksResponse_Task_RequestMethod ¶
func NewTaskQueueQueryTasksResponse_Task_RequestMethod(x TaskQueueQueryTasksResponse_Task_RequestMethod) *TaskQueueQueryTasksResponse_Task_RequestMethod
func (TaskQueueQueryTasksResponse_Task_RequestMethod) String ¶
func (x TaskQueueQueryTasksResponse_Task_RequestMethod) String() 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 (this *TaskQueueQueryTasksResponse_Task_RunLog) Reset()
func (*TaskQueueQueryTasksResponse_Task_RunLog) String ¶
func (this *TaskQueueQueryTasksResponse_Task_RunLog) String() 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 NewTaskQueueServiceError_ErrorCode ¶
func NewTaskQueueServiceError_ErrorCode(x TaskQueueServiceError_ErrorCode) *TaskQueueServiceError_ErrorCode
func (TaskQueueServiceError_ErrorCode) String ¶
func (x TaskQueueServiceError_ErrorCode) String() 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 ¶
func (this *TaskQueueUpdateStorageLimitRequest) String() 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 (this *TaskQueueUpdateStorageLimitResponse) Reset()
func (*TaskQueueUpdateStorageLimitResponse) String ¶
func (this *TaskQueueUpdateStorageLimitResponse) String() 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
Click to show internal directories.
Click to hide internal directories.