30
)
31
32
>
func (cfg *DeleteExecutionsConfig) ApplyDefaults() {
config.go
33
>
if cfg.DeleteActivityRPS <= 0 {
34
>
cfg.DeleteActivityRPS = defaultDeleteActivityRPS
35
>
}
36
>
if cfg.PageSize <= 0 {
37
cfg.PageSize = defaultPageSize
38
}
39
>
if cfg.PagesPerExecution <= 0 {
config.go
40
cfg.PagesPerExecution = defaultPagesPerExecution
41
}
42
>
if cfg.ConcurrentDeleteExecutionsActivities <= 0 {
config.go
43
cfg.ConcurrentDeleteExecutionsActivities = defaultConcurrentDeleteExecutionsActivities
44
}
45
>
if cfg.ConcurrentDeleteExecutionsActivities > maxConcurrentDeleteExecutionsActivities {
config.go
46
cfg.ConcurrentDeleteExecutionsActivities = maxConcurrentDeleteExecutionsActivities
47
}
48
// It won't be able to start more than PagesPerExecution activities.
49
>
if cfg.ConcurrentDeleteExecutionsActivities > cfg.PagesPerExecution {
config.go
50
cfg.ConcurrentDeleteExecutionsActivities = cfg.PagesPerExecution
51
}