v1alpha1

package
v1.0.6 Latest Latest
Warning

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

 Go to latest Published: Jun 18, 2019 License: GPL-2.0-or-later Imports: 15 Imported by: 8

Documentation

Overview

Package v1alpha1 contains API Schema definitions for the ceph v1alpha1 API group +k8s:deepcopy-gen=package,register +groupName=ceph.k8s.pgc.umn.edu

Package v1alpha1 contains API Schema definitions for the ceph v1alpha1 API group +k8s:deepcopy-gen=package,register +groupName=ceph.k8s.pgc.umn.edu

Index

Constants

View Source 
const (
	ClusterNameLabel    = "ceph.k8s.pgc.umn.edu/cluster"
	DaemonTypeLabel     = "ceph.k8s.pgc.umn.edu/daemonType"
	MonitorServiceLabel = "ceph.k8s.pgc.umn.edu/monitorService"
	KeyringEntityLabel  = "ceph.k8s.pgc.umn.edu/keyringEntity"
)
View Source 
const (
	CephDaemonStateIdle         CephDaemonState = "Idle"
	CephDaemonStateLaunching                    = "Launching"
	CephDaemonStateWaitForRun                   = "Wait for Run"
	CephDaemonStateWaitForReady                 = "Wait for Ready"
	CephDaemonStateReady                        = "Ready"
	CephDaemonStateError                        = "Error"
	CephDaemonStateCleanup                      = "Cleanup"
)
View Source 
const (
	CephDaemonClusterStateIdle    CephDaemonClusterState = "Idle"
	CephDaemonClusterStateRunning                        = "Running"
	CephDaemonClusterStateScaling                        = "Scaling"
	CephDaemonClusterStateError                          = "Error"
)
View Source 
const MonQuorumPodCondition corev1.PodConditionType = corev1.PodReady

Variables

View Source 
var (
	// SchemeGroupVersion is group version used to register these objects
	SchemeGroupVersion = schema.GroupVersion{Group: "ceph.k8s.pgc.umn.edu", Version: "v1alpha1"}

	// SchemeBuilder is used to add go types to the GroupVersionKind scheme
	SchemeBuilder = &scheme.Builder{GroupVersion: SchemeGroupVersion}
)

Functions

This section is empty.

Types

type CephCluster 

type CephCluster struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   CephClusterSpec   `json:"spec,omitempty"`
	Status CephClusterStatus `json:"status,omitempty"`
}

CephCluster is the Schema for the cephclusters API +k8s:openapi-gen=true

func (*CephCluster) DeepCopy 

func (in *CephCluster) DeepCopy() *CephCluster

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CephCluster.

func (*CephCluster) DeepCopyInto 

func (in *CephCluster) DeepCopyInto(out *CephCluster)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*CephCluster) DeepCopyObject 

func (in *CephCluster) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*CephCluster) GetAPIVersion 

func (c *CephCluster) GetAPIVersion() string

func (*CephCluster) GetCephConfigMap 

func (c *CephCluster) GetCephConfigMap() (*corev1.ConfigMap, error)

GetCephConfigMap returns a configmap containing a vaild ceph.conf file.

func (*CephCluster) GetCephConfigMapName 

func (c *CephCluster) GetCephConfigMapName() string

func (*CephCluster) GetDaemonEnabled 

func (c *CephCluster) GetDaemonEnabled(d CephDaemonType) bool

func (*CephCluster) GetKind 

func (c *CephCluster) GetKind() string

func (*CephCluster) GetMdsImage 

func (c *CephCluster) GetMdsImage() string

func (*CephCluster) GetMgrImage 

func (c *CephCluster) GetMgrImage() string

func (*CephCluster) GetMonImage 

func (c *CephCluster) GetMonImage() string

func (*CephCluster) GetMonitorDiscoveryService 

func (c *CephCluster) GetMonitorDiscoveryService() *corev1.Service

func (*CephCluster) GetMonitorService 

func (c *CephCluster) GetMonitorService() *corev1.Service

func (*CephCluster) GetOsdImage 

func (c *CephCluster) GetOsdImage() string

func (*CephCluster) GetState 

func (d *CephCluster) GetState() CephClusterState

func (*CephCluster) SetAPIVersion 

