mon

May 2, 2019

Changes in this version

+ const DefaultMsgr1Port

+ const DefaultMsgr2Port

+ func FlattenMonEndpoints(mons map[string]*cephconfig.MonInfo) string

+ func ParseMonEndpoints(input string) map[string]*cephconfig.MonInfo

Dec 8, 2018

Changes in this version

type Cluster

+ Count int

+ MonCountMutex sync.Mutex

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