client

type Conn ¶

type Conn interface {
	grpc.ClientConnInterface
	io.Closer
	GetState() connectivity.State
}

func New(serverURL string, tlsCfg *TLSConfig) (Conn, error)

type Pool ¶

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

Pool keeps the list of clients to inter-cp servers. Because the list of inter-cp servers changes in runtime, we need to properly manage the connections to them (initialize, share, close etc.) Pool helps us to not reimplement this for every inter-cp service (catalog, envoyadmin, etc.)

func NewPool(
	newConn func(string, *TLSConfig) (Conn, error),
	idleDeadline time.Duration,
	now func() time.Time,
) *Pool

func (c *Pool) Client(serverURL string) (Conn, error)

func (c *Pool) SetTLSConfig(tlsCfg *TLSConfig)

func (c *Pool) StartCleanup(ctx context.Context, ticker *time.Ticker)

type TLSConfig ¶

type TLSConfig struct {
	CaCert     x509.Certificate
	ClientCert tls.Certificate
}