dataproc

package

Go to main page

Versions in this module

v1

v1.12.0

Jan 26, 2023

v1.9.0

Jan 5, 2023

Changes in this version

type AutoscalingPolicyClient

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

type BatchControllerClient

+ func NewBatchControllerRESTClient(ctx context.Context, opts ...option.ClientOption) (*BatchControllerClient, error)

type ClusterControllerClient

+ func NewClusterControllerRESTClient(ctx context.Context, opts ...option.ClientOption) (*ClusterControllerClient, error)

+ type CreateNodeGroupOperation struct

+ func (op *CreateNodeGroupOperation) Done() bool

+ func (op *CreateNodeGroupOperation) Metadata() (*dataprocpb.NodeGroupOperationMetadata, error)

+ func (op *CreateNodeGroupOperation) Name() string

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

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

type JobControllerClient

+ func NewJobControllerRESTClient(ctx context.Context, opts ...option.ClientOption) (*JobControllerClient, error)

+ type NodeGroupControllerCallOptions struct

+ CreateNodeGroup []gax.CallOption

+ GetNodeGroup []gax.CallOption

+ ResizeNodeGroup []gax.CallOption

+ type NodeGroupControllerClient struct

+ CallOptions *NodeGroupControllerCallOptions

+ LROClient *lroauto.OperationsClient

+ func NewNodeGroupControllerClient(ctx context.Context, opts ...option.ClientOption) (*NodeGroupControllerClient, error)

+ func NewNodeGroupControllerRESTClient(ctx context.Context, opts ...option.ClientOption) (*NodeGroupControllerClient, error)

+ func (c *NodeGroupControllerClient) Close() error

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

+ func (c *NodeGroupControllerClient) CreateNodeGroup(ctx context.Context, req *dataprocpb.CreateNodeGroupRequest, ...) (*CreateNodeGroupOperation, error)

+ func (c *NodeGroupControllerClient) CreateNodeGroupOperation(name string) *CreateNodeGroupOperation

+ func (c *NodeGroupControllerClient) GetNodeGroup(ctx context.Context, req *dataprocpb.GetNodeGroupRequest, ...) (*dataprocpb.NodeGroup, error)

+ func (c *NodeGroupControllerClient) ResizeNodeGroup(ctx context.Context, req *dataprocpb.ResizeNodeGroupRequest, ...) (*ResizeNodeGroupOperation, error)

+ func (c *NodeGroupControllerClient) ResizeNodeGroupOperation(name string) *ResizeNodeGroupOperation

+ type ResizeNodeGroupOperation struct

+ func (op *ResizeNodeGroupOperation) Done() bool

+ func (op *ResizeNodeGroupOperation) Metadata() (*dataprocpb.NodeGroupOperationMetadata, error)

+ func (op *ResizeNodeGroupOperation) Name() string

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

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

type WorkflowTemplateClient

+ func NewWorkflowTemplateRESTClient(ctx context.Context, opts ...option.ClientOption) (*WorkflowTemplateClient, error)

v1.8.0

Nov 3, 2022

v1.7.0

Oct 25, 2022

v1.6.0

Sep 28, 2022

v1.5.0

Feb 23, 2022

v1.4.0

Feb 22, 2022

v1.3.0

Feb 14, 2022

v1.2.0

Nov 2, 2021

v1.1.0

Oct 18, 2021

Changes in this version

+ type BatchControllerCallOptions struct

+ CreateBatch []gax.CallOption

+ DeleteBatch []gax.CallOption

+ GetBatch []gax.CallOption

+ ListBatches []gax.CallOption

+ type BatchControllerClient struct

+ CallOptions *BatchControllerCallOptions

+ LROClient *lroauto.OperationsClient

+ func NewBatchControllerClient(ctx context.Context, opts ...option.ClientOption) (*BatchControllerClient, error)

+ func (c *BatchControllerClient) Close() error

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

