Add the coldWritesEnabled option to Namespace options

m3db · Sep 10, 2020 · 030a255 · 030a255
1 parent 8cf55a0
commit 030a255
Show file tree

Hide file tree

Showing 5 changed files with 8 additions and 0 deletions.
diff --git a/docs/api.md b/docs/api.md
@@ -180,6 +180,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)
 

diff --git a/docs/configuration/namespaces.md b/docs/configuration/namespaces.md
@@ -59,6 +59,7 @@ spec:
       indexOptions:
         enabled: true
         blockSize: 12h
+      coldWritesEnabled: true
 ```
 
 

diff --git a/pkg/apis/m3dboperator/v1alpha1/namespace.go b/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"`
 }
diff --git a/pkg/m3admin/namespace/namespace.go b/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
 }
 

diff --git a/pkg/m3admin/namespace/presets.go b/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,
 	}
 )