Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

dataproc

package

Go to main page

Versions in this module

v2

v2.4.2

May 1, 2024

v2.4.1

Mar 14, 2024

v2.4.0

Jan 30, 2024

Changes in this version

+ type CreateSessionOperation struct

+ func (op *CreateSessionOperation) Done() bool

+ func (op *CreateSessionOperation) Metadata() (*dataprocpb.SessionOperationMetadata, error)

+ func (op *CreateSessionOperation) Name() string

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

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

+ type DeleteSessionOperation struct

+ func (op *DeleteSessionOperation) Done() bool

+ func (op *DeleteSessionOperation) Metadata() (*dataprocpb.SessionOperationMetadata, error)

+ func (op *DeleteSessionOperation) Name() string

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

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

+ type SessionControllerCallOptions struct

+ CancelOperation []gax.CallOption

+ CreateSession []gax.CallOption

+ DeleteOperation []gax.CallOption

+ DeleteSession []gax.CallOption

+ GetIamPolicy []gax.CallOption

+ GetOperation []gax.CallOption

+ GetSession []gax.CallOption

+ ListOperations []gax.CallOption

+ ListSessions []gax.CallOption

+ SetIamPolicy []gax.CallOption

+ TerminateSession []gax.CallOption

+ TestIamPermissions []gax.CallOption

+ type SessionControllerClient struct

+ CallOptions *SessionControllerCallOptions

+ LROClient *lroauto.OperationsClient

+ func NewSessionControllerClient(ctx context.Context, opts ...option.ClientOption) (*SessionControllerClient, error)

+ func NewSessionControllerRESTClient(ctx context.Context, opts ...option.ClientOption) (*SessionControllerClient, error)

+ func (c *SessionControllerClient) CancelOperation(ctx context.Context, req *longrunningpb.CancelOperationRequest, ...) error

+ func (c *SessionControllerClient) Close() error

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

+ func (c *SessionControllerClient) CreateSession(ctx context.Context, req *dataprocpb.CreateSessionRequest, ...) (*CreateSessionOperation, error)

+ func (c *SessionControllerClient) CreateSessionOperation(name string) *CreateSessionOperation

+ func (c *SessionControllerClient) DeleteOperation(ctx context.Context, req *longrunningpb.DeleteOperationRequest, ...) error

+ func (c *SessionControllerClient) DeleteSession(ctx context.Context, req *dataprocpb.DeleteSessionRequest, ...) (*DeleteSessionOperation, error)

+ func (c *SessionControllerClient) DeleteSessionOperation(name string) *DeleteSessionOperation

+ func (c *SessionControllerClient) GetIamPolicy(ctx context.Context, req *iampb.GetIamPolicyRequest, opts ...gax.CallOption) (*iampb.Policy, error)

+ func (c *SessionControllerClient) GetOperation(ctx context.Context, req *longrunningpb.GetOperationRequest, ...) (*longrunningpb.Operation, error)

+ func (c *SessionControllerClient) GetSession(ctx context.Context, req *dataprocpb.GetSessionRequest, opts ...gax.CallOption) (*dataprocpb.Session, error)

+ func (c *SessionControllerClient) ListOperations(ctx context.Context, req *longrunningpb.ListOperationsRequest, ...) *OperationIterator

+ func (c *SessionControllerClient) ListSessions(ctx context.Context, req *dataprocpb.ListSessionsRequest, ...) *SessionIterator

+ func (c *SessionControllerClient) SetIamPolicy(ctx context.Context, req *iampb.SetIamPolicyRequest, opts ...gax.CallOption) (*iampb.Policy, error)

+ func (c *SessionControllerClient) TerminateSession(ctx context.Context, req *dataprocpb.TerminateSessionRequest, ...) (*TerminateSessionOperation, error)

+ func (c *SessionControllerClient) TerminateSessionOperation(name string) *TerminateSessionOperation

+ func (c *SessionControllerClient) TestIamPermissions(ctx context.Context, req *iampb.TestIamPermissionsRequest, ...) (*iampb.TestIamPermissionsResponse, error)

+ type SessionIterator struct

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

+ Response interface{}

