From 50a25881e21d12cf987e5e9e15afed305eca8ef4 Mon Sep 17 00:00:00 2001 From: Derek Collison Date: Fri, 29 Jul 2022 08:10:57 -0700 Subject: [PATCH] Encrypt meta and raft states. Signed-off-by: Derek Collison --- server/jetstream_cluster.go | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/server/jetstream_cluster.go b/server/jetstream_cluster.go index 8c707f86..6390a605 100644 --- a/server/jetstream_cluster.go +++ b/server/jetstream_cluster.go @@ -544,9 +544,11 @@ func (js *jetStream) setupMetaGroup() error { sysAcc := s.SystemAccount() storeDir := filepath.Join(js.config.StoreDir, sysAcc.Name, defaultStoreDirName, defaultMetaGroupName) - fs, err := newFileStore( + fs, err := newFileStoreWithCreated( FileStoreConfig{StoreDir: storeDir, BlockSize: defaultMetaFSBlkSize, AsyncFlush: false}, StreamConfig{Name: defaultMetaGroupName, Storage: FileStorage}, + time.Now().UTC(), + s.jsKeyGen(defaultMetaGroupName), ) if err != nil { s.Errorf("Error creating filestore: %v", err) @@ -1527,9 +1529,11 @@ func (js *jetStream) createRaftGroup(accName string, rg *raftGroup, storage Stor storeDir := filepath.Join(js.config.StoreDir, sysAcc.Name, defaultStoreDirName, rg.Name) var store StreamStore if storage == FileStorage { - fs, err := newFileStore( + fs, err := newFileStoreWithCreated( FileStoreConfig{StoreDir: storeDir, BlockSize: defaultMediumBlockSize, AsyncFlush: false, SyncInterval: 5 * time.Minute}, StreamConfig{Name: rg.Name, Storage: FileStorage}, + time.Now().UTC(), + s.jsKeyGen(rg.Name), ) if err != nil { s.Errorf("Error creating filestore WAL: %v", err)