type google.golang.org/genproto/googleapis/cloud/tasks/v2.Queue
70 uses
google.golang.org/genproto/googleapis/cloud/tasks/v2 (current package)
cloudtasks.pb.go#L159: Queues []*Queue `protobuf:"bytes,1,rep,name=queues,proto3" json:"queues,omitempty"`
cloudtasks.pb.go#L204: func (x *ListQueuesResponse) GetQueues() []*Queue {
cloudtasks.pb.go#L284: Queue *Queue `protobuf:"bytes,2,opt,name=queue,proto3" json:"queue,omitempty"`
cloudtasks.pb.go#L326: func (x *CreateQueueRequest) GetQueue() *Queue {
cloudtasks.pb.go#L346: Queue *Queue `protobuf:"bytes,1,opt,name=queue,proto3" json:"queue,omitempty"`
cloudtasks.pb.go#L385: func (x *UpdateQueueRequest) GetQueue() *Queue {
cloudtasks.pb.go#L1421: (*Queue)(nil), // 15: google.cloud.tasks.v2.Queue
cloudtasks.pb.go#L1708: GetQueue(ctx context.Context, in *GetQueueRequest, opts ...grpc.CallOption) (*Queue, error)
cloudtasks.pb.go#L1721: CreateQueue(ctx context.Context, in *CreateQueueRequest, opts ...grpc.CallOption) (*Queue, error)
cloudtasks.pb.go#L1737: UpdateQueue(ctx context.Context, in *UpdateQueueRequest, opts ...grpc.CallOption) (*Queue, error)
cloudtasks.pb.go#L1758: PurgeQueue(ctx context.Context, in *PurgeQueueRequest, opts ...grpc.CallOption) (*Queue, error)
cloudtasks.pb.go#L1766: PauseQueue(ctx context.Context, in *PauseQueueRequest, opts ...grpc.CallOption) (*Queue, error)
cloudtasks.pb.go#L1780: ResumeQueue(ctx context.Context, in *ResumeQueueRequest, opts ...grpc.CallOption) (*Queue, error)
cloudtasks.pb.go#L1879: func (c *cloudTasksClient) GetQueue(ctx context.Context, in *GetQueueRequest, opts ...grpc.CallOption) (*Queue, error) {
cloudtasks.pb.go#L1880: out := new(Queue)
cloudtasks.pb.go#L1888: func (c *cloudTasksClient) CreateQueue(ctx context.Context, in *CreateQueueRequest, opts ...grpc.CallOption) (*Queue, error) {
cloudtasks.pb.go#L1889: out := new(Queue)
cloudtasks.pb.go#L1897: func (c *cloudTasksClient) UpdateQueue(ctx context.Context, in *UpdateQueueRequest, opts ...grpc.CallOption) (*Queue, error) {
cloudtasks.pb.go#L1898: out := new(Queue)
cloudtasks.pb.go#L1915: func (c *cloudTasksClient) PurgeQueue(ctx context.Context, in *PurgeQueueRequest, opts ...grpc.CallOption) (*Queue, error) {
cloudtasks.pb.go#L1916: out := new(Queue)
cloudtasks.pb.go#L1924: func (c *cloudTasksClient) PauseQueue(ctx context.Context, in *PauseQueueRequest, opts ...grpc.CallOption) (*Queue, error) {
cloudtasks.pb.go#L1925: out := new(Queue)
cloudtasks.pb.go#L1933: func (c *cloudTasksClient) ResumeQueue(ctx context.Context, in *ResumeQueueRequest, opts ...grpc.CallOption) (*Queue, error) {
cloudtasks.pb.go#L1934: out := new(Queue)
cloudtasks.pb.go#L2021: GetQueue(context.Context, *GetQueueRequest) (*Queue, error)
cloudtasks.pb.go#L2034: CreateQueue(context.Context, *CreateQueueRequest) (*Queue, error)
cloudtasks.pb.go#L2050: UpdateQueue(context.Context, *UpdateQueueRequest) (*Queue, error)
cloudtasks.pb.go#L2071: PurgeQueue(context.Context, *PurgeQueueRequest) (*Queue, error)
cloudtasks.pb.go#L2079: PauseQueue(context.Context, *PauseQueueRequest) (*Queue, error)
cloudtasks.pb.go#L2093: ResumeQueue(context.Context, *ResumeQueueRequest) (*Queue, error)
cloudtasks.pb.go#L2182: func (*UnimplementedCloudTasksServer) GetQueue(context.Context, *GetQueueRequest) (*Queue, error) {
cloudtasks.pb.go#L2185: func (*UnimplementedCloudTasksServer) CreateQueue(context.Context, *CreateQueueRequest) (*Queue, error) {
cloudtasks.pb.go#L2188: func (*UnimplementedCloudTasksServer) UpdateQueue(context.Context, *UpdateQueueRequest) (*Queue, error) {
cloudtasks.pb.go#L2194: func (*UnimplementedCloudTasksServer) PurgeQueue(context.Context, *PurgeQueueRequest) (*Queue, error) {
cloudtasks.pb.go#L2197: func (*UnimplementedCloudTasksServer) PauseQueue(context.Context, *PauseQueueRequest) (*Queue, error) {
cloudtasks.pb.go#L2200: func (*UnimplementedCloudTasksServer) ResumeQueue(context.Context, *ResumeQueueRequest) (*Queue, error) {
queue.pb.go#L129: type Queue struct {
queue.pb.go#L227: func (x *Queue) Reset() {
queue.pb.go#L228: *x = Queue{}
queue.pb.go#L236: func (x *Queue) String() string {
queue.pb.go#L240: func (*Queue) ProtoMessage() {}
queue.pb.go#L242: func (x *Queue) ProtoReflect() protoreflect.Message {
queue.pb.go#L255: func (*Queue) Descriptor() ([]byte, []int) {
queue.pb.go#L259: func (x *Queue) GetName() string {
queue.pb.go#L266: func (x *Queue) GetAppEngineRoutingOverride() *AppEngineRouting {
queue.pb.go#L273: func (x *Queue) GetRateLimits() *RateLimits {
queue.pb.go#L280: func (x *Queue) GetRetryConfig() *RetryConfig {
queue.pb.go#L287: func (x *Queue) GetState() Queue_State {
queue.pb.go#L294: func (x *Queue) GetPurgeTime() *timestamppb.Timestamp {
queue.pb.go#L301: func (x *Queue) GetStackdriverLoggingConfig() *StackdriverLoggingConfig {
queue.pb.go#L776: (*Queue)(nil), // 1: google.cloud.tasks.v2.Queue
queue.pb.go#L809: switch v := v.(*Queue); i {
cloud.google.com/go/cloudtasks/apiv2
cloud_tasks_client.go#L266: it.InternalFetch = func(pageSize int, pageToken string) ([]*taskspb.Queue, string, error) {
cloud_tasks_client.go#L301: func (c *Client) GetQueue(ctx context.Context, req *taskspb.GetQueueRequest, opts ...gax.CallOption) (*taskspb.Queue, error) {
cloud_tasks_client.go#L310: var resp *taskspb.Queue
cloud_tasks_client.go#L334: func (c *Client) CreateQueue(ctx context.Context, req *taskspb.CreateQueueRequest, opts ...gax.CallOption) (*taskspb.Queue, error) {
cloud_tasks_client.go#L343: var resp *taskspb.Queue
cloud_tasks_client.go#L370: func (c *Client) UpdateQueue(ctx context.Context, req *taskspb.UpdateQueueRequest, opts ...gax.CallOption) (*taskspb.Queue, error) {
cloud_tasks_client.go#L379: var resp *taskspb.Queue
cloud_tasks_client.go#L427: func (c *Client) PurgeQueue(ctx context.Context, req *taskspb.PurgeQueueRequest, opts ...gax.CallOption) (*taskspb.Queue, error) {
cloud_tasks_client.go#L436: var resp *taskspb.Queue
cloud_tasks_client.go#L455: func (c *Client) PauseQueue(ctx context.Context, req *taskspb.PauseQueueRequest, opts ...gax.CallOption) (*taskspb.Queue, error) {
cloud_tasks_client.go#L464: var resp *taskspb.Queue
cloud_tasks_client.go#L489: func (c *Client) ResumeQueue(ctx context.Context, req *taskspb.ResumeQueueRequest, opts ...gax.CallOption) (*taskspb.Queue, error) {
cloud_tasks_client.go#L498: var resp *taskspb.Queue
cloud_tasks_client.go#L766: items []*taskspb.Queue
cloud_tasks_client.go#L781: InternalFetch func(pageSize int, pageToken string) (results []*taskspb.Queue, nextPageToken string, err error)
cloud_tasks_client.go#L791: func (it *QueueIterator) Next() (*taskspb.Queue, error) {
cloud_tasks_client.go#L792: var item *taskspb.Queue
 |
The pages are generated with Golds v0.3.2-preview. (GOOS=darwin GOARCH=amd64)
Golds is a Go 101 project developed by Tapir Liu.
PR and bug reports are welcome and can be submitted to the issue list.
Please follow @Go100and1 (reachable from the left QR code) to get the latest news of Golds. |