Add the coldWritesEnabled option to Namespace options (#233)

Co-authored-by: Matt Schallert <[email protected]>

Author: EdgeJ

docs/api.md

@@ -181,6 +181,7 @@ NamespaceOptions defines parameters for an M3DB namespace. See https://m3db.gith
 | snapshotEnabled | SnapshotEnabled controls whether snapshotting is enabled. | bool | false |
 | retentionOptions | RetentionOptions sets the retention parameters. | [RetentionOptions](#retentionoptions) | false |
 | indexOptions | IndexOptions sets the indexing parameters. | [IndexOptions](#indexoptions) | false |
+| coldWritesEnabled | ColdWritesEnabled controls whether cold writes are enabled. | bool | false |
 
 [Back to TOC](#table-of-contents)
 

pkg/apis/m3dboperator/v1alpha1/namespace.go

@@ -90,4 +90,7 @@ type NamespaceOptions struct {
 
 	// IndexOptions sets the indexing parameters.
 	IndexOptions IndexOptions `json:"indexOptions,omitempty"`
+
+	// ColdWritesEnabled controls whether cold writes are enabled.
+	ColdWritesEnabled bool `json:"coldWritesEnabled,omitempty"`
 }

pkg/controller/add_cluster_test.go

@@ -27,10 +27,10 @@ import (
 
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 
-	"k8s.io/utils/pointer"
 	"github.com/rakyll/statik/fs"
 	"github.com/stretchr/testify/assert"
 	"github.com/stretchr/testify/require"
+	"k8s.io/utils/pointer"
 )
 
 func registerValidConfigMap(content string) error {

pkg/controller/update_cluster_test.go

@@ -31,8 +31,8 @@ import (
 
 	myspec "github.com/m3db/m3db-operator/pkg/apis/m3dboperator/v1alpha1"
 	crdfake "github.com/m3db/m3db-operator/pkg/client/clientset/versioned/fake"
-	"github.com/m3db/m3db-operator/pkg/k8sops/m3db"
 	"github.com/m3db/m3db-operator/pkg/k8sops/labels"
+	"github.com/m3db/m3db-operator/pkg/k8sops/m3db"
 	"github.com/m3db/m3db-operator/pkg/k8sops/podidentity"
 	"github.com/m3db/m3db-operator/pkg/m3admin"
 

pkg/k8sops/m3db/config_map_test.go

@@ -28,10 +28,10 @@ import (
 
 	corev1 "k8s.io/api/core/v1"
 
-	"k8s.io/utils/pointer"
 	"github.com/rakyll/statik/fs"
 	"github.com/stretchr/testify/assert"
 	"github.com/stretchr/testify/require"
+	"k8s.io/utils/pointer"
 )
 
 func registerValidConfigMap() error {

pkg/m3admin/namespace/namespace.go

@@ -99,6 +99,7 @@ func m3dbNamespaceOptsFromSpec(opts *myspec.NamespaceOptions) (*m3ns.NamespaceOp
 		RetentionOptions:  retentionOpts,
 		SnapshotEnabled:   opts.SnapshotEnabled,
 		IndexOptions:      indexOpts,
+		ColdWritesEnabled: opts.ColdWritesEnabled,
 	}, nil
 }
 

pkg/m3admin/namespace/presets.go

@@ -61,6 +61,7 @@ var (
 			Enabled:   true,
 			BlockSize: (2 * time.Hour).String(),
 		},
+		ColdWritesEnabled: false,
 	}
 
 	presetOneMinuteFourtyDaysIndexed = myspec.NamespaceOptions{
@@ -82,5 +83,6 @@ var (
 			Enabled:   true,
 			BlockSize: (24 * time.Hour).String(),
 		},
+		ColdWritesEnabled: false,
 	}
 )