clientmanager

Documentation

Index

• type ClientManager
  • func New() *ClientManager
  • func (cm *ClientManager) AddIfNotExists(target string, opts ...grpc.DialOption) error
  • func (cm *ClientManager) Get(target string) *grpc.ClientConn
  • func (cm *ClientManager) Metrics() *metrics.ClientManagerMetrics
  • func (cm *ClientManager) Release(target string)

Types

type ClientManager

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

ClientManager manages GRPC client connections

func New

func New() *ClientManager

New creates a new ClientManager

func (*ClientManager) AddIfNotExists

func (cm *ClientManager) AddIfNotExists(target string, opts ...grpc.DialOption) error

AddIfNotExists adds a client if it doesn't exist already

func (*ClientManager) Get

func (cm *ClientManager) Get(target string) *grpc.ClientConn

Get gets a target connection and tracks it's usage

func (*ClientManager) Metrics

func (cm *ClientManager) Metrics() *metrics.ClientManagerMetrics

Metrics gets ClientManager metrics

func (*ClientManager) Release

func (cm *ClientManager) Release(target string)

Release releases a connection if refCount reaches 0