+ func (it *SessionIterator) Next() (*dataprocpb.Session, error)

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

+ type SessionTemplateControllerCallOptions struct

+ CancelOperation []gax.CallOption

+ CreateSessionTemplate []gax.CallOption

+ DeleteOperation []gax.CallOption

+ DeleteSessionTemplate []gax.CallOption

+ GetIamPolicy []gax.CallOption

+ GetOperation []gax.CallOption

+ GetSessionTemplate []gax.CallOption

+ ListOperations []gax.CallOption

+ ListSessionTemplates []gax.CallOption

+ SetIamPolicy []gax.CallOption

+ TestIamPermissions []gax.CallOption

+ UpdateSessionTemplate []gax.CallOption

+ type SessionTemplateControllerClient struct

+ CallOptions *SessionTemplateControllerCallOptions

+ func NewSessionTemplateControllerClient(ctx context.Context, opts ...option.ClientOption) (*SessionTemplateControllerClient, error)

+ func NewSessionTemplateControllerRESTClient(ctx context.Context, opts ...option.ClientOption) (*SessionTemplateControllerClient, error)

+ func (c *SessionTemplateControllerClient) CancelOperation(ctx context.Context, req *longrunningpb.CancelOperationRequest, ...) error

+ func (c *SessionTemplateControllerClient) Close() error

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

+ func (c *SessionTemplateControllerClient) CreateSessionTemplate(ctx context.Context, req *dataprocpb.CreateSessionTemplateRequest, ...) (*dataprocpb.SessionTemplate, error)

+ func (c *SessionTemplateControllerClient) DeleteOperation(ctx context.Context, req *longrunningpb.DeleteOperationRequest, ...) error

+ func (c *SessionTemplateControllerClient) DeleteSessionTemplate(ctx context.Context, req *dataprocpb.DeleteSessionTemplateRequest, ...) error

+ func (c *SessionTemplateControllerClient) GetIamPolicy(ctx context.Context, req *iampb.GetIamPolicyRequest, opts ...gax.CallOption) (*iampb.Policy, error)

+ func (c *SessionTemplateControllerClient) GetOperation(ctx context.Context, req *longrunningpb.GetOperationRequest, ...) (*longrunningpb.Operation, error)

+ func (c *SessionTemplateControllerClient) GetSessionTemplate(ctx context.Context, req *dataprocpb.GetSessionTemplateRequest, ...) (*dataprocpb.SessionTemplate, error)

+ func (c *SessionTemplateControllerClient) ListOperations(ctx context.Context, req *longrunningpb.ListOperationsRequest, ...) *OperationIterator

+ func (c *SessionTemplateControllerClient) ListSessionTemplates(ctx context.Context, req *dataprocpb.ListSessionTemplatesRequest, ...) *SessionTemplateIterator

+ func (c *SessionTemplateControllerClient) SetIamPolicy(ctx context.Context, req *iampb.SetIamPolicyRequest, opts ...gax.CallOption) (*iampb.Policy, error)

+ func (c *SessionTemplateControllerClient) TestIamPermissions(ctx context.Context, req *iampb.TestIamPermissionsRequest, ...) (*iampb.TestIamPermissionsResponse, error)

+ func (c *SessionTemplateControllerClient) UpdateSessionTemplate(ctx context.Context, req *dataprocpb.UpdateSessionTemplateRequest, ...) (*dataprocpb.SessionTemplate, error)

+ type SessionTemplateIterator struct

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

+ Response interface{}

+ func (it *SessionTemplateIterator) Next() (*dataprocpb.SessionTemplate, error)

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

+ type TerminateSessionOperation struct

+ func (op *TerminateSessionOperation) Done() bool

+ func (op *TerminateSessionOperation) Metadata() (*dataprocpb.SessionOperationMetadata, error)

+ func (op *TerminateSessionOperation) Name() string

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

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

v2.3.0

Nov 9, 2023

v2.2.3

Nov 1, 2023

v2.2.2

Oct 26, 2023

v2.2.1

Oct 12, 2023

v2.2.0

Sep 20, 2023

v2.1.0

Sep 11, 2023

v2.0.2

