Versions in this module Expand all Collapse all v0 v0.8.1 Aug 1, 2018 v0.8.0 Jul 18, 2018 Changes in this version + const DefaultMonCount + const EndpointConfigMapName + const EndpointDataKey + const MappingKey + const MaxMonCount + 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 + AllowMultiplePerNode bool + 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