Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func BasicAuthHeader ¶
func BasicAuthStreamInterceptor ¶
func BasicAuthStreamInterceptor(authHeader string) grpc.StreamClientInterceptor
func BasicAuthUnaryInterceptor ¶
func BasicAuthUnaryInterceptor(authHeader string) grpc.UnaryClientInterceptor
Types ¶
type ConnManager ¶
type ConnManager struct {
// contains filtered or unexported fields
}
func NewConnManager ¶
func NewConnManager(maxOpenConns int, timeout time.Duration, reg prometheus.Registerer, logger logrus.FieldLogger, grpcOpts ...grpc.DialOption) *ConnManager
func (*ConnManager) CleanupIdleConnections ¶
func (m *ConnManager) CleanupIdleConnections()
func (*ConnManager) Close ¶
func (m *ConnManager) Close()
func (*ConnManager) CloseConn ¶
func (m *ConnManager) CloseConn(addr string) error
func (*ConnManager) GetConn ¶
func (m *ConnManager) GetConn(addr string) (*grpc.ClientConn, error)
Source Files
Click to show internal directories.
Click to hide internal directories.