INNER CODE UNIT · Go

newSchedulerServer

apache/yunikorn-core · cmd/simplescheduler/simplescheduler.go:43

func newSchedulerServer() si.SchedulerServer {
	return &SimpleScheduler{}
}

func (scheduler *SimpleScheduler) RegisterResourceManager(ctx context.Context, in *si.RegisterResourceManagerRequest) (*si.RegisterResourceManagerResponse, error) {
	log.Printf("Received registeration")

	return &(si.RegisterResourceManagerResponse{}), nil
}

func (scheduler *SimpleScheduler) UpdateAllocation(conn si.Scheduler_UpdateAllocationServer) error {
	log.Println("start new server")
	ctx := conn.Context()

	for {
		// exit if context is done
		// or continue
		select {

View source record →