spark

package
v0.32.0 Latest Latest
Warning

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

 Go to latest Published: Jul 6, 2026 License: MIT Imports: 5 Imported by: 0

Documentation

Overview

nolint

nolint

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ClusterAccessBindingsIterator added in v0.30.0 

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

func (*ClusterAccessBindingsIterator) Error added in v0.30.0 

func (it *ClusterAccessBindingsIterator) Error() error

func (*ClusterAccessBindingsIterator) Next added in v0.30.0 

func (it *ClusterAccessBindingsIterator) Next() bool

func (*ClusterAccessBindingsIterator) Take added in v0.30.0 

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

func (*ClusterAccessBindingsIterator) TakeAll added in v0.30.0 

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

func (*ClusterAccessBindingsIterator) Value added in v0.30.0 

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

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) ([]*spark.Cluster, error)

func (*ClusterIterator) TakeAll 

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

func (*ClusterIterator) Value 

func (it *ClusterIterator) Value() *spark.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 spark.ClusterServiceClient with lazy GRPC connection initialization.

func (*ClusterServiceClient) ClusterAccessBindingsIterator added in v0.30.0 

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

func (*ClusterServiceClient) ClusterIterator 

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

func (*ClusterServiceClient) ClusterOperationsIterator 

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

func (*ClusterServiceClient) Create 

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

Create implements spark.ClusterServiceClient

func (*ClusterServiceClient) Delete 

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

Delete implements spark.ClusterServiceClient

func (*ClusterServiceClient) Get 

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

Get implements spark.ClusterServiceClient

func (*ClusterServiceClient) List 

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

List implements spark.ClusterServiceClient

func (*ClusterServiceClient) ListAccessBindings added in v0.30.0 

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

ListAccessBindings implements spark.ClusterServiceClient

func (*ClusterServiceClient) ListOperations 

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

ListOperations implements spark.ClusterServiceClient

func (*ClusterServiceClient) SetAccessBindings added in v0.30.0 

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

SetAccessBindings implements spark.ClusterServiceClient

func (*ClusterServiceClient) Start 

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

Start implements spark.ClusterServiceClient

func (*ClusterServiceClient) Stop 

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

Stop implements spark.ClusterServiceClient

func (*ClusterServiceClient) Update added in v0.12.0 

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

Update implements spark.ClusterServiceClient

func (*ClusterServiceClient) UpdateAccessBindings added in v0.30.0 

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

UpdateAccessBindings implements spark.ClusterServiceClient

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) ([]*spark.Job, error)

func (*JobIterator) TakeAll 

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

func (*JobIterator) Value 

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

type JobServiceClient 

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

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

func (*JobServiceClient) Cancel 

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

Cancel implements spark.JobServiceClient

func (*JobServiceClient) Create 

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

Create implements spark.JobServiceClient

func (*JobServiceClient) Get 

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

Get implements spark.JobServiceClient

func (*JobServiceClient) JobIterator 

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

func (*JobServiceClient) List 

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

List implements spark.JobServiceClient

func (*JobServiceClient) ListLog 

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

ListLog implements spark.JobServiceClient

type Spark 

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

Spark provides access to "spark" component of Yandex.Cloud

func NewSpark 

func NewSpark(g func(ctx context.Context) (*grpc.ClientConn, error)) *Spark

NewSpark creates instance of Spark

func (*Spark) Cluster 

func (s *Spark) Cluster() *ClusterServiceClient

Cluster gets ClusterService client

func (*Spark) Job 

func (s *Spark) Job() *JobServiceClient

Job gets JobService client

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.