rpc

Documentation

Index

• type GRPCConnection
  • func NewGRPCConnection() *GRPCConnection
  • func (g *GRPCConnection) Close(ctx context.Context, address string) error
  • func (g *GRPCConnection) Connect(ctx context.Context, address string) (*grpc.ClientConn, error)
  • func (g *GRPCConnection) GetConnection(address string) *grpc.ClientConn
  • func (g *GRPCConnection) Shutdown() []error

Types

type GRPCConnection

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

GRPCConnection manages all grpc connections

func NewGRPCConnection

func NewGRPCConnection() *GRPCConnection

NewGRPCConnection creates a new GRPCConnection instance

func (*GRPCConnection) Close

func (g *GRPCConnection) Close(ctx context.Context, address string) error

Close recieves a connection and closes it

func (*GRPCConnection) Connect

func (g *GRPCConnection) Connect(ctx context.Context, address string) (*grpc.ClientConn, error)

Connect connects to an `address` and stores it in the internal map

func (*GRPCConnection) GetConnection

func (g *GRPCConnection) GetConnection(address string) *grpc.ClientConn

GetConnection receives a address and returns its connection. If a connection is not available return nil

func (*GRPCConnection) Shutdown

func (g *GRPCConnection) Shutdown() []error

Shutdown closes all the connections