Function main

cmd/operator/main.go:43–124

()

const _operatorPortStr = "8888"

func main() {
	if err := config.Init(); err != nil {
		exit.ErrorNoTelemetry(errors.Wrap(err, "init"))
	}

	telemetry.Event("operator.init")

	cron.Run(operator.DeleteEvictedPods, operator.ErrorHandler("delete evicted pods"), time.Hour)
	cron.Run(operator.ClusterTelemetry, operator.ErrorHandler("instance telemetry"), 1*time.Hour)
	cron.Run(operator.CostBreakdown, operator.ErrorHandler("cost breakdown metrics"), 5*time.Minute)

	_, err := operator.UpdateMemoryCapacityConfigMap()
	if err != nil {
		exit.Error(errors.Wrap(err, "init"))
	}

	cron.Run(taskapi.ManageJobResources, operator.ErrorHandler("manage task jobs"), taskapi.ManageJobResourcesCronPeriod)

	deployments, err := config.K8s.ListDeploymentsWithLabelKeys("apiName")
	if err != nil {
		exit.Error(errors.Wrap(err, "init"))
	}

	for i := range deployments {
		deployment := deployments[i]
		apiKind := deployment.Labels["apiKind"]
		switch apiKind {
		case userconfig.AsyncAPIKind.String():
			if err := asyncapi.UpdateAPIMetricsCron(&deployment); err != nil {
				operatorLogger.Fatal(errors.Wrap(err, "init"))
			}
		}
	}

	router := mux.NewRouter()

	routerWithoutAuth := router.NewRoute().Subrouter()
	routerWithoutAuth.Use(endpoints.PanicMiddleware)
	routerWithoutAuth.HandleFunc("/verifycortex", endpoints.VerifyCortex).Methods("GET")

	routerWithoutAuth.HandleFunc("/batch/{apiName}", endpoints.SubmitBatchJob).Methods("POST")
	routerWithoutAuth.HandleFunc("/batch/{apiName}", endpoints.GetBatchJob).Methods("GET")
	routerWithoutAuth.HandleFunc("/batch/{apiName}", endpoints.StopBatchJob).Methods("DELETE")
	routerWithoutAuth.HandleFunc("/tasks/{apiName}", endpoints.SubmitTaskJob).Methods("POST")
	routerWithoutAuth.HandleFunc("/tasks/{apiName}", endpoints.GetTaskJob).Methods("GET")
	routerWithoutAuth.HandleFunc("/tasks/{apiName}", endpoints.StopTaskJob).Methods("DELETE")

	// prometheus metrics
	routerWithoutAuth.Handle("/metrics", promhttp.Handler()).Methods("GET")

	routerWithAuth := router.NewRoute().Subrouter()

	routerWithAuth.Use(endpoints.PanicMiddleware)
	routerWithAuth.Use(endpoints.APIVersionCheckMiddleware)
	routerWithAuth.Use(endpoints.AWSAuthMiddleware)
	routerWithAuth.Use(endpoints.ClientIDMiddleware)

	routerWithAuth.HandleFunc("/info", endpoints.Info).Methods("GET")