Versions in this module Expand all Collapse all v0 v0.23.0 May 18, 2018 Changes in this version + func DefaultAuthScopes() []string + type CallOptions struct + AcknowledgeTask []gax.CallOption + CancelLease []gax.CallOption + CreateQueue []gax.CallOption + CreateTask []gax.CallOption + DeleteQueue []gax.CallOption + DeleteTask []gax.CallOption + GetIamPolicy []gax.CallOption + GetQueue []gax.CallOption + GetTask []gax.CallOption + LeaseTasks []gax.CallOption + ListQueues []gax.CallOption + ListTasks []gax.CallOption + PauseQueue []gax.CallOption + PurgeQueue []gax.CallOption + RenewLease []gax.CallOption + ResumeQueue []gax.CallOption + RunTask []gax.CallOption + SetIamPolicy []gax.CallOption + TestIamPermissions []gax.CallOption + UpdateQueue []gax.CallOption + type Client struct + CallOptions *CallOptions + func NewClient(ctx context.Context, opts ...option.ClientOption) (*Client, error) + func (c *Client) AcknowledgeTask(ctx context.Context, req *taskspb.AcknowledgeTaskRequest, ...) error + func (c *Client) CancelLease(ctx context.Context, req *taskspb.CancelLeaseRequest, opts ...gax.CallOption) (*taskspb.Task, error) + func (c *Client) Close() error + func (c *Client) Connection() *grpc.ClientConn + func (c *Client) CreateQueue(ctx context.Context, req *taskspb.CreateQueueRequest, opts ...gax.CallOption) (*taskspb.Queue, error) + func (c *Client) CreateTask(ctx context.Context, req *taskspb.CreateTaskRequest, opts ...gax.CallOption) (*taskspb.Task, error) + func (c *Client) DeleteQueue(ctx context.Context, req *taskspb.DeleteQueueRequest, opts ...gax.CallOption) error + func (c *Client) DeleteTask(ctx context.Context, req *taskspb.DeleteTaskRequest, opts ...gax.CallOption) error + func (c *Client) GetIamPolicy(ctx context.Context, req *iampb.GetIamPolicyRequest, opts ...gax.CallOption) (*iampb.Policy, error) + func (c *Client) GetQueue(ctx context.Context, req *taskspb.GetQueueRequest, opts ...gax.CallOption) (*taskspb.Queue, error) + func (c *Client) GetTask(ctx context.Context, req *taskspb.GetTaskRequest, opts ...gax.CallOption) (*taskspb.Task, error) + func (c *Client) LeaseTasks(ctx context.Context, req *taskspb.LeaseTasksRequest, opts ...gax.CallOption) (*taskspb.LeaseTasksResponse, error) + func (c *Client) ListQueues(ctx context.Context, req *taskspb.ListQueuesRequest, opts ...gax.CallOption) *QueueIterator + func (c *Client) ListTasks(ctx context.Context, req *taskspb.ListTasksRequest, opts ...gax.CallOption) *TaskIterator + func (c *Client) PauseQueue(ctx context.Context, req *taskspb.PauseQueueRequest, opts ...gax.CallOption) (*taskspb.Queue, error) + func (c *Client) PurgeQueue(ctx context.Context, req *taskspb.PurgeQueueRequest, opts ...gax.CallOption) (*taskspb.Queue, error) + func (c *Client) RenewLease(ctx context.Context, req *taskspb.RenewLeaseRequest, opts ...gax.CallOption) (*taskspb.Task, error) + func (c *Client) ResumeQueue(ctx context.Context, req *taskspb.ResumeQueueRequest, opts ...gax.CallOption) (*taskspb.Queue, error) + func (c *Client) RunTask(ctx context.Context, req *taskspb.RunTaskRequest, opts ...gax.CallOption) (*taskspb.Task, error) + func (c *Client) SetIamPolicy(ctx context.Context, req *iampb.SetIamPolicyRequest, opts ...gax.CallOption) (*iampb.Policy, error) + func (c *Client) TestIamPermissions(ctx context.Context, req *iampb.TestIamPermissionsRequest, ...) (*iampb.TestIamPermissionsResponse, error) + func (c *Client) UpdateQueue(ctx context.Context, req *taskspb.UpdateQueueRequest, opts ...gax.CallOption) (*taskspb.Queue, error) + type QueueIterator struct + InternalFetch func(pageSize int, pageToken string) (results []*taskspb.Queue, nextPageToken string, err error) + func (it *QueueIterator) Next() (*taskspb.Queue, error) + func (it *QueueIterator) PageInfo() *iterator.PageInfo + type TaskIterator struct + InternalFetch func(pageSize int, pageToken string) (results []*taskspb.Task, nextPageToken string, err error) + func (it *TaskIterator) Next() (*taskspb.Task, error) + func (it *TaskIterator) PageInfo() *iterator.PageInfo
Go to main page