Versions in this module Expand all Collapse all v0 v0.7.1 Mar 9, 2018 v0.7.0 Feb 21, 2018 Changes in this version + const EndpointConfigMapName + const EndpointDataKey + const MappingKey + const MaxMonIDKey + var HealthCheckInterval = 45 * time.Second + var MonOutTimeout = 300 * time.Second + func AdminSecretEnvVar() v1.EnvVar + func ClusterNameEnvVar(name string) v1.EnvVar + func EndpointEnvVar() v1.EnvVar + func PublicIPEnvVar(publicIP string) v1.EnvVar + func SecretEnvVar() v1.EnvVar + func WriteConnectionConfig(context *clusterd.Context, clusterInfo *mon.ClusterInfo) error + type Cluster struct + HostNetwork bool + Keyring string + MasterHost string + Namespace string + Port int32 + Size int + Version string + func New(context *clusterd.Context, namespace, dataDirHostPath, version string, ...) *Cluster + func (c *Cluster) Start() error + type HealthChecker struct + func NewHealthChecker(monCluster *Cluster) *HealthChecker + func (hc *HealthChecker) Check(stopCh chan struct{}) + type Mapping struct + Node map[string]*NodeInfo + Port map[string]int32 + func CreateOrLoadClusterInfo(context *clusterd.Context, namespace string, ownerRef *metav1.OwnerReference) (*mon.ClusterInfo, int, *Mapping, error) + func LoadClusterInfo(context *clusterd.Context, namespace string) (*mon.ClusterInfo, int, *Mapping, error) + type NodeInfo struct + Address string + Hostname string + Name string
Go to main page