- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for AddMetrics (0.17 sec)
-
staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/conversion/metrics.go
} var _ crConverterInterface = &converterMetric{} type converterMetric struct { delegate crConverterInterface latencies *metrics.HistogramVec crdName string } func (c *converterMetricFactory) addMetrics(crdName string, converter crConverterInterface) (crConverterInterface, error) { c.factoryLock.Lock() defer c.factoryLock.Unlock() metric, exists := c.durations["webhook"] if !exists { metric = metrics.NewHistogramVec(
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 07 19:34:33 UTC 2023 - 5.7K bytes - Viewed (0) -
cmd/kube-apiserver/app/server.go
// validate options if errs := completedOptions.Validate(); len(errs) != 0 { return utilerrors.NewAggregate(errs) } // add feature enablement metrics utilfeature.DefaultMutableFeatureGate.AddMetrics() return Run(cmd.Context(), completedOptions) }, Args: func(cmd *cobra.Command, args []string) error { for _, arg := range args { if len(arg) > 0 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 01 17:44:20 UTC 2024 - 10.2K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/conversion/converter.go
case apiextensionsv1.WebhookConverter: converter, err = m.webhookConverterFactory.NewWebhookConverter(crd) if err != nil { return nil, nil, err } converter, err = converterMetricFactorySingleton.addMetrics(crd.Name, converter) if err != nil { return nil, nil, err } default: return nil, nil, fmt.Errorf("unknown conversion strategy %q for CRD %s", crd.Spec.Conversion.Strategy, crd.Name) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 28 19:06:46 UTC 2024 - 9.5K bytes - Viewed (0) -
cmd/kube-scheduler/app/server.go
<-stopCh cancel() }() cc, sched, err := Setup(ctx, opts, registryOptions...) if err != nil { return err } // add feature enablement metrics utilfeature.DefaultMutableFeatureGate.AddMetrics() return Run(ctx, cc, sched) } // Run executes the scheduler based on the given configuration. It only returns on error or when context is done.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 27 19:11:24 UTC 2024 - 14.3K bytes - Viewed (0) -
cmd/kube-controller-manager/app/controllermanager.go
c, err := s.Config(KnownControllers(), ControllersDisabledByDefault(), ControllerAliases()) if err != nil { return err } // add feature enablement metrics utilfeature.DefaultMutableFeatureGate.AddMetrics() return Run(context.Background(), c.Complete()) }, Args: func(cmd *cobra.Command, args []string) error { for _, arg := range args { if len(arg) > 0 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 01 13:03:53 UTC 2024 - 37.5K bytes - Viewed (0) -
cmd/kubelet/app/server.go
// set up signal context for kubelet shutdown ctx := genericapiserver.SetupSignalContext() utilfeature.DefaultMutableFeatureGate.AddMetrics() // run the kubelet return Run(ctx, kubeletServer, kubeletDeps, utilfeature.DefaultFeatureGate) }, } // keep cleanFlagSet separate, so Cobra doesn't pollute it with the global flags
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 00:05:34 UTC 2024 - 53.9K bytes - Viewed (0) -
cmd/kube-proxy/app/server.go
cliflag.PrintFlags(cmd.Flags()) if err := opts.Validate(); err != nil { return fmt.Errorf("failed validate: %w", err) } // add feature enablement metrics utilfeature.DefaultMutableFeatureGate.AddMetrics() if err := opts.Run(context.Background()); err != nil { opts.logger.Error(err, "Error running ProxyServer") return err } return nil },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 26 13:27:41 UTC 2024 - 46.8K bytes - Viewed (0)