airflow

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

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Airflow 

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

Airflow provides access to "airflow" component of Yandex.Cloud

func NewAirflow 

func NewAirflow(g func(ctx context.Context) (*grpc.ClientConn, error)) *Airflow

NewAirflow creates instance of Airflow

func (*Airflow) Cluster 

func (a *Airflow) Cluster() *ClusterServiceClient

Cluster gets ClusterService client

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

func (*ClusterIterator) TakeAll 

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

func (*ClusterIterator) Value 

func (it *ClusterIterator) Value() *airflow.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 airflow.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 *airflow.ListClustersRequest, opts ...grpc.CallOption) *ClusterIterator

func (*ClusterServiceClient) ClusterOperationsIterator 

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

func (*ClusterServiceClient) Create 

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

Create implements airflow.ClusterServiceClient

func (*ClusterServiceClient) Delete 

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

Delete implements airflow.ClusterServiceClient

func (*ClusterServiceClient) Get 

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

Get implements airflow.ClusterServiceClient

func (*ClusterServiceClient) List 

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

List implements airflow.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 airflow.ClusterServiceClient

func (*ClusterServiceClient) ListOperations 

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

ListOperations implements airflow.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 airflow.ClusterServiceClient

func (*ClusterServiceClient) Start 

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

Start implements airflow.ClusterServiceClient

func (*ClusterServiceClient) Stop 

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

Stop implements airflow.ClusterServiceClient

func (*ClusterServiceClient) Update 

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

Update implements airflow.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 airflow.ClusterServiceClient

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.