server/storage: address golangci var-naming issues

Signed-off-by: Ivan Valdes <ivan@vald.es>
This commit is contained in:
Ivan Valdes 2024-03-27 10:12:42 -07:00
parent 647b7eb8f6
commit d43738a49b
No known key found for this signature in database
GPG Key ID: 4037D37741ED0CC5
10 changed files with 30 additions and 13 deletions

View File

@ -94,7 +94,7 @@ func (o *migrateOptions) Config() (*migrateConfig, error) {
dbPath := datadir.ToBackendFileName(o.dataDir) dbPath := datadir.ToBackendFileName(o.dataDir)
c.be = backend.NewDefaultBackend(GetLogger(), dbPath) c.be = backend.NewDefaultBackend(GetLogger(), dbPath)
walPath := datadir.ToWalDir(o.dataDir) walPath := datadir.ToWALDir(o.dataDir)
w, err := wal.OpenForRead(c.lg, walPath, walpb.Snapshot{}) w, err := wal.OpenForRead(c.lg, walPath, walpb.Snapshot{})
if err != nil { if err != nil {
return nil, fmt.Errorf(`failed to open wal: %v`, err) return nil, fmt.Errorf(`failed to open wal: %v`, err)

View File

@ -138,7 +138,7 @@ func SnapshotRestoreCommandFunc(restoreCluster string,
walDir := restoreWalDir walDir := restoreWalDir
if walDir == "" { if walDir == "" {
walDir = datadir.ToWalDir(dataDir) walDir = datadir.ToWALDir(dataDir)
} }
lg := GetLogger() lg := GetLogger()

View File

@ -307,7 +307,7 @@ func (c *ServerConfig) WALDir() string {
if c.DedicatedWALDir != "" { if c.DedicatedWALDir != "" {
return c.DedicatedWALDir return c.DedicatedWALDir
} }
return datadir.ToWalDir(c.DataDir) return datadir.ToWALDir(c.DataDir)
} }
func (c *ServerConfig) SnapDir() string { return filepath.Join(c.MemberDir(), "snap") } func (c *ServerConfig) SnapDir() string { return filepath.Join(c.MemberDir(), "snap") }

View File

@ -694,7 +694,7 @@ func (wal *bootstrappedWAL) CommitedEntries() []raftpb.Entry {
func (wal *bootstrappedWAL) NewConfigChangeEntries() []raftpb.Entry { func (wal *bootstrappedWAL) NewConfigChangeEntries() []raftpb.Entry {
return serverstorage.CreateConfigChangeEnts( return serverstorage.CreateConfigChangeEnts(
wal.lg, wal.lg,
serverstorage.GetEffectiveNodeIDsFromWalEntries(wal.lg, wal.snapshot, wal.ents), serverstorage.GetEffectiveNodeIDsFromWALEntries(wal.lg, wal.snapshot, wal.ents),
uint64(wal.meta.nodeID), uint64(wal.meta.nodeID),
wal.st.Term, wal.st.Term,
wal.st.Commit, wal.st.Commit,

View File

@ -230,7 +230,7 @@ func createDataDir(t *testing.T) (string, error) {
} }
// create ${dataDir}/member/wal // create ${dataDir}/member/wal
err = os.MkdirAll(datadir.ToWalDir(dataDir), 0700) err = os.MkdirAll(datadir.ToWALDir(dataDir), 0700)
if err != nil { if err != nil {
return "", err return "", err
} }

View File

@ -69,7 +69,7 @@ func TestGetIDs(t *testing.T) {
if tt.confState != nil { if tt.confState != nil {
snap.Metadata.ConfState = *tt.confState snap.Metadata.ConfState = *tt.confState
} }
idSet := serverstorage.GetEffectiveNodeIDsFromWalEntries(lg, &snap, tt.ents) idSet := serverstorage.GetEffectiveNodeIDsFromWALEntries(lg, &snap, tt.ents)
if !reflect.DeepEqual(idSet, tt.widSet) { if !reflect.DeepEqual(idSet, tt.widSet) {
t.Errorf("#%d: idset = %#v, want %#v", i, idSet, tt.widSet) t.Errorf("#%d: idset = %#v, want %#v", i, idSet, tt.widSet)
} }

View File

@ -31,7 +31,15 @@ func ToSnapDir(dataDir string) string {
return filepath.Join(ToMemberDir(dataDir), snapDirSegment) return filepath.Join(ToMemberDir(dataDir), snapDirSegment)
} }
// ToWalDir returns the directory path for the member's WAL.
// Deprecated: use ToWALDir instead.
//
//revive:disable-next-line:var-naming
func ToWalDir(dataDir string) string { func ToWalDir(dataDir string) string {
return ToWALDir(dataDir)
}
func ToWALDir(dataDir string) string {
return filepath.Join(ToMemberDir(dataDir), walDirSegment) return filepath.Join(ToMemberDir(dataDir), walDirSegment)
} }

View File

@ -37,12 +37,12 @@ func TestToSnapDir(t *testing.T) {
assert.Equal(t, "/dir/data-dir/member/snap", result) assert.Equal(t, "/dir/data-dir/member/snap", result)
} }
func TestToWalDir(t *testing.T) { func TestToWALDir(t *testing.T) {
result := datadir.ToWalDir("/dir/data-dir") result := datadir.ToWALDir("/dir/data-dir")
assert.Equal(t, "/dir/data-dir/member/wal", result) assert.Equal(t, "/dir/data-dir/member/wal", result)
} }
func TestToWalDirSlash(t *testing.T) { func TestToWALDirSlash(t *testing.T) {
result := datadir.ToWalDir("/dir/data-dir/") result := datadir.ToWALDir("/dir/data-dir/")
assert.Equal(t, "/dir/data-dir/member/wal", result) assert.Equal(t, "/dir/data-dir/member/wal", result)
} }

View File

@ -109,13 +109,22 @@ func CreateConfigChangeEnts(lg *zap.Logger, ids []uint64, self uint64, term, ind
return ents return ents
} }
// GetEffectiveNodeIDsFromWalEntries returns an ordered set of IDs included in the given snapshot and // GetEffectiveNodeIdsFromWalEntries returns an ordered set of IDs included in the given snapshot and
// the entries.
// Deprecated: use GetEffectiveNodeIDsFromWALEntries instead.
//
//revive:disable-next-line:var-naming
func GetEffectiveNodeIdsFromWalEntries(lg *zap.Logger, snap *raftpb.Snapshot, ents []raftpb.Entry) []uint64 {
return GetEffectiveNodeIDsFromWALEntries(lg, snap, ents)
}
// GetEffectiveNodeIDsFromWALEntries returns an ordered set of IDs included in the given snapshot and
// the entries. The given snapshot/entries can contain three kinds of // the entries. The given snapshot/entries can contain three kinds of
// ID-related entry: // ID-related entry:
// - ConfChangeAddNode, in which case the contained ID will Be added into the set. // - ConfChangeAddNode, in which case the contained ID will Be added into the set.
// - ConfChangeRemoveNode, in which case the contained ID will Be removed from the set. // - ConfChangeRemoveNode, in which case the contained ID will Be removed from the set.
// - ConfChangeAddLearnerNode, in which the contained ID will Be added into the set. // - ConfChangeAddLearnerNode, in which the contained ID will Be added into the set.
func GetEffectiveNodeIDsFromWalEntries(lg *zap.Logger, snap *raftpb.Snapshot, ents []raftpb.Entry) []uint64 { func GetEffectiveNodeIDsFromWALEntries(lg *zap.Logger, snap *raftpb.Snapshot, ents []raftpb.Entry) []uint64 {
ids := make(map[uint64]bool) ids := make(map[uint64]bool)
if snap != nil { if snap != nil {
for _, id := range snap.Metadata.ConfState.Voters { for _, id := range snap.Metadata.ConfState.Voters {

View File

@ -132,7 +132,7 @@ func validateConsistentIndex(cfg Config, hardstate *raftpb.HardState, snapshot *
} }
func validateWAL(cfg Config) (*walpb.Snapshot, *raftpb.HardState, error) { func validateWAL(cfg Config) (*walpb.Snapshot, *raftpb.HardState, error) {
walDir := datadir.ToWalDir(cfg.DataDir) walDir := datadir.ToWALDir(cfg.DataDir)
walSnaps, err := wal2.ValidSnapshotEntries(cfg.Logger, walDir) walSnaps, err := wal2.ValidSnapshotEntries(cfg.Logger, walDir)
if err != nil { if err != nil {