Versions in this module Expand all Collapse all v0 v0.26.0 Aug 7, 2018 Changes in this version + func DefaultAuthScopes() []string + type ClusterControllerCallOptions struct + CreateCluster []gax.CallOption + DeleteCluster []gax.CallOption + DiagnoseCluster []gax.CallOption + GetCluster []gax.CallOption + ListClusters []gax.CallOption + UpdateCluster []gax.CallOption + type ClusterControllerClient struct + CallOptions *ClusterControllerCallOptions + LROClient *lroauto.OperationsClient + func NewClusterControllerClient(ctx context.Context, opts ...option.ClientOption) (*ClusterControllerClient, error) + func (c *ClusterControllerClient) Close() error + func (c *ClusterControllerClient) Connection() *grpc.ClientConn + func (c *ClusterControllerClient) CreateCluster(ctx context.Context, req *dataprocpb.CreateClusterRequest, ...) (*CreateClusterOperation, error) + func (c *ClusterControllerClient) CreateClusterOperation(name string) *CreateClusterOperation + func (c *ClusterControllerClient) DeleteCluster(ctx context.Context, req *dataprocpb.DeleteClusterRequest, ...) (*DeleteClusterOperation, error) + func (c *ClusterControllerClient) DeleteClusterOperation(name string) *DeleteClusterOperation + func (c *ClusterControllerClient) DiagnoseCluster(ctx context.Context, req *dataprocpb.DiagnoseClusterRequest, ...) (*DiagnoseClusterOperation, error) + func (c *ClusterControllerClient) DiagnoseClusterOperation(name string) *DiagnoseClusterOperation + func (c *ClusterControllerClient) GetCluster(ctx context.Context, req *dataprocpb.GetClusterRequest, opts ...gax.CallOption) (*dataprocpb.Cluster, error) + func (c *ClusterControllerClient) ListClusters(ctx context.Context, req *dataprocpb.ListClustersRequest, ...) *ClusterIterator + func (c *ClusterControllerClient) UpdateCluster(ctx context.Context, req *dataprocpb.UpdateClusterRequest, ...) (*UpdateClusterOperation, error) + func (c *ClusterControllerClient) UpdateClusterOperation(name string) *UpdateClusterOperation + type ClusterIterator struct + InternalFetch func(pageSize int, pageToken string) (results []*dataprocpb.Cluster, nextPageToken string, err error) + func (it *ClusterIterator) Next() (*dataprocpb.Cluster, error) + func (it *ClusterIterator) PageInfo() *iterator.PageInfo + type CreateClusterOperation struct + func (op *CreateClusterOperation) Delete(ctx context.Context, opts ...gax.CallOption) error + func (op *CreateClusterOperation) Done() bool + func (op *CreateClusterOperation) Metadata() (*dataprocpb.ClusterOperationMetadata, error) + func (op *CreateClusterOperation) Name() string + func (op *CreateClusterOperation) Poll(ctx context.Context, opts ...gax.CallOption) (*dataprocpb.Cluster, error) + func (op *CreateClusterOperation) Wait(ctx context.Context, opts ...gax.CallOption) (*dataprocpb.Cluster, error) + type DeleteClusterOperation struct + func (op *DeleteClusterOperation) Delete(ctx context.Context, opts ...gax.CallOption) error + func (op *DeleteClusterOperation) Done() bool + func (op *DeleteClusterOperation) Metadata() (*dataprocpb.ClusterOperationMetadata, error) + func (op *DeleteClusterOperation) Name() string + func (op *DeleteClusterOperation) Poll(ctx context.Context, opts ...gax.CallOption) error + func (op *DeleteClusterOperation) Wait(ctx context.Context, opts ...gax.CallOption) error + type DiagnoseClusterOperation struct + func (op *DiagnoseClusterOperation) Delete(ctx context.Context, opts ...gax.CallOption) error + func (op *DiagnoseClusterOperation) Done() bool + func (op *DiagnoseClusterOperation) Metadata() (*dataprocpb.DiagnoseClusterResults, error) + func (op *DiagnoseClusterOperation) Name() string + func (op *DiagnoseClusterOperation) Poll(ctx context.Context, opts ...gax.CallOption) error + func (op *DiagnoseClusterOperation) Wait(ctx context.Context, opts ...gax.CallOption) error + type InstantiateWorkflowTemplateOperation struct + func (op *InstantiateWorkflowTemplateOperation) Cancel(ctx context.Context, opts ...gax.CallOption) error + func (op *InstantiateWorkflowTemplateOperation) Delete(ctx context.Context, opts ...gax.CallOption) error + func (op *InstantiateWorkflowTemplateOperation) Done() bool + func (op *InstantiateWorkflowTemplateOperation) Metadata() (*dataprocpb.WorkflowMetadata, error) + func (op *InstantiateWorkflowTemplateOperation) Name() string + func (op *InstantiateWorkflowTemplateOperation) Poll(ctx context.Context, opts ...gax.CallOption) error + func (op *InstantiateWorkflowTemplateOperation) Wait(ctx context.Context, opts ...gax.CallOption) error + type JobControllerCallOptions struct + CancelJob []gax.CallOption + DeleteJob []gax.CallOption + GetJob []gax.CallOption + ListJobs []gax.CallOption + SubmitJob []gax.CallOption + UpdateJob []gax.CallOption + type JobControllerClient struct + CallOptions *JobControllerCallOptions + func NewJobControllerClient(ctx context.Context, opts ...option.ClientOption) (*JobControllerClient, error) + func (c *JobControllerClient) CancelJob(ctx context.Context, req *dataprocpb.CancelJobRequest, opts ...gax.CallOption) (*dataprocpb.Job, error) + func (c *JobControllerClient) Close() error + func (c *JobControllerClient) Connection() *grpc.ClientConn + func (c *JobControllerClient) DeleteJob(ctx context.Context, req *dataprocpb.DeleteJobRequest, opts ...gax.CallOption) error + func (c *JobControllerClient) GetJob(ctx context.Context, req *dataprocpb.GetJobRequest, opts ...gax.CallOption) (*dataprocpb.Job, error) + func (c *JobControllerClient) ListJobs(ctx context.Context, req *dataprocpb.ListJobsRequest, opts ...gax.CallOption) *JobIterator + func (c *JobControllerClient) SubmitJob(ctx context.Context, req *dataprocpb.SubmitJobRequest, opts ...gax.CallOption) (*dataprocpb.Job, error) + func (c *JobControllerClient) UpdateJob(ctx context.Context, req *dataprocpb.UpdateJobRequest, opts ...gax.CallOption) (*dataprocpb.Job, error) + type JobIterator struct + InternalFetch func(pageSize int, pageToken string) (results []*dataprocpb.Job, nextPageToken string, err error) + func (it *JobIterator) Next() (*dataprocpb.Job, error) + func (it *JobIterator) PageInfo() *iterator.PageInfo + type UpdateClusterOperation struct + func (op *UpdateClusterOperation) Delete(ctx context.Context, opts ...gax.CallOption) error + func (op *UpdateClusterOperation) Done() bool + func (op *UpdateClusterOperation) Metadata() (*dataprocpb.ClusterOperationMetadata, error) + func (op *UpdateClusterOperation) Name() string + func (op *UpdateClusterOperation) Poll(ctx context.Context, opts ...gax.CallOption) (*dataprocpb.Cluster, error) + func (op *UpdateClusterOperation) Wait(ctx context.Context, opts ...gax.CallOption) (*dataprocpb.Cluster, error) + type WorkflowTemplateCallOptions struct + CreateWorkflowTemplate []gax.CallOption + DeleteWorkflowTemplate []gax.CallOption + GetWorkflowTemplate []gax.CallOption + InstantiateWorkflowTemplate []gax.CallOption + ListWorkflowTemplates []gax.CallOption + UpdateWorkflowTemplate []gax.CallOption + type WorkflowTemplateClient struct + CallOptions *WorkflowTemplateCallOptions + LROClient *lroauto.OperationsClient + func NewWorkflowTemplateClient(ctx context.Context, opts ...option.ClientOption) (*WorkflowTemplateClient, error) + func (c *WorkflowTemplateClient) Close() error + func (c *WorkflowTemplateClient) Connection() *grpc.ClientConn + func (c *WorkflowTemplateClient) CreateWorkflowTemplate(ctx context.Context, req *dataprocpb.CreateWorkflowTemplateRequest, ...) (*dataprocpb.WorkflowTemplate, error) + func (c *WorkflowTemplateClient) DeleteWorkflowTemplate(ctx context.Context, req *dataprocpb.DeleteWorkflowTemplateRequest, ...) error + func (c *WorkflowTemplateClient) GetWorkflowTemplate(ctx context.Context, req *dataprocpb.GetWorkflowTemplateRequest, ...) (*dataprocpb.WorkflowTemplate, error) + func (c *WorkflowTemplateClient) InstantiateWorkflowTemplate(ctx context.Context, req *dataprocpb.InstantiateWorkflowTemplateRequest, ...) (*InstantiateWorkflowTemplateOperation, error) + func (c *WorkflowTemplateClient) InstantiateWorkflowTemplateOperation(name string) *InstantiateWorkflowTemplateOperation + func (c *WorkflowTemplateClient) ListWorkflowTemplates(ctx context.Context, req *dataprocpb.ListWorkflowTemplatesRequest, ...) *WorkflowTemplateIterator + func (c *WorkflowTemplateClient) UpdateWorkflowTemplate(ctx context.Context, req *dataprocpb.UpdateWorkflowTemplateRequest, ...) (*dataprocpb.WorkflowTemplate, error) + type WorkflowTemplateIterator struct + InternalFetch func(pageSize int, pageToken string) (results []*dataprocpb.WorkflowTemplate, nextPageToken string, err error) + func (it *WorkflowTemplateIterator) Next() (*dataprocpb.WorkflowTemplate, error) + func (it *WorkflowTemplateIterator) PageInfo() *iterator.PageInfo
Go to main page