Add support for master volume size

Author: komljen

README.md

@@ -36,6 +36,7 @@ Following parameters are available to customize the elastic cluster:
 - data-node-replicas: Number of data node replicas
 - zones: Define which zones to deploy data nodes to for high availability (_Note: Zones are evenly distributed based upon number of data-node-replicas defined_)
 - data-volume-size: Size of persistent volume to attach to data nodes
+- master-volume-size: Size of persistent volume to attach to master nodes
 - elastic-search-image: Override the elasticsearch image (e.g. `upmcenterprises/docker-elasticsearch-kubernetes:6.1.3_0`)
 - keep-secrets-on-delete (Boolean): Tells the operator to not delete cert secrets when a cluster is deleted
 - use-ssl: Use SSL for communication with the cluster and inside the cluster. Default value is true.
@@ -107,6 +108,7 @@ spec:
   client-node-replicas: 3
   data-node-replicas: 3
   data-volume-size: 10Gi
+  master-volume-size: 10Gi
   java-options: -Xms256m -Xmx256m
   master-node-replicas: 2
   image-pull-secrets:
@@ -274,6 +276,7 @@ spec:
   client-node-replicas: 3
   data-node-replicas: 3
   data-volume-size: 10Gi
+  master-volume-size: 10Gi
   java-options: -Xms256m -Xmx256m
   master-node-replicas: 2
   snapshot:

example/example-es-cluster-azure.yaml

@@ -10,6 +10,7 @@ spec:
   network-host: 0.0.0.0
   zones: []
   data-volume-size: 10Gi
+  master-volume-size: 10Gi
   java-options: "-Xms1024m -Xmx1024m"
   snapshot:
     scheduler-enabled: false

example/example-es-cluster-gke.yaml

@@ -15,6 +15,7 @@ spec:
   zones:
   - us-east1-d
   data-volume-size: 10Gi
+  master-volume-size: 10Gi
   java-options: "-Xms512m -Xmx512m"
   snapshot:
     scheduler-enabled: false

example/example-es-cluster-hostpath.yaml

@@ -14,6 +14,7 @@ spec:
   network-host: 0.0.0.0
   zones: []
   data-volume-size: 10Gi
+  master-volume-size: 10Gi
   java-options: "-Xms512m -Xmx512m"
   snapshot:
     scheduler-enabled: false

example/example-es-cluster-ibm.yaml

@@ -71,6 +71,7 @@ spec:
   - dal12
   - dal13
   data-volume-size: 10Gi
+  master-volume-size: 10Gi
   java-options: "-Xms512m -Xmx512m"
   snapshot:  # Not verified with IBM Cloud Object Storage
     scheduler-enabled: false

example/example-es-cluster-minikube.yaml

@@ -17,6 +17,7 @@ spec:
   network-host: 0.0.0.0
   zones: []
   data-volume-size: 10Gi
+  master-volume-size: 10Gi
   java-options: "-Xms512m -Xmx512m"
   snapshot:
     scheduler-enabled: false

example/example-es-cluster-rook.yaml

@@ -12,6 +12,7 @@ spec:
   network-host: 0.0.0.0
   zones: []
   data-volume-size: 10Gi
+  master-volume-size: 10Gi
   java-options: "-Xms256m -Xmx256m"
   snapshot:
     scheduler-enabled: false

example/example-es-cluster.yaml

@@ -15,6 +15,7 @@ spec:
   zones:
   - us-east-2b
   data-volume-size: 10Gi
+  master-volume-size: 10Gi
   java-options: "-Xms512m -Xmx512m"
   snapshot:
     scheduler-enabled: false

pkg/apis/elasticsearchoperator/v1/cluster.go

@@ -87,6 +87,10 @@ type ClusterSpec struct {
 	// to the data nodes in the ES cluster
 	DataDiskSize string `json:"data-volume-size"`
 
+        // MasterDiskSize specifies how large the persistent volume should be attached
+        // to the master nodes in the ES cluster
+        MasterDiskSize string `json:"master-volume-size"`
+
 	// ElasticSearchImage specifies the docker image to use (optional)
 	ElasticSearchImage string `json:"elastic-search-image"`
 

pkg/processor/processor.go

@@ -161,6 +161,7 @@ func (p *Processor) refreshClusters() error {
 					DataNodeReplicas:    cluster.Spec.DataNodeReplicas,
 					Zones:               cluster.Spec.Zones,
 					DataDiskSize:        cluster.Spec.DataDiskSize,
+                                        MasterDiskSize:      cluster.Spec.MasterDiskSize,
 					JavaOptions:         cluster.Spec.JavaOptions,
 					ClientJavaOptions:   cluster.Spec.ClientJavaOptions,
 					DataJavaOptions:     cluster.Spec.DataJavaOptions,
@@ -395,7 +396,7 @@ func (p *Processor) processElasticSearchCluster(c *myspec.ElasticsearchCluster)
 
 		// Create Master Nodes
 		for index, count := range zoneDistributionMaster {
-			if err := p.k8sclient.CreateDataNodeDeployment("master", &count, baseImage, c.Spec.Zones[index], c.Spec.DataDiskSize, c.Spec.Resources,
+			if err := p.k8sclient.CreateDataNodeDeployment("master", &count, baseImage, c.Spec.Zones[index], c.Spec.MasterDiskSize, c.Spec.Resources,
 				c.Spec.ImagePullSecrets, c.Spec.ImagePullPolicy, c.Spec.ServiceAccountName, c.ObjectMeta.Name, c.Spec.Instrumentation.StatsdHost, c.Spec.NetworkHost,
 				c.ObjectMeta.Namespace, c.Spec.JavaOptions, c.Spec.MasterJavaOptions, c.Spec.DataJavaOptions, c.Spec.UseSSL, c.Spec.Scheduler.ElasticURL, c.Spec.NodeSelector, c.Spec.Tolerations); err != nil {
 				logrus.Error("Error creating master node deployment ", err)
@@ -422,7 +423,7 @@ func (p *Processor) processElasticSearchCluster(c *myspec.ElasticsearchCluster)
 
 		// Create Master Nodes
 		if err := p.k8sclient.CreateDataNodeDeployment("master", func() *int32 { i := int32(c.Spec.MasterNodeReplicas); return &i }(), baseImage, c.Spec.Storage.StorageClass,
-			c.Spec.DataDiskSize, c.Spec.Resources, c.Spec.ImagePullSecrets, c.Spec.ImagePullPolicy, c.Spec.ServiceAccountName, c.ObjectMeta.Name,
+			c.Spec.MasterDiskSize, c.Spec.Resources, c.Spec.ImagePullSecrets, c.Spec.ImagePullPolicy, c.Spec.ServiceAccountName, c.ObjectMeta.Name,
 			c.Spec.Instrumentation.StatsdHost, c.Spec.NetworkHost, c.ObjectMeta.Namespace, c.Spec.JavaOptions, c.Spec.MasterJavaOptions, c.Spec.DataJavaOptions, c.Spec.UseSSL, c.Spec.Scheduler.ElasticURL, c.Spec.NodeSelector, c.Spec.Tolerations); err != nil {
 			logrus.Error("Error creating master node deployment ", err)