Method initAPIC

pkg/apiserver/apiserver.go:287–330

(ctx context.Context)

}

func (s *APIServer) initAPIC(ctx context.Context) {
	s.apic.pushTomb.Go(func() error {
		defer trace.ReportPanic()
		return s.apicPush(ctx)
	})
	s.apic.pullTomb.Go(func() error {
		defer trace.ReportPanic()
		return s.apicPull(ctx)
	})

	if s.apic.apiClient.IsEnrolled() {
		if s.papi != nil {
			if s.papi.URL != "" {
				log.Info("Starting PAPI decision receiver")
				s.papi.pullTomb.Go(func() error {
					defer trace.ReportPanic()
					return s.papiPull(ctx)
				})
				s.papi.syncTomb.Go(func() error {
					defer trace.ReportPanic()
					return s.papiSync(ctx)
				})
			} else {
				log.Warnf("papi_url is not set in online_api_credentials.yaml, can't synchronize with the console. Run cscli console enable console_management to add it.")
			}
		} else {
			log.Warningf("Machine is not allowed to synchronize decisions, you can enable it with `cscli console enable console_management`")
		}
	}

	s.apic.metricsTomb.Go(func() error {
		defer trace.ReportPanic()
		s.apic.SendMetrics(ctx, make(chan bool))
		return nil
	})

	if !s.cfg.DisableUsageMetricsExport {
		s.apic.metricsTomb.Go(func() error {
			defer trace.ReportPanic()
			s.apic.SendUsageMetrics(ctx)
			return nil
		})
	}
}

func (s *APIServer) Run(ctx context.Context, apiReady chan bool) error {
	tlsCfg, err := s.cfg.TLS.GetTLSConfig()