Struct Server

scheduler/scheduler.go:59–92

Server is the scheduler server.

// Server is the scheduler server.
type Server struct {
	// Server configuration.
	config *config.Config

	// GRPC server.
	grpcServer *grpc.Server

	// Metrics server.
	metricsServer *http.Server

	// Manager client.
	managerClient managerclient.V2

	// Resource interface.
	resource standard.Resource

	// Persistent resource interface.
	persistentResource persistent.Resource

	// Persistent cache resource interface.
	persistentCacheResource persistentcache.Resource

	// Dynamic config.
	dynconfig config.DynconfigInterface

	// Async job.
	job job.Job

	// Announcer interface.
	announcer announcer.Announcer

	// GC service.
	gc gc.GC
}

// New creates a new scheduler server.
func New(ctx context.Context, cfg *config.Config, d dfpath.Dfpath) (*Server, error) {