func (c *CephCluster) SetAPIVersion(version string)

func (*CephCluster) SetKind 

func (c *CephCluster) SetKind(kind string)

func (*CephCluster) SetState 

func (d *CephCluster) SetState(s CephClusterState)

type CephClusterList 

type CephClusterList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []CephCluster `json:"items"`
}

CephClusterList contains a list of CephCluster

func (*CephClusterList) DeepCopy 

func (in *CephClusterList) DeepCopy() *CephClusterList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CephClusterList.

func (*CephClusterList) DeepCopyInto 

func (in *CephClusterList) DeepCopyInto(out *CephClusterList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*CephClusterList) DeepCopyObject 

func (in *CephClusterList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type CephClusterSpec 

type CephClusterSpec struct {
	Disabled       bool                         `json:"disabled"`
	Config         map[string]map[string]string `json:"config"`
	Fsid           string                       `json:"fsid"`
	MonServiceName string                       `json:"monServiceName"`
	ClusterDomain  string                       `json:"clusterDomain"`
	MonImage       ImageSpec                    `json:"monImage"`
	OsdImage       ImageSpec                    `json:"osdImage"`
	MgrImage       ImageSpec                    `json:"mgrImage"`
	MdsImage       ImageSpec                    `json:"mdsImage"`
}

CephClusterSpec defines the desired state of CephCluster

func (*CephClusterSpec) DeepCopy 

func (in *CephClusterSpec) DeepCopy() *CephClusterSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CephClusterSpec.

func (*CephClusterSpec) DeepCopyInto 

func (in *CephClusterSpec) DeepCopyInto(out *CephClusterSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type CephClusterState 

type CephClusterState string
const (
	CephClusterIdle         CephClusterState = "Idle"
	CephClusterStartMons    CephClusterState = "Start Mons"
	CephClusterStartDaemons CephClusterState = "Start Daemons"
	CephClusterStartOsds    CephClusterState = "Start Osds"
	CephClusterRunning      CephClusterState = "Running"
	CephClusterShutdown     CephClusterState = "Starting Shutdown"
	CephClusterStopDaemons  CephClusterState = "Stop Daemons"
	CephClusterStopOsds     CephClusterState = "Stop Osds"
	CephClusterStopMons     CephClusterState = "Stop Mons"
)

type CephClusterStatus 

type CephClusterStatus struct {
	MonClusterName string           `json:"monClusterName"`
	State          CephClusterState `json:"state"`
}

CephClusterStatus defines the observed state of CephCluster

func (*CephClusterStatus) DeepCopy 

func (in *CephClusterStatus) DeepCopy() *CephClusterStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CephClusterStatus.

func (*CephClusterStatus) DeepCopyInto 

func (in *CephClusterStatus) DeepCopyInto(out *CephClusterStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type CephDaemon 

type CephDaemon struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   CephDaemonSpec   `json:"spec,omitempty"`
	Status CephDaemonStatus `json:"status,omitempty"`
}

CephDaemon is the Schema for the cephdaemons API +k8s:openapi-gen=true

func NewCephDaemon 

func NewCephDaemon(t CephDaemonType, clusterName string) *CephDaemon

func (*CephDaemon) CheckReady 

func (d *CephDaemon) CheckReady() bool

CheckReady returns true if the daemon is ready

func (*CephDaemon) DeepCopy 

func (in *CephDaemon) DeepCopy() *CephDaemon

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CephDaemon.

func (*CephDaemon) DeepCopyInto 

func (in *CephDaemon) DeepCopyInto(out *CephDaemon)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*CephDaemon) DeepCopyObject 

func (in *CephDaemon) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*CephDaemon) GetBasePod 

func (d *CephDaemon) GetBasePod() *corev1.Pod

func (*CephDaemon) GetPodName 

func (d *CephDaemon) GetPodName() string

func (*CephDaemon) GetState 

func (d *CephDaemon) GetState() CephDaemonState

func (*CephDaemon) SetState 

func (d *CephDaemon) SetState(s CephDaemonState)

type CephDaemonCluster 

type CephDaemonCluster struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   CephDaemonClusterSpec   `json:"spec,omitempty"`
	Status CephDaemonClusterStatus `json:"status,omitempty"`
}

