dataproc

package

Go to main page

Versions in this module

v1

v1.42.0

Jun 28, 2021

Changes in this version

+ type AutoscalingPolicyCallOptions struct

+ CreateAutoscalingPolicy []gax.CallOption

+ DeleteAutoscalingPolicy []gax.CallOption

+ GetAutoscalingPolicy []gax.CallOption

+ ListAutoscalingPolicies []gax.CallOption

+ UpdateAutoscalingPolicy []gax.CallOption

+ type AutoscalingPolicyClient struct

+ CallOptions *AutoscalingPolicyCallOptions

+ func NewAutoscalingPolicyClient(ctx context.Context, opts ...option.ClientOption) (*AutoscalingPolicyClient, error)

+ func (c *AutoscalingPolicyClient) Close() error

+ func (c *AutoscalingPolicyClient) Connection() *grpc.ClientConn

+ func (c *AutoscalingPolicyClient) CreateAutoscalingPolicy(ctx context.Context, req *dataprocpb.CreateAutoscalingPolicyRequest, ...) (*dataprocpb.AutoscalingPolicy, error)

+ func (c *AutoscalingPolicyClient) DeleteAutoscalingPolicy(ctx context.Context, req *dataprocpb.DeleteAutoscalingPolicyRequest, ...) error

+ func (c *AutoscalingPolicyClient) GetAutoscalingPolicy(ctx context.Context, req *dataprocpb.GetAutoscalingPolicyRequest, ...) (*dataprocpb.AutoscalingPolicy, error)

+ func (c *AutoscalingPolicyClient) ListAutoscalingPolicies(ctx context.Context, req *dataprocpb.ListAutoscalingPoliciesRequest, ...) *AutoscalingPolicyIterator

+ func (c *AutoscalingPolicyClient) UpdateAutoscalingPolicy(ctx context.Context, req *dataprocpb.UpdateAutoscalingPolicyRequest, ...) (*dataprocpb.AutoscalingPolicy, error)

+ type AutoscalingPolicyIterator struct

+ InternalFetch func(pageSize int, pageToken string) (results []*dataprocpb.AutoscalingPolicy, nextPageToken string, err error)

+ Response interface{}

+ func (it *AutoscalingPolicyIterator) Next() (*dataprocpb.AutoscalingPolicy, error)

+ func (it *AutoscalingPolicyIterator) PageInfo() *iterator.PageInfo

type ClusterIterator

+ Response interface{}

type JobControllerCallOptions

+ SubmitJobAsOperation []gax.CallOption

type JobControllerClient

+ LROClient *lroauto.OperationsClient

+ func (c *JobControllerClient) SubmitJobAsOperation(ctx context.Context, req *dataprocpb.SubmitJobRequest, opts ...gax.CallOption) (*SubmitJobAsOperationOperation, error)

+ func (c *JobControllerClient) SubmitJobAsOperationOperation(name string) *SubmitJobAsOperationOperation

type JobIterator

+ Response interface{}

+ type SubmitJobAsOperationOperation struct

+ func (op *SubmitJobAsOperationOperation) Done() bool

+ func (op *SubmitJobAsOperationOperation) Metadata() (*dataprocpb.JobMetadata, error)

+ func (op *SubmitJobAsOperationOperation) Name() string

+ func (op *SubmitJobAsOperationOperation) Poll(ctx context.Context, opts ...gax.CallOption) (*dataprocpb.Job, error)

+ func (op *SubmitJobAsOperationOperation) Wait(ctx context.Context, opts ...gax.CallOption) (*dataprocpb.Job, error)

type WorkflowTemplateIterator

+ Response interface{}

v0

v0.34.0

Dec 5, 2018

Changes in this version

+ type InstantiateInlineWorkflowTemplateOperation struct

+ func (op *InstantiateInlineWorkflowTemplateOperation) Cancel(ctx context.Context, opts ...gax.CallOption) error

+ func (op *InstantiateInlineWorkflowTemplateOperation) Delete(ctx context.Context, opts ...gax.CallOption) error

+ func (op *InstantiateInlineWorkflowTemplateOperation) Done() bool

+ func (op *InstantiateInlineWorkflowTemplateOperation) Metadata() (*dataprocpb.WorkflowMetadata, error)

+ func (op *InstantiateInlineWorkflowTemplateOperation) Name() string

+ func (op *InstantiateInlineWorkflowTemplateOperation) Poll(ctx context.Context, opts ...gax.CallOption) error

+ func (op *InstantiateInlineWorkflowTemplateOperation) Wait(ctx context.Context, opts ...gax.CallOption) error

type WorkflowTemplateCallOptions

+ InstantiateInlineWorkflowTemplate []gax.CallOption

type WorkflowTemplateClient

+ func (c *WorkflowTemplateClient) InstantiateInlineWorkflowTemplate(ctx context.Context, req *dataprocpb.InstantiateInlineWorkflowTemplateRequest, ...) (*InstantiateInlineWorkflowTemplateOperation, error)

+ func (c *WorkflowTemplateClient) InstantiateInlineWorkflowTemplateOperation(name string) *InstantiateInlineWorkflowTemplateOperation

v0.33.1

Nov 15, 2018

v0.33.0

Nov 13, 2018

v0.32.0

Oct 31, 2018

v0.31.0

Oct 23, 2018

v0.30.0

Oct 8, 2018

v0.29.0

Oct 3, 2018

v0.28.0

Sep 17, 2018

v0.27.0

Sep 4, 2018

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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL