type Tunnel … type dialResult … type pendingDial … type pendingDialManager … func (p *pendingDialManager) add(dialID int64, pd pendingDial) { … } func (p *pendingDialManager) remove(dialID int64) { … } func (p *pendingDialManager) get(dialID int64) (pendingDial, bool) { … } type connectionManager … func (cm *connectionManager) add(connID int64, c *conn) { … } func (cm *connectionManager) remove(connID int64) { … } func (cm *connectionManager) get(connID int64) (*conn, bool) { … } func (cm *connectionManager) closeAll() { … } type grpcTunnel … type clientConn … var _ … var Metrics … // CreateSingleUseGrpcTunnel creates a Tunnel to dial to a remote server through a // gRPC based proxy service. // Currently, a single tunnel supports a single connection, and the tunnel is closed when the connection is terminated // The Dial() method of the returned tunnel should only be called once // Deprecated 2022-06-07: use CreateSingleUseGrpcTunnelWithContext func CreateSingleUseGrpcTunnel(tunnelCtx context.Context, address string, opts ...grpc.DialOption) (Tunnel, error) { … } // CreateSingleUseGrpcTunnelWithContext creates a Tunnel to dial to a remote server through a // gRPC based proxy service. // Currently, a single tunnel supports a single connection. // The tunnel is normally closed when the connection is terminated. // If createCtx is cancelled before tunnel creation, an error will be returned. // If tunnelCtx is cancelled while the tunnel is still in use, the tunnel (and any in flight connections) will be closed. // The Dial() method of the returned tunnel should only be called once func CreateSingleUseGrpcTunnelWithContext(createCtx, tunnelCtx context.Context, address string, opts ...grpc.DialOption) (Tunnel, error) { … } func newUnstartedTunnel(stream client.ProxyService_ProxyClient, c clientConn) *grpcTunnel { … } func (t *grpcTunnel) updateMetric(status metrics.ClientConnectionStatus) { … } // closeMetric should be called exactly once to finalize client_connections metric. func (t *grpcTunnel) closeMetric() { … } func (t *grpcTunnel) serve(tunnelCtx context.Context) { … } // Dial connects to the address on the named network, similar to // what net.Dial does. The only supported protocol is tcp. func (t *grpcTunnel) DialContext(requestCtx context.Context, protocol, address string) (net.Conn, error) { … } func (t *grpcTunnel) dialContext(requestCtx context.Context, protocol, address string) (net.Conn, error) { … } func (t *grpcTunnel) Done() <-chan struct{ … } func (t *grpcTunnel) sendCloseRequest(connID int64) error { … } func (t *grpcTunnel) sendDialClose(dialID int64) error { … } func (t *grpcTunnel) closeTunnel() { … } func (t *grpcTunnel) isClosing() bool { … } func (t *grpcTunnel) Send(pkt *client.Packet) error { … } func (t *grpcTunnel) Recv() (*client.Packet, error) { … } func GetDialFailureReason(err error) (isDialFailure bool, reason metrics.DialFailureReason) { … } type dialFailure … func (df *dialFailure) Error() string { … }
Codebase Browser
kubernetes