Struct canceler

app/pipeline/scheduler/canceler.go:23–28

)

type canceler struct {
	sync.Mutex

	subscribers map[chan struct{}]int64
	cancelled   map[int64]time.Time
}

func newCanceler() *canceler {
	return &canceler{