32
isRunning bool,
33
resolve func(enumspb.ScheduleOverlapPolicy) enumspb.ScheduleOverlapPolicy,
35
>
// We should try to do something reasonable with any combination of overlap
36
>
// policies in the buffer, although some combinations don't make much sense
37
>
// and would require a convoluted series of calls to set up.
38
>
//
39
>
// Buffer entries that have unspecified overlap policy are resolved to the
40
>
// current policy here, not earlier, so that updates to the policy can
41
>
// affect them.
42
>
43
>
var action ProcessBufferResult[T]
44
>
action.OverlapSkippedByPolicy = make(map[enumspb.ScheduleOverlapPolicy]int64)
45
>
var zeroVal T
46
>
47
>
for _, start := range buffer {
48
overlapPolicy := resolve(start.GetOverlapPolicy())
49