INNER CODE UNIT · Go
func
apache/yunikorn-core · cmd/simplescheduler/simplescheduler.go:35
func (scheduler *SimpleScheduler) Run(endpoint string) {
// Create gRPC servers
ss := newSchedulerServer()
s := common.NewNonBlockingGRPCServer()
s.Start(endpoint, ss)
s.Wait()
}
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
}