var directDialer … func init() { … } type EgressSelector … type EgressType … const ControlPlane … const Etcd … const Cluster … type NetworkContext … type Lookup … // String returns the canonical string representation of the egress type func (s EgressType) String() string { … } // AsNetworkContext is a helper function to make it easy to get the basic NetworkContext objects. func (s EgressType) AsNetworkContext() NetworkContext { … } func lookupServiceName(name string) (EgressType, error) { … } func tunnelHTTPConnect(proxyConn net.Conn, proxyAddress, addr string) (net.Conn, error) { … } type proxier … var _ … type httpConnectProxier … func (t *httpConnectProxier) proxy(ctx context.Context, addr string) (net.Conn, error) { … } var _ … type grpcProxier … func (g *grpcProxier) proxy(ctx context.Context, addr string) (net.Conn, error) { … } type proxyServerConnector … type tcpHTTPConnectConnector … func (t *tcpHTTPConnectConnector) connect(ctx context.Context) (proxier, error) { … } type udsHTTPConnectConnector … func (u *udsHTTPConnectConnector) connect(ctx context.Context) (proxier, error) { … } type udsGRPCConnector … // connect establishes a connection to a proxy over gRPC. // TODO At the moment, it does not use the provided context. func (u *udsGRPCConnector) connect(_ context.Context) (proxier, error) { … } type dialerCreator … type metricsOptions … func (d *dialerCreator) createDialer() utilnet.DialFunc { … } func getTLSConfig(t *apiserver.TLSConfig) (*tls.Config, error) { … } func getProxyAddress(urlString string) (string, error) { … } func connectionToDialerCreator(c apiserver.Connection) (*dialerCreator, error) { … } // NewEgressSelector configures lookup mechanism for Lookup. // It does so based on a EgressSelectorConfiguration which was read at startup. func NewEgressSelector(config *apiserver.EgressSelectorConfiguration) (*EgressSelector, error) { … } // NewEgressSelectorWithMap returns a EgressSelector with the supplied EgressType to DialFunc map. func NewEgressSelectorWithMap(m map[EgressType]utilnet.DialFunc) *EgressSelector { … } // Lookup gets the dialer function for the network context. // This is configured for the Kubernetes API Server at startup. func (cs *EgressSelector) Lookup(networkContext NetworkContext) (utilnet.DialFunc, error) { … }
Codebase Browser
kubernetes