Versions in this module Expand all Collapse all v0 v0.27.0 Sep 4, 2018 Changes in this version + func DefaultAuthScopes() []string + type CallOptions struct + CreateQueue []gax.CallOption + CreateTask []gax.CallOption + DeleteQueue []gax.CallOption + DeleteTask []gax.CallOption + GetIamPolicy []gax.CallOption + GetQueue []gax.CallOption + GetTask []gax.CallOption + ListQueues []gax.CallOption + ListTasks []gax.CallOption + PauseQueue []gax.CallOption + PurgeQueue []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) 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) 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) 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