Vihren Atlas

Atlas › Test

non-default_InitialIntervalInSeconds_is_not_set

go.temporal.io/server/common/retrypolicy/TestEnsureRetryPolicyDefaults/non-default_InitialIntervalInSeconds_is_not_set

Package
go.temporal.io/server/common/retrypolicy
Suite / test hierarchy
TestEnsureRetryPolicyDefaults/non-default_InitialIntervalInSeconds_is_not_set
Test
non-default_InitialIntervalInSeconds_is_not_set
Introduced at
non-default_InitialIntervalInSeconds_is_not_set Test frontier
Covered ranges
10
Covered lines
16
Covered files
2

Covered source

Expand a file to inspect source; the > gutter marks covered lines.

go.temporal.io/server/common/retrypolicy/retry_policy.go 11 covered LOC · 7 ranges

Open complete file

38
39 // EnsureDefaults ensures the policy subfields, if not explicitly set, are set to the specified defaults
40 > func EnsureDefaults(originalPolicy *commonpb.RetryPolicy, defaultSettings DefaultRetrySettings) { retry_policy.go
41 > if originalPolicy.GetMaximumAttempts() == 0 {
42 > originalPolicy.MaximumAttempts = defaultSettings.MaximumAttempts retry_policy.go
43 > }
44
45 > if timestamp.DurationValue(originalPolicy.GetInitialInterval()) == 0 { retry_policy.go
46 originalPolicy.InitialInterval = durationpb.New(defaultSettings.InitialInterval)
47 }
48
49 > if timestamp.DurationValue(originalPolicy.GetMaximumInterval()) == 0 { retry_policy.go
50 > originalPolicy.MaximumInterval = durationpb.New(time.Duration(defaultSettings.MaximumIntervalCoefficient) * timestamp.DurationValue(originalPolicy.GetInitialInterval())) retry_policy.go
51 > }
52
53 > if originalPolicy.GetBackoffCoefficient() == 0 { retry_policy.go
54 > originalPolicy.BackoffCoefficient = defaultSettings.BackoffCoefficient retry_policy.go
55 > }
56 }
57
go.temporal.io/server/common/primitives/timestamp/duration.go 5 covered LOC · 3 ranges

Open complete file

19 )
20
21 > func DurationValue(d *durationpb.Duration) time.Duration { duration.go
22 > if d == nil {
23 > return 0 duration.go
24 > }
25 > return d.AsDuration() duration.go
26 }
27