CephDaemonCluster is the Schema for the cephdaemonclusters API +k8s:openapi-gen=true

func NewCephDaemonCluster 

func NewCephDaemonCluster(t CephDaemonType) *CephDaemonCluster

func (*CephDaemonCluster) DeepCopy 

func (in *CephDaemonCluster) DeepCopy() *CephDaemonCluster

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CephDaemonCluster.

func (*CephDaemonCluster) DeepCopyInto 

func (in *CephDaemonCluster) DeepCopyInto(out *CephDaemonCluster)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*CephDaemonCluster) DeepCopyObject 

func (in *CephDaemonCluster) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*CephDaemonCluster) GetCephClusterName 

func (c *CephDaemonCluster) GetCephClusterName() string

func (*CephDaemonCluster) GetCephConfConfigMapName 

func (c *CephDaemonCluster) GetCephConfConfigMapName() string

func (*CephDaemonCluster) GetDaemonType 

func (c *CephDaemonCluster) GetDaemonType() CephDaemonType

func (*CephDaemonCluster) GetImage 

func (c *CephDaemonCluster) GetImage() ImageSpec

func (*CephDaemonCluster) GetState 

func (d *CephDaemonCluster) GetState() CephDaemonClusterState

func (*CephDaemonCluster) SetCephClusterName 

func (c *CephDaemonCluster) SetCephClusterName(name string)

func (*CephDaemonCluster) SetCephConfConfigMapName 

func (c *CephDaemonCluster) SetCephConfConfigMapName(name string)

func (*CephDaemonCluster) SetImage 

func (c *CephDaemonCluster) SetImage(image ImageSpec)

func (*CephDaemonCluster) SetState 

func (d *CephDaemonCluster) SetState(s CephDaemonClusterState)

type CephDaemonClusterList 

type CephDaemonClusterList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []CephDaemonCluster `json:"items"`
}

CephDaemonClusterList contains a list of CephDaemonCluster

func (*CephDaemonClusterList) AllInState 

func (c *CephDaemonClusterList) AllInState(state CephDaemonClusterState) bool

func (*CephDaemonClusterList) DeepCopy 

func (in *CephDaemonClusterList) DeepCopy() *CephDaemonClusterList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CephDaemonClusterList.

func (*CephDaemonClusterList) DeepCopyInto 

func (in *CephDaemonClusterList) DeepCopyInto(out *CephDaemonClusterList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*CephDaemonClusterList) DeepCopyObject 

