Versions in this module Expand all Collapse all v1 v1.14.1 Mar 14, 2023 Changes in this version + const BufferSize + const CheckInterval + const ConfigMapAgentConfigName + const ConfigMapProviderAutoKey + const ConfigMapProviderKey + const ConfigMapProviderName + const ConfigMapScriptPathKey + const DefaultAgentNamespace + const HeartbeatInterval + const SessionIDHeaderKey + func Heartbeat(ctx context.Context, logger *logrus.Logger, conn net.Conn, cfg *rest.Config) + func StartHealthzServer(addr string, logger *logrus.Logger) + type AgentMeta struct + CustomizeCommand string + Data map[string]string + IsIntranet string + K8sVersion string + Provider string + func (src *AgentMeta) DeepCopy(dest *AgentMeta) + type Component struct + func NewComponent(ctx context.Context, logger *logrus.Logger) Component + type Heart struct + func (h *Heart) Beat() + func (h *Heart) CheckCluster() + type StubMeta struct + ActiveCluster string + AgentsMeta map[string]AgentMeta + State TunnelState + Version string + type StubMetaProviderFunc func() StubMeta + type TunnelEndpoint struct + func NewTunnelEndpoint(ctx context.Context, logger *logrus.Logger) TunnelEndpoint + func (endpoint *TunnelEndpoint) CheckAndStartPipe(request *http.Request, response *http.Response, endpointA io.ReadWriter, ...) + type TunnelState string