Vihren Atlas

Atlas › Test

default_fields_are_set_

go.temporal.io/server/common/retrypolicy/TestEnsureRetryPolicyDefaults/default_fields_are_set_

Package
go.temporal.io/server/common/retrypolicy
Suite / test hierarchy
TestEnsureRetryPolicyDefaults/default_fields_are_set_
Test
default_fields_are_set_
Introduced at
default_fields_are_set_, non-retryable_errors_are_set, +1 Test frontier
Covered ranges
11
Covered lines
18
Covered files
2

Co-introduced tests

2 other tests enter at the same concept.

Covered source

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

go.temporal.io/server/common/retrypolicy/retry_policy.go 13 covered LOC · 8 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) retry_policy.go
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