Merge pull request #1262 from nats-io/fix_1261

Add RecordSizeLimit to AllOptions
nats-io · Jul 22, 2022 · 2f0c582 · 2f0c582
2 parents 07ec793 + 4928491
commit 2f0c582
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 1 deletion.
diff --git a/stores/filestore.go b/stores/filestore.go
@@ -433,6 +433,9 @@ func AllOptions(opts *FileStoreOptions) FileStoreOption {
 		if err := AutoSync(opts.AutoSync)(o); err != nil {
 			return err
 		}
+		if err := RecordSizeLimit(opts.RecordSizeLimit)(o); err != nil {
+			return err
+		}
 		o.CompactEnabled = opts.CompactEnabled
 		o.DoCRC = opts.DoCRC
 		o.DoSync = opts.DoSync

diff --git a/stores/filestore_test.go b/stores/filestore_test.go
@@ -578,6 +578,7 @@ func TestFSOptions(t *testing.T) {
 		ParallelRecovery:     5,
 		ReadBufferSize:       5 * 1024,
 		AutoSync:             2 * time.Minute,
+		RecordSizeLimit:      1024 * 1024,
 	}
 	// Create the file with custom options
 	fs, err := NewFileStore(testLogger, testFSDefaultDatastore, &testDefaultStoreLimits,
@@ -593,7 +594,9 @@ func TestFSOptions(t *testing.T) {
 		FileDescriptorsLimit(20),
 		ParallelRecovery(5),
 		ReadBufferSize(5*1024),
-		AutoSync(2*time.Minute))
+		AutoSync(2*time.Minute),
+		RecordSizeLimit(1024*1024),
+	)
 	if err != nil {
 		t.Fatalf("Unexpected error on file store create: %v", err)
 	}