connect

Documentation

Index

• type Connection
  • func (c *Connection) Close() error
  • func (c *Connection) Connect() (*Connection, error)
• type Connector
  • func (c Connector) Add(connections ...*Connection) Connector
  • func (c Connector) Connect(name string) (*grpc.ClientConn, error)
  • func (c Connector) Delete(connections ...*Connection) Connector
  • func (c Connector) Get(name string) (*Connection, error)
• type TLSOptions

Types

type Connection

type Connection struct {
	Name       string
	Address    string
	TLS        bool
	TLSOptions *TLSOptions
	Conn       *grpc.ClientConn
}

func (*Connection) Close

func (c *Connection) Close() error

Close close the gRPC connection

func (*Connection) Connect

func (c *Connection) Connect() (*Connection, error)

Connect connect to gRPC server Remember to defer.Close() to avoid memory leak

type Connector

type Connector map[string]*Connection

func (Connector) Add

func (c Connector) Add(connections ...*Connection) Connector

Add add connection to connector

func (Connector) Connect

func (c Connector) Connect(name string) (*grpc.ClientConn, error)

Connect connect to the gRPC server Remember to defer Close() to avoid memory leak

func (Connector) Delete

func (c Connector) Delete(connections ...*Connection) Connector

Delete delete connection in the connector

func (Connector) Get

func (c Connector) Get(name string) (*Connection, error)

Get get connection in the connector by name

type TLSOptions

type TLSOptions struct {
	CACert     string
	ClientCert string
	ClientKey  string
}