diff --git a/PROJECT b/PROJECT index 157a8474..0ee9d756 100644 --- a/PROJECT +++ b/PROJECT @@ -25,4 +25,12 @@ resources: kind: OperatorConfig path: github.com/ceph/ceph-csi-operator/api/v1alpha1 version: v1alpha1 +- api: + crdVersion: v1 + namespaced: true + domain: ceph.io + group: csi + kind: CephCluster + path: github.com/ceph/ceph-csi-operator/api/v1alpha1 + version: v1alpha1 version: "3" diff --git a/api/v1alpha1/cephcluster_types.go b/api/v1alpha1/cephcluster_types.go new file mode 100644 index 00000000..c064003c --- /dev/null +++ b/api/v1alpha1/cephcluster_types.go @@ -0,0 +1,62 @@ +/* +Copyright 2024. + +Licensed under the Apache License, Version 2.0 (the "License"); +you may not use this file except in compliance with the License. +You may obtain a copy of the License at + + http://www.apache.org/licenses/LICENSE-2.0 + +Unless required by applicable law or agreed to in writing, software +distributed under the License is distributed on an "AS IS" BASIS, +WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +See the License for the specific language governing permissions and +limitations under the License. +*/ + +package v1alpha1 + +import ( + metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" +) + +// ReadAffinitySpec capture Ceph CSI read affinity settings +type ReadAffinitySpec struct { + CrushLocationLabels []string `json:"crushLocationLabels,omitempty"` +} + +// CephClusterSpec defines the desired state of CephCluster +type CephClusterSpec struct { + Monitors []string `json:"monitors"` + ReadAffinity ReadAffinitySpec `json:"readAffinity,omitempty"` + RbdMirrorDaemonCount int `json:"rbdMirrorDaemonCount,omitempty"` +} + +// CephClusterStatus defines the observed state of CephCluster +type CephClusterStatus struct { +} + +//+kubebuilder:object:root=true +//+kubebuilder:subresource:status + +// CephCluster is the Schema for the cephclusters API +type CephCluster struct { + metav1.TypeMeta `json:",inline"` + metav1.ObjectMeta `json:"metadata,omitempty"` + + Spec CephClusterSpec `json:"spec,omitempty"` + Status CephClusterStatus `json:"status,omitempty"` +} + +//+kubebuilder:object:root=true + +// CephClusterList contains a list of CephCluster +type CephClusterList struct { + metav1.TypeMeta `json:",inline"` + metav1.ListMeta `json:"metadata,omitempty"` + Items []CephCluster `json:"items"` +} + +func init() { + SchemeBuilder.Register(&CephCluster{}, &CephClusterList{}) +} diff --git a/api/v1alpha1/zz_generated.deepcopy.go b/api/v1alpha1/zz_generated.deepcopy.go index a6bda332..d126a661 100644 --- a/api/v1alpha1/zz_generated.deepcopy.go +++ b/api/v1alpha1/zz_generated.deepcopy.go @@ -26,6 +26,101 @@ import ( runtime "k8s.io/apimachinery/pkg/runtime" ) +// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil. +func (in *CephCluster) DeepCopyInto(out *CephCluster) { + *out = *in + out.TypeMeta = in.TypeMeta + in.ObjectMeta.DeepCopyInto(&out.ObjectMeta) + in.Spec.DeepCopyInto(&out.Spec) + out.Status = in.Status +} + +// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CephCluster. +func (in *CephCluster) DeepCopy() *CephCluster { + if in == nil { + return nil + } + out := new(CephCluster) + in.DeepCopyInto(out) + return out +} + +// DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object. +func (in *CephCluster) DeepCopyObject() runtime.Object { + if c := in.DeepCopy(); c != nil { + return c + } + return nil +} + +// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil. +func (in *CephClusterList) DeepCopyInto(out *CephClusterList) { + *out = *in + out.TypeMeta = in.TypeMeta + in.ListMeta.DeepCopyInto(&out.ListMeta) + if in.Items != nil { + in, out := &in.Items, &out.Items + *out = make([]CephCluster, len(*in)) + for i := range *in { + (*in)[i].DeepCopyInto(&(*out)[i]) + } + } +} + +// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CephClusterList. +func (in *CephClusterList) DeepCopy() *CephClusterList { + if in == nil { + return nil + } + out := new(CephClusterList) + in.DeepCopyInto(out) + return out +} + +// DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object. +func (in *CephClusterList) DeepCopyObject() runtime.Object { + if c := in.DeepCopy(); c != nil { + return c + } + return nil +} + +// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil. +func (in *CephClusterSpec) DeepCopyInto(out *CephClusterSpec) { + *out = *in + if in.Monitors != nil { + in, out := &in.Monitors, &out.Monitors + *out = make([]string, len(*in)) + copy(*out, *in) + } + in.ReadAffinity.DeepCopyInto(&out.ReadAffinity) +} + +// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CephClusterSpec. +func (in *CephClusterSpec) DeepCopy() *CephClusterSpec { + if in == nil { + return nil + } + out := new(CephClusterSpec) + in.DeepCopyInto(out) + return out +} + +// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil. +func (in *CephClusterStatus) DeepCopyInto(out *CephClusterStatus) { + *out = *in +} + +// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CephClusterStatus. +func (in *CephClusterStatus) DeepCopy() *CephClusterStatus { + if in == nil { + return nil + } + out := new(CephClusterStatus) + in.DeepCopyInto(out) + return out +} + // DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil. func (in *Driver) DeepCopyInto(out *Driver) { *out = *in @@ -526,3 +621,23 @@ func (in *ProvisionerSpec) DeepCopy() *ProvisionerSpec { in.DeepCopyInto(out) return out } + +// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil. +func (in *ReadAffinitySpec) DeepCopyInto(out *ReadAffinitySpec) { + *out = *in + if in.CrushLocationLabels != nil { + in, out := &in.CrushLocationLabels, &out.CrushLocationLabels + *out = make([]string, len(*in)) + copy(*out, *in) + } +} + +// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ReadAffinitySpec. +func (in *ReadAffinitySpec) DeepCopy() *ReadAffinitySpec { + if in == nil { + return nil + } + out := new(ReadAffinitySpec) + in.DeepCopyInto(out) + return out +} diff --git a/config/crd/bases/csi.ceph.io_cephclusters.yaml b/config/crd/bases/csi.ceph.io_cephclusters.yaml new file mode 100644 index 00000000..f827b362 --- /dev/null +++ b/config/crd/bases/csi.ceph.io_cephclusters.yaml @@ -0,0 +1,66 @@ +--- +apiVersion: apiextensions.k8s.io/v1 +kind: CustomResourceDefinition +metadata: + annotations: + controller-gen.kubebuilder.io/version: v0.14.0 + name: cephclusters.csi.ceph.io +spec: + group: csi.ceph.io + names: + kind: CephCluster + listKind: CephClusterList + plural: cephclusters + singular: cephcluster + scope: Namespaced + versions: + - name: v1alpha1 + schema: + openAPIV3Schema: + description: CephCluster is the Schema for the cephclusters API + properties: + apiVersion: + description: |- + APIVersion defines the versioned schema of this representation of an object. + Servers should convert recognized schemas to the latest internal value, and + may reject unrecognized values. + More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#resources + type: string + kind: + description: |- + Kind is a string value representing the REST resource this object represents. + Servers may infer this from the endpoint the client submits requests to. + Cannot be updated. + In CamelCase. + More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#types-kinds + type: string + metadata: + type: object + spec: + description: CephClusterSpec defines the desired state of CephCluster + properties: + monitors: + items: + type: string + type: array + rbdMirrorDaemonCount: + type: integer + readAffinity: + description: ReadAffinitySpec capture Ceph CSI read affinity settings + properties: + crushLocationLabels: + items: + type: string + type: array + type: object + required: + - monitors + type: object + status: + description: CephClusterStatus defines the observed state of CephCluster + type: object + type: object + served: true + storage: true + subresources: + status: {} diff --git a/config/crd/kustomization.yaml b/config/crd/kustomization.yaml index 49511d6b..05a28268 100644 --- a/config/crd/kustomization.yaml +++ b/config/crd/kustomization.yaml @@ -4,6 +4,7 @@ resources: - bases/csi.ceph.io_drivers.yaml - bases/csi.ceph.io_operatorconfigs.yaml +- bases/csi.ceph.io_cephclusters.yaml #+kubebuilder:scaffold:crdkustomizeresource patches: @@ -15,6 +16,7 @@ patches: # patches here are for enabling the CA injection for each CRD #- path: patches/cainjection_in_drivers.yaml #- path: patches/cainjection_in_operatorconfigs.yaml +#- path: patches/cainjection_in_cephclusters.yaml #+kubebuilder:scaffold:crdkustomizecainjectionpatch # [WEBHOOK] To enable webhook, uncomment the following section diff --git a/config/rbac/cephcluster_editor_role.yaml b/config/rbac/cephcluster_editor_role.yaml new file mode 100644 index 00000000..080a7b99 --- /dev/null +++ b/config/rbac/cephcluster_editor_role.yaml @@ -0,0 +1,27 @@ +# permissions for end users to edit cephclusters. +apiVersion: rbac.authorization.k8s.io/v1 +kind: ClusterRole +metadata: + labels: + app.kubernetes.io/name: ceph-csi-operator + app.kubernetes.io/managed-by: kustomize + name: cephcluster-editor-role +rules: +- apiGroups: + - csi.ceph.io + resources: + - cephclusters + verbs: + - create + - delete + - get + - list + - patch + - update + - watch +- apiGroups: + - csi.ceph.io + resources: + - cephclusters/status + verbs: + - get diff --git a/config/rbac/cephcluster_viewer_role.yaml b/config/rbac/cephcluster_viewer_role.yaml new file mode 100644 index 00000000..bcfe86ca --- /dev/null +++ b/config/rbac/cephcluster_viewer_role.yaml @@ -0,0 +1,23 @@ +# permissions for end users to view cephclusters. +apiVersion: rbac.authorization.k8s.io/v1 +kind: ClusterRole +metadata: + labels: + app.kubernetes.io/name: ceph-csi-operator + app.kubernetes.io/managed-by: kustomize + name: cephcluster-viewer-role +rules: +- apiGroups: + - csi.ceph.io + resources: + - cephclusters + verbs: + - get + - list + - watch +- apiGroups: + - csi.ceph.io + resources: + - cephclusters/status + verbs: + - get diff --git a/config/rbac/kustomization.yaml b/config/rbac/kustomization.yaml index 4e0aa287..615e5948 100644 --- a/config/rbac/kustomization.yaml +++ b/config/rbac/kustomization.yaml @@ -20,6 +20,8 @@ resources: # default, aiding admins in cluster management. Those roles are # not used by the Project itself. You can comment the following lines # if you do not want those helpers be installed with your Project. +- cephcluster_editor_role.yaml +- cephcluster_viewer_role.yaml - operatorconfig_editor_role.yaml - operatorconfig_viewer_role.yaml - driver_editor_role.yaml diff --git a/config/samples/csi_v1alpha1_cephcluster.yaml b/config/samples/csi_v1alpha1_cephcluster.yaml new file mode 100644 index 00000000..a8f35765 --- /dev/null +++ b/config/samples/csi_v1alpha1_cephcluster.yaml @@ -0,0 +1,9 @@ +apiVersion: csi.ceph.io/v1alpha1 +kind: CephCluster +metadata: + labels: + app.kubernetes.io/name: ceph-csi-operator + app.kubernetes.io/managed-by: kustomize + name: cephcluster-sample +spec: + # TODO(user): Add fields here diff --git a/config/samples/kustomization.yaml b/config/samples/kustomization.yaml index 11429b7a..f7d18956 100644 --- a/config/samples/kustomization.yaml +++ b/config/samples/kustomization.yaml @@ -2,4 +2,5 @@ resources: - csi_v1alpha1_driver.yaml - csi_v1alpha1_operatorconfig.yaml +- csi_v1alpha1_cephcluster.yaml #+kubebuilder:scaffold:manifestskustomizesamples