Aug 8, 2023

v2.0.1

Jun 20, 2023

v2.0.0

Apr 26, 2023

Changes in this version

+ func DefaultAuthScopes() []string

+ type AutoscalingPolicyCallOptions struct

+ CancelOperation []gax.CallOption

+ CreateAutoscalingPolicy []gax.CallOption

+ DeleteAutoscalingPolicy []gax.CallOption

+ DeleteOperation []gax.CallOption

+ GetAutoscalingPolicy []gax.CallOption

+ GetIamPolicy []gax.CallOption

+ GetOperation []gax.CallOption

+ ListAutoscalingPolicies []gax.CallOption

+ ListOperations []gax.CallOption

+ SetIamPolicy []gax.CallOption

+ TestIamPermissions []gax.CallOption

+ UpdateAutoscalingPolicy []gax.CallOption

+ type AutoscalingPolicyClient struct

+ CallOptions *AutoscalingPolicyCallOptions

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

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

+ func (c *AutoscalingPolicyClient) CancelOperation(ctx context.Context, req *longrunningpb.CancelOperationRequest, ...) 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) DeleteOperation(ctx context.Context, req *longrunningpb.DeleteOperationRequest, ...) error

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

+ func (c *AutoscalingPolicyClient) GetIamPolicy(ctx context.Context, req *iampb.GetIamPolicyRequest, opts ...gax.CallOption) (*iampb.Policy, error)

+ func (c *AutoscalingPolicyClient) GetOperation(ctx context.Context, req *longrunningpb.GetOperationRequest, ...) (*longrunningpb.Operation, error)

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

+ func (c *AutoscalingPolicyClient) ListOperations(ctx context.Context, req *longrunningpb.ListOperationsRequest, ...) *OperationIterator

+ func (c *AutoscalingPolicyClient) SetIamPolicy(ctx context.Context, req *iampb.SetIamPolicyRequest, opts ...gax.CallOption) (*iampb.Policy, error)

+ func (c *AutoscalingPolicyClient) TestIamPermissions(ctx context.Context, req *iampb.TestIamPermissionsRequest, ...) (*iampb.TestIamPermissionsResponse, error)

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

+ CancelOperation []gax.CallOption

+ CreateBatch []gax.CallOption

+ DeleteBatch []gax.CallOption

+ DeleteOperation []gax.CallOption

+ GetBatch []gax.CallOption

+ GetIamPolicy []gax.CallOption

+ GetOperation []gax.CallOption

+ ListBatches []gax.CallOption

+ ListOperations []gax.CallOption

+ SetIamPolicy []gax.CallOption

+ TestIamPermissions []gax.CallOption

+ type BatchControllerClient struct

+ CallOptions *BatchControllerCallOptions

+ LROClient *lroauto.OperationsClient

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

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

+ func (c *BatchControllerClient) CancelOperation(ctx context.Context, req *longrunningpb.CancelOperationRequest, ...) 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) DeleteOperation(ctx context.Context, req *longrunningpb.DeleteOperationRequest, ...) error

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

+ func (c *BatchControllerClient) GetIamPolicy(ctx context.Context, req *iampb.GetIamPolicyRequest, opts ...gax.CallOption) (*iampb.Policy, error)

+ func (c *BatchControllerClient) GetOperation(ctx context.Context, req *longrunningpb.GetOperationRequest, ...) (*longrunningpb.Operation, error)

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

+ func (c *BatchControllerClient) ListOperations(ctx context.Context, req *longrunningpb.ListOperationsRequest, ...) *OperationIterator

+ func (c *BatchControllerClient) SetIamPolicy(ctx context.Context, req *iampb.SetIamPolicyRequest, opts ...gax.CallOption) (*iampb.Policy, error)

+ func (c *BatchControllerClient) TestIamPermissions(ctx context.Context, req *iampb.TestIamPermissionsRequest, ...) (*iampb.TestIamPermissionsResponse, error)

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

+ CancelOperation []gax.CallOption

+ CreateCluster []gax.CallOption

+ DeleteCluster []gax.CallOption

+ DeleteOperation []gax.CallOption