func (in *CephDaemonClusterList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type CephDaemonClusterSpec 

type CephDaemonClusterSpec struct {
	ClusterName           string         `json:"clusterName"`
	Image                 ImageSpec      `json:"image"`
	CephConfConfigMapName string         `json:"cephConfConfigMapName"`
	DaemonType            CephDaemonType `json:"daemonType"`
	Disabled              bool           `json:"disabled"`
	Replicas              int            `json:"replicas"`
}

CephDaemonClusterSpec defines the desired state of CephDaemonCluster

func (*CephDaemonClusterSpec) DeepCopy 

func (in *CephDaemonClusterSpec) DeepCopy() *CephDaemonClusterSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CephDaemonClusterSpec.

func (*CephDaemonClusterSpec) DeepCopyInto 

func (in *CephDaemonClusterSpec) DeepCopyInto(out *CephDaemonClusterSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type CephDaemonClusterState 

type CephDaemonClusterState string

type CephDaemonClusterStatus 

type CephDaemonClusterStatus struct {
	State CephDaemonClusterState `json:"state"`
}

CephDaemonClusterStatus defines the observed state of CephDaemonCluster

func (*CephDaemonClusterStatus) DeepCopy 

func (in *CephDaemonClusterStatus) DeepCopy() *CephDaemonClusterStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CephDaemonClusterStatus.

func (*CephDaemonClusterStatus) DeepCopyInto 

func (in *CephDaemonClusterStatus) DeepCopyInto(out *CephDaemonClusterStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type CephDaemonList 

type CephDaemonList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []CephDaemon `json:"items"`
}

CephDaemonList contains a list of CephDaemon

func (*CephDaemonList) DeepCopy 

func (in *CephDaemonList) DeepCopy() *CephDaemonList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CephDaemonList.

func (*CephDaemonList) DeepCopyInto 

func (in *CephDaemonList) DeepCopyInto(out *CephDaemonList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*CephDaemonList) DeepCopyObject 

func (in *CephDaemonList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type CephDaemonSpec 

type CephDaemonSpec struct {
	ClusterName           string         `json:"clusterName"`
	ID                    string         `json:"id"`
	Image                 ImageSpec      `json:"image"`
	CephConfConfigMapName string         `json:"cephConfConfigMapName"`
	DaemonType            CephDaemonType `json:"daemonType"`
	Disabled              bool           `json:"disabled"`
}

CephDaemonSpec defines the desired state of CephDaemon

func (*CephDaemonSpec) DeepCopy 

func (in *CephDaemonSpec) DeepCopy() *CephDaemonSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CephDaemonSpec.

func (*CephDaemonSpec) DeepCopyInto 

func (in *CephDaemonSpec) DeepCopyInto(out *CephDaemonSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type CephDaemonState 

type CephDaemonState string

type CephDaemonStatus 

type CephDaemonStatus struct {
	State CephDaemonState `json:"state"`
}

CephDaemonStatus defines the observed state of CephDaemon

func (*CephDaemonStatus) DeepCopy 

func (in *CephDaemonStatus) DeepCopy() *CephDaemonStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CephDaemonStatus.

func (*CephDaemonStatus) DeepCopyInto 

func (in *CephDaemonStatus) DeepCopyInto(out *CephDaemonStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type CephDaemonType 

type CephDaemonType string
const (
	CephDaemonTypeMgr CephDaemonType = "mgr"
	CephDaemonTypeMds CephDaemonType = "mds"
	CephDaemonTypeRgw CephDaemonType = "rgw"
	CephDaemonTypeOsd CephDaemonType = "osd"
	CephDaemonTypeMon CephDaemonType = "mon"
)

func (CephDaemonType) String 

func (c CephDaemonType) String() string

type CephMon 

type CephMon struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   CephMonSpec   `json:"spec,omitempty"`
	Status CephMonStatus `json:"status,omitempty"`
}

CephMon is the Schema for the cephmons API +k8s:openapi-gen=true

func (*CephMon) CheckMonState 

func (c *CephMon) CheckMonState(state ...MonState) bool

func (*CephMon) DeepCopy 

func (in *CephMon) DeepCopy() *CephMon

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CephMon.

func (*CephMon) DeepCopyInto 

func (in *CephMon) DeepCopyInto(out *CephMon)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*CephMon) DeepCopyObject 

func (in *CephMon) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*CephMon) GetAPIVersion 

func (m *CephMon) GetAPIVersion() string

func (*CephMon) GetDisabled 

func (m *CephMon) GetDisabled() bool

func (*CephMon) GetKind 

func (m *CephMon) GetKind() string

func (*CephMon) GetMonMapEntry 

func (c *CephMon) GetMonMapEntry() MonMapEntry

func (*CephMon) GetMonState 

func (c *CephMon) GetMonState() MonState

func (*CephMon) GetPod 

func (m *CephMon) GetPod(monCluster *CephMonCluster, clientAdminKeyringName string) *corev1.Pod

func (*CephMon) GetPodName 

func (m *CephMon) GetPodName() string

func (*CephMon) GetPort 

func (c *CephMon) GetPort() int

func (*CephMon) GetPvLabelSelector 

func (m *CephMon) GetPvLabelSelector() (*metav1.LabelSelector, error)

func (*CephMon) GetVolumeClaimTemplate 

func (m *CephMon) GetVolumeClaimTemplate() (*corev1.PersistentVolumeClaim, error)

func (*CephMon) SetAPIVersion 

func (m *CephMon) SetAPIVersion(version string)

func (*CephMon) SetKind 

func (m *CephMon) SetKind(kind string)

func (*CephMon) SetMonState 

func (c *CephMon) SetMonState(state MonState)

type CephMonCluster 

type CephMonCluster struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   CephMonClusterSpec   `json:"spec,omitempty"`
	Status CephMonClusterStatus `json:"status,omitempty"`
}

CephMonCluster is the Schema for the cephmonclusters API +k8s:openapi-gen=true

func (*CephMonCluster) CheckMonClusterState 

func (c *CephMonCluster) CheckMonClusterState(state ...MonClusterState) bool

func (*CephMonCluster) DeepCopy 

func (in *CephMonCluster) DeepCopy() *CephMonCluster

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CephMonCluster.

func (*CephMonCluster) DeepCopyInto 

func (in *CephMonCluster) DeepCopyInto(out *CephMonCluster)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*CephMonCluster) DeepCopyObject 

