Versions in this module Expand all Collapse all v1 v1.14.1 Mar 14, 2023 Changes in this version + const NonSessionBackoffInitialInterval + const NonSessionBackoffMaxElapsedTime + const NonSessionBackoffMaxInterval + const NonSessionBackoffMultiplier + const NonSessionBackoffRandomizationFactor + func Base64EncodeStr(info string) (str string) + func MetaMessenger(ctx context.Context, logger *logrus.Logger, metaConn net.Conn) error + type KubernetesClientManager struct + func NewKubernetesClientManager(ctx context.Context, logger *logrus.Logger, config *rest.Config, ...) KubernetesClientManager + func (kcm *KubernetesClientManager) Do(sessionID uint16, r *http.Request) (net.Conn, *http.Response, error) + type StubConnector struct + func NewStubConnector(ctx context.Context, logger *logrus.Logger, urlStr string, ...) StubConnector + func (sc *StubConnector) Connect(isSession byte, sessionID uint16) (conn net.Conn, err error) + type TLSRoundTripper struct + Conn net.Conn + func NewTLSRoundTripper(config *tls.Config, address string) (*TLSRoundTripper, error) + func (tlsRoundTripper *TLSRoundTripper) RoundTrip(r *http.Request) (*http.Response, error)