+ DiagnoseCluster []gax.CallOption

+ GetCluster []gax.CallOption

+ GetIamPolicy []gax.CallOption

+ GetOperation []gax.CallOption

+ ListClusters []gax.CallOption

+ ListOperations []gax.CallOption

+ SetIamPolicy []gax.CallOption

+ StartCluster []gax.CallOption

+ StopCluster []gax.CallOption

+ TestIamPermissions []gax.CallOption

+ UpdateCluster []gax.CallOption

+ type ClusterControllerClient struct

+ CallOptions *ClusterControllerCallOptions

+ LROClient *lroauto.OperationsClient

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

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

+ func (c *ClusterControllerClient) CancelOperation(ctx context.Context, req *longrunningpb.CancelOperationRequest, ...) 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) DeleteOperation(ctx context.Context, req *longrunningpb.DeleteOperationRequest, ...) error

+ 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) GetIamPolicy(ctx context.Context, req *iampb.GetIamPolicyRequest, opts ...gax.CallOption) (*iampb.Policy, error)

+ func (c *ClusterControllerClient) GetOperation(ctx context.Context, req *longrunningpb.GetOperationRequest, ...) (*longrunningpb.Operation, error)

+ func (c *ClusterControllerClient) ListClusters(ctx context.Context, req *dataprocpb.ListClustersRequest, ...) *ClusterIterator

+ func (c *ClusterControllerClient) ListOperations(ctx context.Context, req *longrunningpb.ListOperationsRequest, ...) *OperationIterator

+ func (c *ClusterControllerClient) SetIamPolicy(ctx context.Context, req *iampb.SetIamPolicyRequest, opts ...gax.CallOption) (*iampb.Policy, error)

+ 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) TestIamPermissions(ctx context.Context, req *iampb.TestIamPermissionsRequest, ...) (*iampb.TestIamPermissionsResponse, error)

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

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

+ CancelOperation []gax.CallOption

+ DeleteJob []gax.CallOption

+ DeleteOperation []gax.CallOption

+ GetIamPolicy []gax.CallOption

+ GetJob []gax.CallOption

+ GetOperation []gax.CallOption

+ ListJobs []gax.CallOption

+ ListOperations []gax.CallOption

+ SetIamPolicy []gax.CallOption

+ SubmitJob []gax.CallOption

+ SubmitJobAsOperation []gax.CallOption

+ TestIamPermissions []gax.CallOption

+ UpdateJob []gax.CallOption

+ type JobControllerClient struct

+ CallOptions *JobControllerCallOptions

+ LROClient *lroauto.OperationsClient

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

+ func NewJobControllerRESTClient(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) CancelOperation(ctx context.Context, req *longrunningpb.CancelOperationRequest, ...) 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) DeleteOperation(ctx context.Context, req *longrunningpb.DeleteOperationRequest, ...) error

+ func (c *JobControllerClient) GetIamPolicy(ctx context.Context, req *iampb.GetIamPolicyRequest, opts ...gax.CallOption) (*iampb.Policy, error)

+ func (c *JobControllerClient) GetJob(ctx context.Context, req *dataprocpb.GetJobRequest, opts ...gax.CallOption) (*dataprocpb.Job, error)

+ func (c *JobControllerClient) GetOperation(ctx context.Context, req *longrunningpb.GetOperationRequest, ...) (*longrunningpb.Operation, error)

+ func (c *JobControllerClient) ListJobs(ctx context.Context, req *dataprocpb.ListJobsRequest, opts ...gax.CallOption) *JobIterator

+ func (c *JobControllerClient) ListOperations(ctx context.Context, req *longrunningpb.ListOperationsRequest, ...) *OperationIterator

+ func (c *JobControllerClient) SetIamPolicy(ctx context.Context, req *iampb.SetIamPolicyRequest, opts ...gax.CallOption) (*iampb.Policy, error)

+ 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) TestIamPermissions(ctx context.Context, req *iampb.TestIamPermissionsRequest, ...) (*iampb.TestIamPermissionsResponse, 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)

+ Response interface{}

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

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

+ type NodeGroupControllerCallOptions struct

+ CancelOperation []gax.CallOption

