mon

package
v0.6.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 12, 2017 License: Apache-2.0 Imports: 26 Imported by: 0

Documentation

Overview

Package mon for the Ceph monitors.

Package mon for the Ceph monitors.

Package mon for the Ceph monitors.

Package mon for the Ceph monitors.

Index

Constants

View Source
const (
	// EndpointConfigMapName is the name of the configmap with mon endpoints
	EndpointConfigMapName = "rook-ceph-mon-endpoints"
	// EndpointDataKey is the name of the key inside the mon configmap to get the endpoints
	EndpointDataKey = "data"
	// MaxMonIDKey is the name of the max mon id used
	MaxMonIDKey = "maxMonId"
	// MappingKey is the name of the mapping for the mon->node and node->port
	MappingKey = "mapping"
)

Variables

View Source
var (
	// HealthCheckInterval interval to check the mons to be in quorum
	HealthCheckInterval = 20 * time.Second
	// MonOutTimeout the duration to wait before removing/failover to a new mon pod
	MonOutTimeout = 300 * time.Second
)

Functions

func AdminSecretEnvVar

func AdminSecretEnvVar() v1.EnvVar

AdminSecretEnvVar is the admin secret environment var

func ClusterNameEnvVar added in v0.3.1

func ClusterNameEnvVar(name string) v1.EnvVar

ClusterNameEnvVar is the cluster name environment var

func EndpointEnvVar added in v0.5.0

func EndpointEnvVar() v1.EnvVar

EndpointEnvVar is the mon endpoint environment var

func LoadClusterInfo added in v0.6.0

func LoadClusterInfo(context *clusterd.Context, namespace string) (*mon.ClusterInfo, int, error)

LoadClusterInfo constructs or loads a clusterinfo and returns it along with the maxMonID

func PublicIPEnvVar added in v0.5.0

func PublicIPEnvVar(publicIP string) v1.EnvVar

PublicIPEnvVar is the public ip env var for monitors

func SecretEnvVar added in v0.5.0

func SecretEnvVar() v1.EnvVar

SecretEnvVar is the mon secret environment var

func WriteConnectionConfig added in v0.6.0

func WriteConnectionConfig(context *clusterd.Context, clusterInfo *mon.ClusterInfo) error

WriteConnectionConfig save monitor connection config to disk

Types

type Cluster

type Cluster struct {
	Namespace  string
	Keyring    string
	Version    string
	MasterHost string
	Size       int
	Paused     bool
	Port       int32

	HostNetwork bool
	// contains filtered or unexported fields
}

Cluster is for the cluster of monitors

func New

func New(context *clusterd.Context, namespace, dataDirHostPath, version string, size int, placement k8sutil.Placement, hostNetwork bool) *Cluster

New creates an instance of a mon cluster

func (*Cluster) Start

func (c *Cluster) Start() error

Start the mon cluster

type HealthChecker added in v0.5.0

type HealthChecker struct {
	// contains filtered or unexported fields
}

HealthChecker check health for the monitors

func NewHealthChecker added in v0.5.0

func NewHealthChecker(monCluster *Cluster) *HealthChecker

NewHealthChecker creates a new HealthChecker object

func (*HealthChecker) Check added in v0.5.0

func (hc *HealthChecker) Check(stopCh chan struct{})

Check periodically the health of the monitors

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL