connectionmanager

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: 4 Imported by: 0

Documentation

Overview

nolint

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ConnectionIterator 

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

func (*ConnectionIterator) Error 

func (it *ConnectionIterator) Error() error

func (*ConnectionIterator) Next 

func (it *ConnectionIterator) Next() bool

func (*ConnectionIterator) Take 

func (it *ConnectionIterator) Take(size int64) ([]*connectionmanager.Connection, error)

func (*ConnectionIterator) TakeAll 

func (it *ConnectionIterator) TakeAll() ([]*connectionmanager.Connection, error)

func (*ConnectionIterator) Value 

func (it *ConnectionIterator) Value() *connectionmanager.Connection

type ConnectionManager 

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

ConnectionManager provides access to "connectionmanager" component of Yandex.Cloud

func NewConnectionManager 

func NewConnectionManager(g func(ctx context.Context) (*grpc.ClientConn, error)) *ConnectionManager

NewConnectionManager creates instance of ConnectionManager

func (*ConnectionManager) Connection 

func (c *ConnectionManager) Connection() *ConnectionServiceClient

Connection gets ConnectionService client

type ConnectionOperationsIterator 

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

func (*ConnectionOperationsIterator) Error 

func (it *ConnectionOperationsIterator) Error() error

func (*ConnectionOperationsIterator) Next 

func (it *ConnectionOperationsIterator) Next() bool

func (*ConnectionOperationsIterator) Take 

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

func (*ConnectionOperationsIterator) TakeAll 

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

func (*ConnectionOperationsIterator) Value 

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

type ConnectionServiceClient 

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

ConnectionServiceClient is a connectionmanager.ConnectionServiceClient with lazy GRPC connection initialization.

func (*ConnectionServiceClient) ConnectionIterator 

func (c *ConnectionServiceClient) ConnectionIterator(ctx context.Context, req *connectionmanager.ListConnectionRequest, opts ...grpc.CallOption) *ConnectionIterator

func (*ConnectionServiceClient) ConnectionOperationsIterator 

func (c *ConnectionServiceClient) ConnectionOperationsIterator(ctx context.Context, req *connectionmanager.ListOperationsRequest, opts ...grpc.CallOption) *ConnectionOperationsIterator

func (*ConnectionServiceClient) Create 

func (c *ConnectionServiceClient) Create(ctx context.Context, in *connectionmanager.CreateConnectionRequest, opts ...grpc.CallOption) (*operation.Operation, error)

Create implements connectionmanager.ConnectionServiceClient

func (*ConnectionServiceClient) Delete 

func (c *ConnectionServiceClient) Delete(ctx context.Context, in *connectionmanager.DeleteConnectionRequest, opts ...grpc.CallOption) (*operation.Operation, error)

Delete implements connectionmanager.ConnectionServiceClient

func (*ConnectionServiceClient) Get 

func (c *ConnectionServiceClient) Get(ctx context.Context, in *connectionmanager.GetConnectionRequest, opts ...grpc.CallOption) (*connectionmanager.Connection, error)

Get implements connectionmanager.ConnectionServiceClient

func (*ConnectionServiceClient) List 

func (c *ConnectionServiceClient) List(ctx context.Context, in *connectionmanager.ListConnectionRequest, opts ...grpc.CallOption) (*connectionmanager.ListConnectionResponse, error)

List implements connectionmanager.ConnectionServiceClient

func (*ConnectionServiceClient) ListOperations 

func (c *ConnectionServiceClient) ListOperations(ctx context.Context, in *connectionmanager.ListOperationsRequest, opts ...grpc.CallOption) (*connectionmanager.ListOperationsResponse, error)

ListOperations implements connectionmanager.ConnectionServiceClient

func (*ConnectionServiceClient) ResolveCluster 

func (c *ConnectionServiceClient) ResolveCluster(ctx context.Context, in *connectionmanager.ResolveClusterRequest, opts ...grpc.CallOption) (*connectionmanager.Connection, error)

ResolveCluster implements connectionmanager.ConnectionServiceClient

func (*ConnectionServiceClient) Update 

func (c *ConnectionServiceClient) Update(ctx context.Context, in *connectionmanager.UpdateConnectionRequest, opts ...grpc.CallOption) (*operation.Operation, error)

Update implements connectionmanager.ConnectionServiceClient

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.