adityadtu5 commented on code in PR #1095:
URL: https://github.com/apache/yunikorn-core/pull/1095#discussion_r3433244830
##########
pkg/scheduler/scheduler.go:
##########
@@ -32,32 +32,35 @@ import (
"github.com/apache/yunikorn-scheduler-interface/lib/go/si"
)
-// Main Scheduler service that starts the needed sub services
+// The Scheduler service that starts the needed sub services
type Scheduler struct {
- clusterContext *ClusterContext // main context
- pendingEvents chan interface{} // queue for events
- activityPending chan bool // activity pending channel
- stop chan struct{} // channel to signal stop request
- healthChecker *HealthChecker
- nodesMonitor *nodesResourceUsageMonitor
+ clusterContext *ClusterContext // main context
+ pendingAllocEvents chan interface{} // queue for allocation and
application events
+ pendingInfraEvents chan interface{} // queue for node, config, and
registration events
+ activityPending chan bool // activity pending channel
+ stop chan struct{} // channel to signal stop request
+ healthChecker *HealthChecker
+ nodesMonitor *nodesResourceUsageMonitor
}
func NewScheduler() *Scheduler {
m := &Scheduler{}
m.clusterContext = newClusterContext()
- m.pendingEvents = make(chan interface{}, 1024*1024)
+ m.pendingAllocEvents = make(chan interface{}, 1024*1024)
+ m.pendingInfraEvents = make(chan interface{}, 1024*1024)
Review Comment:
Updated the capacity as per our last discussion
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
