package client

import "sigs.k8s.io/apiserver-network-proxy/konnectivity-client/pkg/client"

Index ¶

• Constants
• type Tunnel
• func CreateGrpcTunnel(address string, opts ...grpc.DialOption) (Tunnel, error)

Constants ¶

const CloseTimeout = 10 * time.Second

CloseTimeout is the timeout to wait CLOSE_RSP packet after a successful delivery of CLOSE_REQ.

Types ¶

type Tunnel ¶

type Tunnel interface {
	// Dial connects to the address on the named network, similar to
	// what net.Dial does. The only supported protocol is tcp.
	Dial(protocol, address string) (net.Conn, error)
}

Tunnel provides ability to dial a connection through a tunnel.

func CreateGrpcTunnel ¶

func CreateGrpcTunnel(address string, opts ...grpc.DialOption) (Tunnel, error)

CreateGrpcTunnel creates a Tunnel to dial to a remote server through a gRPC based proxy service.

Source Files ¶

client.go conn.go