- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 17 for NewRegistry (0.15 sec)
-
pkg/registry/rbac/role/registry.go
} // storage puts strong typing around storage calls type storage struct { rest.Getter } // NewRegistry returns a new Registry interface for the given Storage. Any mismatched // types will panic. func NewRegistry(s rest.StandardStorage) Registry { return &storage{s} }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 02 02:36:35 UTC 2019 - 2K bytes - Viewed (0) -
pkg/registry/rbac/clusterrolebinding/registry.go
} // storage puts strong typing around storage calls type storage struct { rest.Lister } // NewRegistry returns a new Registry interface for the given Storage. Any mismatched // types will panic. func NewRegistry(s rest.StandardStorage) Registry { return &storage{s} }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 22 12:17:05 UTC 2018 - 2.3K bytes - Viewed (0) -
pkg/registry/rbac/clusterrole/registry.go
} // storage puts strong typing around storage calls type storage struct { rest.Getter } // NewRegistry returns a new Registry interface for the given Storage. Any mismatched // types will panic. func NewRegistry(s rest.StandardStorage) Registry { return &storage{s} }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 02 02:35:47 UTC 2019 - 2.1K bytes - Viewed (0) -
pkg/registry/rbac/rolebinding/registry.go
} // storage puts strong typing around storage calls type storage struct { rest.Lister } // NewRegistry returns a new Registry interface for the given Storage. Any mismatched // types will panic. func NewRegistry(s rest.StandardStorage) Registry { return &storage{s} }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 22 12:17:05 UTC 2018 - 2.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/quota/v1/generic/registry.go
// implements a basic registry type simpleRegistry struct { lock sync.RWMutex // evaluators tracked by the registry evaluators map[schema.GroupResource]quota.Evaluator } // NewRegistry creates a simple registry with initial list of evaluators func NewRegistry(evaluators []quota.Evaluator) quota.Registry { return &simpleRegistry{ evaluators: evaluatorsByGroupResource(evaluators), } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Sep 04 12:53:52 UTC 2020 - 2.2K bytes - Viewed (0) -
pkg/registry/rbac/rest/storage_rbac.go
role.AuthorizerAdapter{Registry: role.NewRegistry(rolesStorage)}, rolebinding.AuthorizerAdapter{Registry: rolebinding.NewRegistry(roleBindingsStorage)}, clusterrole.AuthorizerAdapter{Registry: clusterrole.NewRegistry(clusterRolesStorage)}, clusterrolebinding.AuthorizerAdapter{Registry: clusterrolebinding.NewRegistry(clusterRoleBindingsStorage)}, ) // roles
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jul 14 03:25:19 UTC 2022 - 18.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/resourcequota/admission.go
a.quotaConfiguration = c if a.stopCh == nil { a.initializationErr = stopChUnconfiguredErr return } a.evaluator = NewQuotaEvaluator(a.quotaAccessor, a.quotaConfiguration.IgnoredResources(), generic.NewRegistry(a.quotaConfiguration.Evaluators()), nil, a.config, a.numEvaluators, a.stopCh) } // ValidateInitialization ensures an authorizer is set. func (a *QuotaAdmission) ValidateInitialization() error {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 23 10:34:50 UTC 2022 - 5.8K bytes - Viewed (0) -
cmd/metrics-v3.go
collectors[mg.CollectorPath] = mg } // Helper function to register a collector and return a gatherer for it. mustRegister := func(c ...prometheus.Collector) prometheus.Gatherer { subRegistry := prometheus.NewRegistry() for _, col := range c { subRegistry.MustRegister(col) } r.MustRegister(subRegistry) return subRegistry } // Register all collectors and create gatherers for them.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 06 09:36:25 UTC 2024 - 13.6K bytes - Viewed (0) -
cmd/metrics-v3-handler.go
opts promhttp.HandlerOpts authFn func(http.Handler) http.Handler metricsData *metricsV3Collection } func newMetricsV3Server(authType prometheusAuthType) *metricsV3Server { registry := prometheus.NewRegistry() authFn := AuthMiddleware if authType == prometheusPublic { authFn = NoAuthMiddleware } metricGroups := newMetricGroups(registry) return &metricsV3Server{ registry: registry,
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 15 16:06:35 UTC 2024 - 7.6K bytes - Viewed (0) -
pkg/monitoring/monitortest/test.go
attrs attribute.Set } var reg = lazy.New(func() (prometheus.Gatherer, error) { // TODO: do not use a global and/or add a way to reset (https://github.com/open-telemetry/opentelemetry-go/issues/4291) reg := prometheus.NewRegistry() _, err := monitoring.RegisterPrometheusExporter(reg, reg) if err != nil { return nil, err } return reg, nil }) func TestRegistry(t test.Failer) prometheus.Gatherer { r, err := reg.Get()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Sep 13 16:04:48 UTC 2023 - 7.2K bytes - Viewed (0)