Struct Server

pkg/scheduler/server/server.go:92–107

Server is the gRPC server for the Scheduler service.

// Server is the gRPC server for the Scheduler service.
type Server struct {
	listenAddress string
	port          int

	sec        security.Handler
	serializer *serialize.Serializer
	cron       cron.Interface
	etcd       etcd.Interface
	controller *controller.Controller

	hzAPIServer healthz.Target

	running atomic.Bool

	closeCh chan struct{}
}

func New(ctx context.Context, opts Options) (*Server, error) {
	var broadcastAddr string