dataproc

package
v0.0.0-...-417428f Latest Latest
Warning

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

 Go to latest Published: Oct 27, 2020 License: MIT Imports: 4 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 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) 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) 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) 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) ClusterHostsIterator 

func (c *ClusterServiceClient) ClusterHostsIterator(ctx context.Context, clusterId string, opts ...grpc.CallOption) *ClusterHostsIterator

func (*ClusterServiceClient) ClusterIterator 

func (c *ClusterServiceClient) ClusterIterator(ctx context.Context, folderId string, opts ...grpc.CallOption) *ClusterIterator

func (*ClusterServiceClient) ClusterOperationsIterator 

func (c *ClusterServiceClient) ClusterOperationsIterator(ctx context.Context, clusterId string, opts ...grpc.CallOption) *ClusterOperationsIterator

func (*ClusterServiceClient) ClusterUILinksIterator 

func (c *ClusterServiceClient) ClusterUILinksIterator(ctx context.Context, clusterId string, 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) 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) 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

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) 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) 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) 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, clusterId string, 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) 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, 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) 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, clusterId string, 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.