func (in *CephMonCluster) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*CephMonCluster) GetCephClusterName 

func (c *CephMonCluster) GetCephClusterName() string

func (*CephMonCluster) GetCephConfConfigMapName 

func (c *CephMonCluster) GetCephConfConfigMapName() string

func (*CephMonCluster) GetConfigMapName 

func (c *CephMonCluster) GetConfigMapName() string

func (*CephMonCluster) GetDaemonType 

func (c *CephMonCluster) GetDaemonType() CephDaemonType

func (*CephMonCluster) GetImage 

func (c *CephMonCluster) GetImage() ImageSpec

func (*CephMonCluster) GetMonClusterState 

func (c *CephMonCluster) GetMonClusterState() MonClusterState

func (*CephMonCluster) GetMonMapConfigMap 

func (c *CephMonCluster) GetMonMapConfigMap(monMap MonMap) (*corev1.ConfigMap, error)

func (*CephMonCluster) SetCephClusterName 

func (c *CephMonCluster) SetCephClusterName(name string)

func (*CephMonCluster) SetCephConfConfigMapName 

func (c *CephMonCluster) SetCephConfConfigMapName(name string)

func (*CephMonCluster) SetImage 

func (c *CephMonCluster) SetImage(image ImageSpec)

func (*CephMonCluster) SetMonClusterState 

func (c *CephMonCluster) SetMonClusterState(state MonClusterState)

type CephMonClusterList 

type CephMonClusterList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []CephMonCluster `json:"items"`
}

CephMonClusterList contains a list of CephMonCluster

func (*CephMonClusterList) AllInState 

func (c *CephMonClusterList) AllInState(state MonClusterState) bool

func (*CephMonClusterList) DeepCopy 

func (in *CephMonClusterList) DeepCopy() *CephMonClusterList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CephMonClusterList.

func (*CephMonClusterList) DeepCopyInto 

func (in *CephMonClusterList) DeepCopyInto(out *CephMonClusterList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*CephMonClusterList) DeepCopyObject 

