dataproc

package
v0.31.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 22, 2026 License: MIT Imports: 5 Imported by: 0

Documentation

Overview

nolint

nolint

nolint

nolint

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ClusterAccessBindingsIterator added in v0.31.0 

type ClusterAccessBindingsIterator struct {
	// contains filtered or unexported fields
}

func (*ClusterAccessBindingsIterator) Error added in v0.31.0 

func (it *ClusterAccessBindingsIterator) Error() error

func (*ClusterAccessBindingsIterator) Next added in v0.31.0 

func (it *ClusterAccessBindingsIterator) Next() bool

func (*ClusterAccessBindingsIterator) Take added in v0.31.0 

func (it *ClusterAccessBindingsIterator) Take(size int64) ([]*access.AccessBinding, error)

func (*ClusterAccessBindingsIterator) TakeAll added in v0.31.0 

func (it *ClusterAccessBindingsIterator) TakeAll() ([]*access.AccessBinding, error)

func (*ClusterAccessBindingsIterator) Value added in v0.31.0 

func (it *ClusterAccessBindingsIterator) Value() *access.AccessBinding

type ClusterHostsIterator 

type ClusterHostsIterator struct {
	// contains filtered or unexported fields
}

func (*ClusterHostsIterator) Error 

func (it *ClusterHostsIterator) Error() error

func (*ClusterHostsIterator) Next 

func (it *ClusterHostsIterator) Next() bool

func (*ClusterHostsIterator) Take 

func (it *ClusterHostsIterator) Take(size int64) ([]*dataproc.Host, error)

func (*ClusterHostsIterator) TakeAll 

func (it *ClusterHostsIterator) TakeAll() ([]*dataproc.Host, error)

func (*ClusterHostsIterator) Value 

func (it *ClusterHostsIterator) Value() *dataproc.Host

type ClusterIterator 

type ClusterIterator struct {
	// contains filtered or unexported fields
}

func (*ClusterIterator) Error 

func (it *ClusterIterator) Error() error

func (*ClusterIterator) Next 

func (it *ClusterIterator) Next() bool

func (*ClusterIterator) Take 

func (it *ClusterIterator) Take(size int64) ([]*dataproc.Cluster, error)

func (*ClusterIterator) TakeAll 

func (it *ClusterIterator) TakeAll() ([]*dataproc.Cluster, error)

func (*ClusterIterator) Value 

func (it *ClusterIterator) Value() *dataproc.Cluster

type ClusterOperationsIterator 

type ClusterOperationsIterator struct {
	// contains filtered or unexported fields
}

func (*ClusterOperationsIterator) Error 

func (it *ClusterOperationsIterator) Error() error

func (*ClusterOperationsIterator) Next 

func (it *ClusterOperationsIterator) Next() bool

func (*ClusterOperationsIterator) Take 

func (it *ClusterOperationsIterator) Take(size int64) ([]*operation.Operation, error)

func (*ClusterOperationsIterator) TakeAll 

func (it *ClusterOperationsIterator) TakeAll() ([]*operation.Operation, error)

func (*ClusterOperationsIterator) Value 

func (it *ClusterOperationsIterator) Value() *operation.Operation

type ClusterServiceClient 

type ClusterServiceClient struct {
	// contains filtered or unexported fields
}

ClusterServiceClient is a dataproc.ClusterServiceClient with lazy GRPC connection initialization.

func (*ClusterServiceClient) ClusterAccessBindingsIterator added in v0.31.0 

func (c *ClusterServiceClient) ClusterAccessBindingsIterator(ctx context.Context, req *access.ListAccessBindingsRequest, opts ...grpc.CallOption) *ClusterAccessBindingsIterator

func (*ClusterServiceClient) ClusterHostsIterator 

func (c *ClusterServiceClient) ClusterHostsIterator(ctx context.Context, req *dataproc.ListClusterHostsRequest, opts ...grpc.CallOption) *ClusterHostsIterator

func (*ClusterServiceClient) ClusterIterator 

func (c *ClusterServiceClient) ClusterIterator(ctx context.Context, req *dataproc.ListClustersRequest, opts ...grpc.CallOption) *ClusterIterator

