Versions in this module Expand all Collapse all v0 v0.1.0 Nov 28, 2019 Changes in this version + const ClusterConnectHeaderListenAddr + const ClusterConnectHeaderUserDefineName + const K8sInformerSyncDuration + const RootClusterName + var ErrDuplicatedName = fmt.Errorf("cluster name duplicated") + func IsRoot(clusterName string) bool + type ClusterControllerConfig struct + ClusterName string + ClusterToEdgeChan chan clustermessage.ClusterMessage + ClusterUserDefineName string + EdgeToClusterChan chan clustermessage.ClusterMessage + HelmTillerAddr string + K8sClient oteclient.Interface + KubeConfig string + LeaderListenAddr string + ParentCluster string + RemoteShimAddr string + TunnelListenAddr string + type ClusterRegistry struct + Listen string + Name string + ParentName string + Time int64 + UserDefineName string + func ClusterRegistryDeserialize(b []byte) (*ClusterRegistry, error) + func (cr *ClusterRegistry) Serialize() ([]byte, error) + func (cr *ClusterRegistry) WrapperToClusterMessage(command clustermessage.CommandType) (*clustermessage.ClusterMessage, error)
Go to main page