Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 17 for NewRegistry (0.15 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top