+ CreateNodeGroup []gax.CallOption

+ DeleteOperation []gax.CallOption

+ GetIamPolicy []gax.CallOption

+ GetNodeGroup []gax.CallOption

+ GetOperation []gax.CallOption

+ ListOperations []gax.CallOption

+ ResizeNodeGroup []gax.CallOption

+ SetIamPolicy []gax.CallOption

+ TestIamPermissions []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) CancelOperation(ctx context.Context, req *longrunningpb.CancelOperationRequest, ...) 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) DeleteOperation(ctx context.Context, req *longrunningpb.DeleteOperationRequest, ...) error

+ func (c *NodeGroupControllerClient) GetIamPolicy(ctx context.Context, req *iampb.GetIamPolicyRequest, opts ...gax.CallOption) (*iampb.Policy, error)

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

+ func (c *NodeGroupControllerClient) GetOperation(ctx context.Context, req *longrunningpb.GetOperationRequest, ...) (*longrunningpb.Operation, error)

+ func (c *NodeGroupControllerClient) ListOperations(ctx context.Context, req *longrunningpb.ListOperationsRequest, ...) *OperationIterator

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

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

+ func (c *NodeGroupControllerClient) SetIamPolicy(ctx context.Context, req *iampb.SetIamPolicyRequest, opts ...gax.CallOption) (*iampb.Policy, error)

+ func (c *NodeGroupControllerClient) TestIamPermissions(ctx context.Context, req *iampb.TestIamPermissionsRequest, ...) (*iampb.TestIamPermissionsResponse, error)

+ type OperationIterator struct

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

+ Response interface{}

+ func (it *OperationIterator) Next() (*longrunningpb.Operation, error)

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

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

+ CancelOperation []gax.CallOption

+ CreateWorkflowTemplate []gax.CallOption

+ DeleteOperation []gax.CallOption

+ DeleteWorkflowTemplate []gax.CallOption

+ GetIamPolicy []gax.CallOption

+ GetOperation []gax.CallOption

+ GetWorkflowTemplate []gax.CallOption

+ InstantiateInlineWorkflowTemplate []gax.CallOption

+ InstantiateWorkflowTemplate []gax.CallOption

+ ListOperations []gax.CallOption

+ ListWorkflowTemplates []gax.CallOption

+ SetIamPolicy []gax.CallOption

+ TestIamPermissions []gax.CallOption

+ UpdateWorkflowTemplate []gax.CallOption

+ type WorkflowTemplateClient struct

+ CallOptions *WorkflowTemplateCallOptions

+ LROClient *lroauto.OperationsClient

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

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

+ func (c *WorkflowTemplateClient) CancelOperation(ctx context.Context, req *longrunningpb.CancelOperationRequest, ...) 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) DeleteOperation(ctx context.Context, req *longrunningpb.DeleteOperationRequest, ...) error

+ func (c *WorkflowTemplateClient) DeleteWorkflowTemplate(ctx context.Context, req *dataprocpb.DeleteWorkflowTemplateRequest, ...) error

+ func (c *WorkflowTemplateClient) GetIamPolicy(ctx context.Context, req *iampb.GetIamPolicyRequest, opts ...gax.CallOption) (*iampb.Policy, error)

+ func (c *WorkflowTemplateClient) GetOperation(ctx context.Context, req *longrunningpb.GetOperationRequest, ...) (*longrunningpb.Operation, 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) ListOperations(ctx context.Context, req *longrunningpb.ListOperationsRequest, ...) *OperationIterator

+ func (c *WorkflowTemplateClient) ListWorkflowTemplates(ctx context.Context, req *dataprocpb.ListWorkflowTemplatesRequest, ...) *WorkflowTemplateIterator

+ func (c *WorkflowTemplateClient) SetIamPolicy(ctx context.Context, req *iampb.SetIamPolicyRequest, opts ...gax.CallOption) (*iampb.Policy, error)

+ func (c *WorkflowTemplateClient) TestIamPermissions(ctx context.Context, req *iampb.TestIamPermissionsRequest, ...) (*iampb.TestIamPermissionsResponse, error)

+ 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