func (*ClusterServiceClient) ClusterOperationsIterator 

func (c *ClusterServiceClient) ClusterOperationsIterator(ctx context.Context, req *dataproc.ListClusterOperationsRequest, opts ...grpc.CallOption) *ClusterOperationsIterator

func (*ClusterServiceClient) ClusterUILinksIterator 

func (c *ClusterServiceClient) ClusterUILinksIterator(ctx context.Context, req *dataproc.ListUILinksRequest, opts ...grpc.CallOption) *ClusterUILinksIterator

func (*ClusterServiceClient) Create 

func (c *ClusterServiceClient) Create(ctx context.Context, in *dataproc.CreateClusterRequest, opts ...grpc.CallOption) (*operation.Operation, error)

Create implements dataproc.ClusterServiceClient

func (*ClusterServiceClient) Delete 

func (c *ClusterServiceClient) Delete(ctx context.Context, in *dataproc.DeleteClusterRequest, opts ...grpc.CallOption) (*operation.Operation, error)

Delete implements dataproc.ClusterServiceClient

func (*ClusterServiceClient) Get 

func (c *ClusterServiceClient) Get(ctx context.Context, in *dataproc.GetClusterRequest, opts ...grpc.CallOption) (*dataproc.Cluster, error)

Get implements dataproc.ClusterServiceClient

func (*ClusterServiceClient) List 

func (c *ClusterServiceClient) List(ctx context.Context, in *dataproc.ListClustersRequest, opts ...grpc.CallOption) (*dataproc.ListClustersResponse, error)

List implements dataproc.ClusterServiceClient

func (*ClusterServiceClient) ListAccessBindings added in v0.31.0 

func (c *ClusterServiceClient) ListAccessBindings(ctx context.Context, in *access.ListAccessBindingsRequest, opts ...grpc.CallOption) (*access.ListAccessBindingsResponse, error)

ListAccessBindings implements dataproc.ClusterServiceClient

func (*ClusterServiceClient) ListHosts 

func (c *ClusterServiceClient) ListHosts(ctx context.Context, in *dataproc.ListClusterHostsRequest, opts ...grpc.CallOption) (*dataproc.ListClusterHostsResponse, error)

ListHosts implements dataproc.ClusterServiceClient

func (*ClusterServiceClient) ListOperations 

func (c *ClusterServiceClient) ListOperations(ctx context.Context, in *dataproc.ListClusterOperationsRequest, opts ...grpc.CallOption) (*dataproc.ListClusterOperationsResponse, error)

ListOperations implements dataproc.ClusterServiceClient 

func (c *ClusterServiceClient) ListUILinks(ctx context.Context, in *dataproc.ListUILinksRequest, opts ...grpc.CallOption) (*dataproc.ListUILinksResponse, error)

ListUILinks implements dataproc.ClusterServiceClient

func (*ClusterServiceClient) SetAccessBindings added in v0.31.0 

func (c *ClusterServiceClient) SetAccessBindings(ctx context.Context, in *access.SetAccessBindingsRequest, opts ...grpc.CallOption) (*operation.Operation, error)

SetAccessBindings implements dataproc.ClusterServiceClient

func (*ClusterServiceClient) Start 

func (c *ClusterServiceClient) Start(ctx context.Context, in *dataproc.StartClusterRequest, opts ...grpc.CallOption) (*operation.Operation, error)

Start implements dataproc.ClusterServiceClient

func (*ClusterServiceClient) Stop 

func (c *ClusterServiceClient) Stop(ctx context.Context, in *dataproc.StopClusterRequest, opts ...grpc.CallOption) (*operation.Operation, error)

Stop implements dataproc.ClusterServiceClient

func (*ClusterServiceClient) Update 

func (c *ClusterServiceClient) Update(ctx context.Context, in *dataproc.UpdateClusterRequest, opts ...grpc.CallOption) (*operation.Operation, error)

Update implements dataproc.ClusterServiceClient

func (*ClusterServiceClient) UpdateAccessBindings added in v0.31.0 

func (c *ClusterServiceClient) UpdateAccessBindings(ctx context.Context, in *access.UpdateAccessBindingsRequest, opts ...grpc.CallOption) (*operation.Operation, error)

