conn

Documentation

Index

• Variables
• type ClientConnections
  • func NewClientConnections() *ClientConnections
  • func (c *ClientConnections) GetConnection(storageName string) (*grpc.ClientConn, error)
  • func (c *ClientConnections) RegisterNode(storageName, listenAddr, token string) error

Variables

var ErrAlreadyRegistered = errors.New("client connection already registered")

ErrAlreadyRegistered indicates the client connection for a given storage has already been registered

var ErrConnectionNotFound = errors.New("client connection not found")

ErrConnectionNotFound indicates the connection for a given storage has not yet been registered

Types

type ClientConnections

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

ClientConnections contains ready to use grpc client connections

func NewClientConnections

func NewClientConnections() *ClientConnections

NewClientConnections creates a new ClientConnections struct

func (*ClientConnections) GetConnection

func (c *ClientConnections) GetConnection(storageName string) (*grpc.ClientConn, error)

GetConnection gets the grpc client connection based on an address

func (*ClientConnections) RegisterNode

func (c *ClientConnections) RegisterNode(storageName, listenAddr, token string) error

RegisterNode will direct traffic to the supplied downstream connection when the storage location is encountered.