func (in *CephMonClusterList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type CephMonClusterSpec 

type CephMonClusterSpec struct {
	ClusterName           string    `json:"clusterName"`
	Image                 ImageSpec `json:"image"`
	CephConfConfigMapName string    `json:"cephConfConfigMapName"`
}

CephMonClusterSpec defines the desired state of CephMonCluster

func (*CephMonClusterSpec) DeepCopy 

func (in *CephMonClusterSpec) DeepCopy() *CephMonClusterSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CephMonClusterSpec.

func (*CephMonClusterSpec) DeepCopyInto 

func (in *CephMonClusterSpec) DeepCopyInto(out *CephMonClusterSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type CephMonClusterStatus 

type CephMonClusterStatus struct {
	StartEpoch int             `json:"monStartEpoch"`
	State      MonClusterState `json:"monClusterState"`
}

CephMonClusterStatus defines the observed state of CephMonCluster

func (*CephMonClusterStatus) DeepCopy 

func (in *CephMonClusterStatus) DeepCopy() *CephMonClusterStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CephMonClusterStatus.

func (*CephMonClusterStatus) DeepCopyInto 

func (in *CephMonClusterStatus) DeepCopyInto(out *CephMonClusterStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type CephMonList 

type CephMonList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []CephMon `json:"items"`
}

CephMonList contains a list of CephMon

func (*CephMonList) DeepCopy 

func (in *CephMonList) DeepCopy() *CephMonList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CephMonList.

func (*CephMonList) DeepCopyInto 

func (in *CephMonList) DeepCopyInto(out *CephMonList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*CephMonList) DeepCopyObject 

func (in *CephMonList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type CephMonSpec 

type CephMonSpec struct {
	ClusterName      string `json:"clusterName"`
	ID               string `json:"id"`
	PvSelectorString string `json:"pvSelectorString"`
	Disabled         bool   `json:"disabled"`
	Port             int    `json:"port"`
}

CephMonSpec defines the desired state of CephMon

func (*CephMonSpec) DeepCopy 

func (in *CephMonSpec) DeepCopy() *CephMonSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CephMonSpec.

func (*CephMonSpec) DeepCopyInto 

func (in *CephMonSpec) DeepCopyInto(out *CephMonSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type CephMonStatus 

type CephMonStatus struct {
	StartEpoch   int      `json:"startEpoch"`
	State        MonState `json:"monState"`
	PodIP        net.IP   `json:"podIP"`
	InitalMember bool     `json:"initalMember"`
}

CephMonStatus defines the observed state of CephMon

func (*CephMonStatus) DeepCopy 

func (in *CephMonStatus) DeepCopy() *CephMonStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CephMonStatus.

func (*CephMonStatus) DeepCopyInto 

func (in *CephMonStatus) DeepCopyInto(out *CephMonStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type CephOsd 

type CephOsd struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   CephOsdSpec   `json:"spec,omitempty"`
	Status CephOsdStatus `json:"status,omitempty"`
}

CephOsd is the Schema for the cephosds API +k8s:openapi-gen=true

func (*CephOsd) DeepCopy 

func (in *CephOsd) DeepCopy() *CephOsd

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CephOsd.

func (*CephOsd) DeepCopyInto 

func (in *CephOsd) DeepCopyInto(out *CephOsd)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*CephOsd) DeepCopyObject 

func (in *CephOsd) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*CephOsd) GetAPIVersion 

func (o *CephOsd) GetAPIVersion() string

func (*CephOsd) GetDisabled 

func (o *CephOsd) GetDisabled() bool

func (*CephOsd) GetKind 

func (o *CephOsd) GetKind() string

func (*CephOsd) GetPod 

func (o *CephOsd) GetPod(osdImage, cephConfConfigMap, serviceAccountName string) *corev1.Pod

func (*CephOsd) GetPodName 

func (o *CephOsd) GetPodName() string

func (*CephOsd) GetPvLabelSelector 

func (o *CephOsd) GetPvLabelSelector() (*metav1.LabelSelector, error)

func (*CephOsd) GetVolumeClaimTemplate 

func (o *CephOsd) GetVolumeClaimTemplate() (*corev1.PersistentVolumeClaim, error)

func (*CephOsd) SetAPIVersion 

func (o *CephOsd) SetAPIVersion(version string)

func (*CephOsd) SetKind 

func (o *CephOsd) SetKind(kind string)

type CephOsdList 

type CephOsdList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []CephOsd `json:"items"`
}

CephOsdList contains a list of CephOsd

func (*CephOsdList) DeepCopy 

func (in *CephOsdList) DeepCopy() *CephOsdList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CephOsdList.

func (*CephOsdList) DeepCopyInto 

func (in *CephOsdList) DeepCopyInto(out *CephOsdList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*CephOsdList) DeepCopyObject 

func (in *CephOsdList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type CephOsdSpec 

type CephOsdSpec struct {
	ID               int    `json:"id"`
	ClusterName      string `json:"clusterName"`
	PvSelectorString string `json:"pvSelectorString"`
	Disabled         bool   `json:"disabled"`
}

CephOsdSpec defines the desired state of CephOsd

func (*CephOsdSpec) DeepCopy 

func (in *CephOsdSpec) DeepCopy() *CephOsdSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CephOsdSpec.

func (*CephOsdSpec) DeepCopyInto 

func (in *CephOsdSpec) DeepCopyInto(out *CephOsdSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type CephOsdStatus 

type CephOsdStatus struct {
}

CephOsdStatus defines the observed state of CephOsd

func (*CephOsdStatus) DeepCopy 

func (in *CephOsdStatus) DeepCopy() *CephOsdStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CephOsdStatus.

func (*CephOsdStatus) DeepCopyInto 

func (in *CephOsdStatus) DeepCopyInto(out *CephOsdStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type DaemonEnabledStateMap 

type DaemonEnabledStateMap map[CephDaemonType][]CephClusterState
var DaemonEnabledStates DaemonEnabledStateMap = DaemonEnabledStateMap{
	CephDaemonTypeMgr: []CephClusterState{
		CephClusterRunning, CephClusterStartDaemons, CephClusterStartOsds, CephClusterShutdown,
	},
	CephDaemonTypeMds: []CephClusterState{
		CephClusterRunning, CephClusterStartDaemons, CephClusterStartOsds, CephClusterShutdown,
	},
	CephDaemonTypeRgw: []CephClusterState{
		CephClusterRunning, CephClusterStartDaemons, CephClusterStartOsds, CephClusterShutdown,
	},
	CephDaemonTypeOsd: []CephClusterState{
		CephClusterRunning, CephClusterStartOsds, CephClusterStopDaemons, CephClusterShutdown,
	},
	CephDaemonTypeMon: []CephClusterState{
		CephClusterRunning, CephClusterStartMons, CephClusterStartDaemons, CephClusterStartOsds, CephClusterStopDaemons, CephClusterStopOsds, CephClusterShutdown,
	},
}

type ImageSpec 

type ImageSpec struct {
	Registry string `json:"registry"`
	Tag      string `json:"tag"`
}

func (*ImageSpec) DeepCopy 

func (in *ImageSpec) DeepCopy() *ImageSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ImageSpec.

func (*ImageSpec) DeepCopyInto 

func (in *ImageSpec) DeepCopyInto(out *ImageSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (ImageSpec) String 

func (i ImageSpec) String() string

type JsonMonMap 

type JsonMonMap MonMap

func (JsonMonMap) DeepCopy 

func (in JsonMonMap) DeepCopy() JsonMonMap

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new JsonMonMap.

func (JsonMonMap) DeepCopyInto 

func (in JsonMonMap) DeepCopyInto(out *JsonMonMap)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (JsonMonMap) MarshalJSON 

func (m JsonMonMap) MarshalJSON() ([]byte, error)

type MonClusterState 

type MonClusterState string
const (
	MonClusterIdle               MonClusterState = "Idle"
	MonClusterLaunching          MonClusterState = "Launching"
	MonClusterEstablishingQuorum MonClusterState = "Establishing Quorum"
	MonClusterInQuorum           MonClusterState = "In Quorum"
	MonClusterLostQuorum         MonClusterState = "Lost Quorum"
)

type MonMap 

type MonMap map[string]MonMapEntry

func (MonMap) AllInState 

func (m MonMap) AllInState(state MonState) bool

func (MonMap) Contains 

func (m MonMap) Contains(mon *CephMon) bool

func (MonMap) CountInState 

func (m MonMap) CountInState(state MonState) int

func (MonMap) CountInitalMembers 

func (m MonMap) CountInitalMembers() int

func (MonMap) DeepCopy 

func (in MonMap) DeepCopy() MonMap

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MonMap.

func (MonMap) DeepCopyInto 

func (in MonMap) DeepCopyInto(out *MonMap)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (MonMap) Empty 

func (m MonMap) Empty() bool

func (MonMap) GetInitalMonMap 

func (m MonMap) GetInitalMonMap() MonMap

func (MonMap) GetRandomEntry 

func (m MonMap) GetRandomEntry() MonMapEntry

func (MonMap) QuorumAtEpoch 

func (m MonMap) QuorumAtEpoch(epoch int) bool

func (MonMap) QuorumCount 

func (m MonMap) QuorumCount() int

type MonMapEntry 

type MonMapEntry struct {
	IP             net.IP
	Port           int
	StartEpoch     int
	State          MonState
	InitalMember   bool
	NamespacedName types.NamespacedName
}

func (*MonMapEntry) DeepCopy 

func (in *MonMapEntry) DeepCopy() *MonMapEntry

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MonMapEntry.

func (*MonMapEntry) DeepCopyInto 

func (in *MonMapEntry) DeepCopyInto(out *MonMapEntry)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type MonState 

type MonState string

MonState describes the state of the monitor 

const (
	MonLaunchPod       MonState = "Launch Pod"
	MonWaitForPodRun   MonState = "Wait for Pod Run"
	MonWaitForPodReady MonState = "Wait for Pod Ready"
	MonInQuorum        MonState = "In Quorum"
	MonError           MonState = "Error"
	MonCleanup         MonState = "Cleanup"
	MonIdle            MonState = "Idle"
)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.