UpdateAccessBindings implements dataproc.ClusterServiceClient

type ClusterUILinksIterator 

type ClusterUILinksIterator struct {
	// contains filtered or unexported fields
}

func (*ClusterUILinksIterator) Error 

func (it *ClusterUILinksIterator) Error() error

func (*ClusterUILinksIterator) Next 

func (it *ClusterUILinksIterator) Next() bool

func (*ClusterUILinksIterator) Take 

func (it *ClusterUILinksIterator) Take(size int64) ([]*dataproc.UILink, error)

func (*ClusterUILinksIterator) TakeAll 

func (it *ClusterUILinksIterator) TakeAll() ([]*dataproc.UILink, error)

func (*ClusterUILinksIterator) Value 

func (it *ClusterUILinksIterator) Value() *dataproc.UILink

type Dataproc 

type Dataproc struct {
	// contains filtered or unexported fields
}

Dataproc provides access to "dataproc" component of Yandex.Cloud

func NewDataproc 

func NewDataproc(g func(ctx context.Context) (*grpc.ClientConn, error)) *Dataproc

NewDataproc creates instance of Dataproc

func (*Dataproc) Cluster 

func (d *Dataproc) Cluster() *ClusterServiceClient

Cluster gets ClusterService client

func (*Dataproc) Job 

func (d *Dataproc) Job() *JobServiceClient

Job gets JobService client

func (*Dataproc) ResourcePreset 

func (d *Dataproc) ResourcePreset() *ResourcePresetServiceClient

ResourcePreset gets ResourcePresetService client

func (*Dataproc) Subcluster 

func (d *Dataproc) Subcluster() *SubclusterServiceClient

Subcluster gets SubclusterService client

type JobIterator 

type JobIterator struct {
	// contains filtered or unexported fields
}

func (*JobIterator) Error 

func (it *JobIterator) Error() error

func (*JobIterator) Next 

func (it *JobIterator) Next() bool

func (*JobIterator) Take 

func (it *JobIterator) Take(size int64) ([]*dataproc.Job, error)

func (*JobIterator) TakeAll 

func (it *JobIterator) TakeAll() ([]*dataproc.Job, error)

func (*JobIterator) Value 

func (it *JobIterator) Value() *dataproc.Job

type JobServiceClient 

type JobServiceClient struct {
	// contains filtered or unexported fields
}

JobServiceClient is a dataproc.JobServiceClient with lazy GRPC connection initialization.

func (*JobServiceClient) Cancel 

func (c *JobServiceClient) Cancel(ctx context.Context, in *dataproc.CancelJobRequest, opts ...grpc.CallOption) (*operation.Operation, error)

Cancel implements dataproc.JobServiceClient

func (*JobServiceClient) Create 

func (c *JobServiceClient) Create(ctx context.Context, in *dataproc.CreateJobRequest, opts ...grpc.CallOption) (*operation.Operation, error)

Create implements dataproc.JobServiceClient

func (*JobServiceClient) Get 

func (c *JobServiceClient) Get(ctx context.Context, in *dataproc.GetJobRequest, opts ...grpc.CallOption) (*dataproc.Job, error)

Get implements dataproc.JobServiceClient

func (*JobServiceClient) JobIterator 

func (c *JobServiceClient) JobIterator(ctx context.Context, req *dataproc.ListJobsRequest, opts ...grpc.CallOption) *JobIterator

func (*JobServiceClient) List 

func (c *JobServiceClient) List(ctx context.Context, in *dataproc.ListJobsRequest, opts ...grpc.CallOption) (*dataproc.ListJobsResponse, error)

List implements dataproc.JobServiceClient

func (*JobServiceClient) ListLog 

func (c *JobServiceClient) ListLog(ctx context.Context, in *dataproc.ListJobLogRequest, opts ...grpc.CallOption) (*dataproc.ListJobLogResponse, error)

ListLog implements dataproc.JobServiceClient

type ResourcePresetIterator 

type ResourcePresetIterator struct {
	// contains filtered or unexported fields
}

func (*ResourcePresetIterator) Error 

func (it *ResourcePresetIterator) Error() error

