Function newKeyScheduler

src/go/plugin/framework/functions/scheduler.go:41–49

(maxPending int)

}

func newKeyScheduler(maxPending int) *keyScheduler {
	s := &keyScheduler{
		lanes:      make(map[string]*scheduleLane),
		maxPending: maxPending,
		accepting:  true,
	}
	s.cond = sync.NewCond(&s.mux)
	return s
}

func (s *keyScheduler) enqueue(req *invocationRequest) error {
	if req == nil || req.fn == nil || req.fn.UID == "" || req.scheduleKey == "" {