+ func (c *BatchControllerClient) CreateBatch(ctx context.Context, req *dataprocpb.CreateBatchRequest, ...) (*CreateBatchOperation, error)

+ func (c *BatchControllerClient) CreateBatchOperation(name string) *CreateBatchOperation

+ func (c *BatchControllerClient) DeleteBatch(ctx context.Context, req *dataprocpb.DeleteBatchRequest, ...) error

+ func (c *BatchControllerClient) GetBatch(ctx context.Context, req *dataprocpb.GetBatchRequest, opts ...gax.CallOption) (*dataprocpb.Batch, error)

+ func (c *BatchControllerClient) ListBatches(ctx context.Context, req *dataprocpb.ListBatchesRequest, ...) *BatchIterator

+ type BatchIterator struct

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

+ Response interface{}

+ func (it *BatchIterator) Next() (*dataprocpb.Batch, error)

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

+ type CreateBatchOperation struct

+ func (op *CreateBatchOperation) Done() bool

+ func (op *CreateBatchOperation) Metadata() (*dataprocpb.BatchOperationMetadata, error)

+ func (op *CreateBatchOperation) Name() string

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

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

v1.0.0

Sep 23, 2021

v0

v0.2.0

Sep 12, 2021

v0.1.0

Aug 16, 2021

Changes in this version

+ func DefaultAuthScopes() []string

+ 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 ClusterControllerCallOptions struct

+ CreateCluster []gax.CallOption

+ DeleteCluster []gax.CallOption

+ DiagnoseCluster []gax.CallOption

+ GetCluster []gax.CallOption

+ ListClusters []gax.CallOption

+ StartCluster []gax.CallOption

+ StopCluster []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) StartCluster(ctx context.Context, req *dataprocpb.StartClusterRequest, ...) (*StartClusterOperation, error)

+ func (c *ClusterControllerClient) StartClusterOperation(name string) *StartClusterOperation

+ func (c *ClusterControllerClient) StopCluster(ctx context.Context, req *dataprocpb.StopClusterRequest, ...) (*StopClusterOperation, error)

+ func (c *ClusterControllerClient) StopClusterOperation(name string) *StopClusterOperation

+ 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)

+ Response interface{}

+ 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.ClusterOperationMetadata, error)

+ func (op *DiagnoseClusterOperation) Name() string

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

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

+ 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 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

+ SubmitJobAsOperation []gax.CallOption

+ UpdateJob []gax.CallOption

+ type JobControllerClient struct

+ CallOptions *JobControllerCallOptions

+ LROClient *lroauto.OperationsClient

+ 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) SubmitJobAsOperation(ctx context.Context, req *dataprocpb.SubmitJobRequest, opts ...gax.CallOption) (*SubmitJobAsOperationOperation, error)

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

+ 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)

+ Response interface{}

+ func (it *JobIterator) Next() (*dataprocpb.Job, error)

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

+ type StartClusterOperation struct

+ func (op *StartClusterOperation) Done() bool

+ func (op *StartClusterOperation) Metadata() (*dataprocpb.ClusterOperationMetadata, error)

+ func (op *StartClusterOperation) Name() string

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

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

+ type StopClusterOperation struct

+ func (op *StopClusterOperation) Done() bool

+ func (op *StopClusterOperation) Metadata() (*dataprocpb.ClusterOperationMetadata, error)

+ func (op *StopClusterOperation) Name() string

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

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

+ 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 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

+ InstantiateInlineWorkflowTemplate []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) InstantiateInlineWorkflowTemplate(ctx context.Context, req *dataprocpb.InstantiateInlineWorkflowTemplateRequest, ...) (*InstantiateInlineWorkflowTemplateOperation, error)

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

+ 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)

+ Response interface{}

+ func (it *WorkflowTemplateIterator) Next() (*dataprocpb.WorkflowTemplate, error)

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

Other modules containing this package

cloud.google.com/go

cloud.google.com/go/dataproc/v2

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