func (*ResourcePresetIterator) Next 

func (it *ResourcePresetIterator) Next() bool

func (*ResourcePresetIterator) Take 

func (it *ResourcePresetIterator) Take(size int64) ([]*dataproc.ResourcePreset, error)

func (*ResourcePresetIterator) TakeAll 

func (it *ResourcePresetIterator) TakeAll() ([]*dataproc.ResourcePreset, error)

func (*ResourcePresetIterator) Value 

func (it *ResourcePresetIterator) Value() *dataproc.ResourcePreset

type ResourcePresetServiceClient 

type ResourcePresetServiceClient struct {
	// contains filtered or unexported fields
}

ResourcePresetServiceClient is a dataproc.ResourcePresetServiceClient with lazy GRPC connection initialization.

func (*ResourcePresetServiceClient) Get 

func (c *ResourcePresetServiceClient) Get(ctx context.Context, in *dataproc.GetResourcePresetRequest, opts ...grpc.CallOption) (*dataproc.ResourcePreset, error)

Get implements dataproc.ResourcePresetServiceClient

func (*ResourcePresetServiceClient) List 

func (c *ResourcePresetServiceClient) List(ctx context.Context, in *dataproc.ListResourcePresetsRequest, opts ...grpc.CallOption) (*dataproc.ListResourcePresetsResponse, error)

List implements dataproc.ResourcePresetServiceClient

func (*ResourcePresetServiceClient) ResourcePresetIterator 

func (c *ResourcePresetServiceClient) ResourcePresetIterator(ctx context.Context, req *dataproc.ListResourcePresetsRequest, opts ...grpc.CallOption) *ResourcePresetIterator

type SubclusterIterator 

type SubclusterIterator struct {
	// contains filtered or unexported fields
}

func (*SubclusterIterator) Error 

func (it *SubclusterIterator) Error() error

func (*SubclusterIterator) Next 

func (it *SubclusterIterator) Next() bool

func (*SubclusterIterator) Take 

func (it *SubclusterIterator) Take(size int64) ([]*dataproc.Subcluster, error)

func (*SubclusterIterator) TakeAll 

func (it *SubclusterIterator) TakeAll() ([]*dataproc.Subcluster, error)

func (*SubclusterIterator) Value 

func (it *SubclusterIterator) Value() *dataproc.Subcluster

type SubclusterServiceClient 

type SubclusterServiceClient struct {
	// contains filtered or unexported fields
}

SubclusterServiceClient is a dataproc.SubclusterServiceClient with lazy GRPC connection initialization.

func (*SubclusterServiceClient) Create 

func (c *SubclusterServiceClient) Create(ctx context.Context, in *dataproc.CreateSubclusterRequest, opts ...grpc.CallOption) (*operation.Operation, error)

Create implements dataproc.SubclusterServiceClient

func (*SubclusterServiceClient) Delete 

func (c *SubclusterServiceClient) Delete(ctx context.Context, in *dataproc.DeleteSubclusterRequest, opts ...grpc.CallOption) (*operation.Operation, error)

Delete implements dataproc.SubclusterServiceClient

func (*SubclusterServiceClient) Get 

func (c *SubclusterServiceClient) Get(ctx context.Context, in *dataproc.GetSubclusterRequest, opts ...grpc.CallOption) (*dataproc.Subcluster, error)

Get implements dataproc.SubclusterServiceClient

func (*SubclusterServiceClient) List 

func (c *SubclusterServiceClient) List(ctx context.Context, in *dataproc.ListSubclustersRequest, opts ...grpc.CallOption) (*dataproc.ListSubclustersResponse, error)

List implements dataproc.SubclusterServiceClient

func (*SubclusterServiceClient) SubclusterIterator 

func (c *SubclusterServiceClient) SubclusterIterator(ctx context.Context, req *dataproc.ListSubclustersRequest, opts ...grpc.CallOption) *SubclusterIterator

func (*SubclusterServiceClient) Update 

func (c *SubclusterServiceClient) Update(ctx context.Context, in *dataproc.UpdateSubclusterRequest, opts ...grpc.CallOption) (*operation.Operation, error)

Update implements dataproc.SubclusterServiceClient

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.