TrueCloudLab/frostfs-node
20
1
Fork 28
Code Issues 107 Pull requests 4 Projects Releases 2 Packages 4 Activity Actions

[#303] morph/netmap: Implement getting network map snapshot by epoch

Browse source 
Signed-off-by: Leonard Lyubich <leonard@nspcc.ru>
This commit is contained in:
Leonard Lyubich 2021-01-12 14:26:58 +03:00 • committed by Alex Vanin
parent d58e28afee
commit 9ea75e51b2
3 changed files with 78 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

18
pkg/morph/client/netmap/client.go
View file

@ -35,6 +35,7 @@ type cfg struct {
newEpochMethod, // new epoch method name for invocation
netMapMethod, // get network map method name
snapshotMethod, // get network map snapshot method name
epochSnapshotMethod, // get network map snapshot by epoch method name
updateStateMethod, // update state method name for invocation
innerRingListMethod, // IR list method name for invocation
epochMethod, // get epoch number method name
@ -50,6 +51,8 @@ const (
defaultInnerRIngListMethod = "innerRingList" // default IR list method name
defaultEpochMethod = "epoch" // default get epoch number method name
defaultConfigMethod = "config" // default get config value method name
defaultEpochSnapshotMethod = "snapshotByEpoch" // default get network map snapshot by epoch method name
)
func defaultConfig() *cfg {
@ -58,6 +61,7 @@ func defaultConfig() *cfg {
newEpochMethod: defaultNewEpochMethod,
netMapMethod: defaultNetMapMethod,
snapshotMethod: defaultSnapshotMethod,
epochSnapshotMethod: defaultEpochSnapshotMethod,
updateStateMethod: defaultUpdateStateMethod,
innerRingListMethod: defaultInnerRIngListMethod,
epochMethod: defaultEpochMethod,
@ -194,3 +198,17 @@ func WithConfigMethod(n string) Option {
}
}
}
// WithEpochSnapshotMethod returns a client constructor option that
// specifies the method name of snapshot by value receiving operation.
//
// Ignores empty value.
//
// If option not provided, "snapshotByValue" is used.
func WithEpochSnapshotMethod(n string) Option {
return func(c *cfg) {
if n != "" {
c.epochSnapshotMethod = n
}
}
}