blob: 7f02bb9f62ae07ed3d5ef0fd3a71360faba96d73 (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
|
#include "backoff_strategy_config.h"
namespace NYT {
////////////////////////////////////////////////////////////////////////////////
void TExponentialBackoffOptionsSerializer::Register(TRegistrar registrar)
{
registrar.ExternalClassParameter("invocation_count", &TThat::InvocationCount)
.Alias("retry_count")
.Default(TThat::DefaultInvocationCount);
registrar.ExternalClassParameter("min_backoff", &TThat::MinBackoff)
.Default(TThat::DefaultMinBackoff);
registrar.ExternalClassParameter("max_backoff", &TThat::MaxBackoff)
.Default(TThat::DefaultMaxBackoff);
registrar.ExternalClassParameter("backoff_multiplier", &TThat::BackoffMultiplier)
.Default(TThat::DefaultBackoffMultiplier)
.GreaterThanOrEqual(1.0);
registrar.ExternalClassParameter("backoff_jitter", &TThat::BackoffJitter)
.Default(TThat::DefaultBackoffJitter);
}
////////////////////////////////////////////////////////////////////////////////
void TConstantBackoffOptionsSerializer::Register(TRegistrar registrar)
{
registrar.ExternalClassParameter("invocation_count", &TThat::InvocationCount)
.Alias("retry_count")
.Default(TThat::DefaultInvocationCount);
registrar.ExternalClassParameter("backoff", &TThat::Backoff)
.Default(TThat::DefaultBackoff);
registrar.ExternalClassParameter("backoff_jitter", &TThat::BackoffJitter)
.Default(TThat::DefaultBackoffJitter);
}
////////////////////////////////////////////////////////////////////////////////
} // namespace NYT
|
