Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 228 for lobster (0.15 sec)

  1. staging/src/k8s.io/apiserver/pkg/cel/library/lists.go

    		}
    		return result.(ref.Val)
    	}
    }
    
    func indexOf(list ref.Val, item ref.Val) ref.Val {
    	lister, ok := list.(traits.Lister)
    	if !ok {
    		return types.MaybeNoSuchOverloadErr(list)
    	}
    	sz := lister.Size().(types.Int)
    	for i := types.Int(0); i < sz; i++ {
    		if lister.Get(types.Int(i)).Equal(item) == types.True {
    			return types.Int(i)
    		}
    	}
    	return types.Int(-1)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Aug 23 21:31:27 UTC 2023
    - 9.2K bytes
    - Viewed (0)
  2. plugin/pkg/auth/authorizer/rbac/rbac.go

    	return l.Lister.RoleBindings(namespace).List(labels.Everything())
    }
    
    type ClusterRoleGetter struct {
    	Lister rbaclisters.ClusterRoleLister
    }
    
    func (g *ClusterRoleGetter) GetClusterRole(name string) (*rbacv1.ClusterRole, error) {
    	return g.Lister.Get(name)
    }
    
    type ClusterRoleBindingLister struct {
    	Lister rbaclisters.ClusterRoleBindingLister
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 24 10:13:50 UTC 2022
    - 7.8K bytes
    - Viewed (0)
  3. platforms/software/dependency-management/src/test/groovy/org/gradle/api/internal/artifacts/repositories/DefaultMavenArtifactRepositoryTest.groovy

            when:
            def lister = repository.createResolver().providedVersionLister
    
            then:
            lister.rules.configurableRules[0].ruleClass == CustomVersionLister
            lister.rules.configurableRules[0].ruleParams.isolate() == [] as Object[]
        }
    
        def "can inject configuration into a custom version lister"() {
            repository.name = 'name'
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Oct 10 21:10:11 UTC 2023
    - 14.6K bytes
    - Viewed (0)
  4. pkg/volume/util/storageclass_test.go

    			for _, c := range tc.classes {
    				informerFactory.Storage().V1().StorageClasses().Informer().GetStore().Add(c)
    			}
    			lister := informerFactory.Storage().V1().StorageClasses().Lister()
    			actual, err := GetDefaultClass(lister)
    			if err != nil {
    				t.Errorf("Expected no error, got %v", err)
    				return
    			}
    			if tc.expect != actual {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Aug 18 14:18:11 UTC 2023
    - 3.1K bytes
    - Viewed (0)
  5. pkg/kubeapiserver/authorizer/config.go

    			r.rbacAuthorizer = rbac.New(
    				&rbac.RoleGetter{Lister: config.VersionedInformerFactory.Rbac().V1().Roles().Lister()},
    				&rbac.RoleBindingLister{Lister: config.VersionedInformerFactory.Rbac().V1().RoleBindings().Lister()},
    				&rbac.ClusterRoleGetter{Lister: config.VersionedInformerFactory.Rbac().V1().ClusterRoles().Lister()},
    				&rbac.ClusterRoleBindingLister{Lister: config.VersionedInformerFactory.Rbac().V1().ClusterRoleBindings().Lister()},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 21:22:55 UTC 2024
    - 8K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiextensions-apiserver/pkg/client/informers/externalversions/apiextensions/v1/customresourcedefinition.go

    	watch "k8s.io/apimachinery/pkg/watch"
    	cache "k8s.io/client-go/tools/cache"
    )
    
    // CustomResourceDefinitionInformer provides access to a shared informer and lister for
    // CustomResourceDefinitions.
    type CustomResourceDefinitionInformer interface {
    	Informer() cache.SharedIndexInformer
    	Lister() v1.CustomResourceDefinitionLister
    }
    
    type customResourceDefinitionInformer struct {
    	factory          internalinterfaces.SharedInformerFactory
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Feb 08 02:16:47 UTC 2020
    - 3.8K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiextensions-apiserver/pkg/client/informers/externalversions/apiextensions/v1beta1/customresourcedefinition.go

    	watch "k8s.io/apimachinery/pkg/watch"
    	cache "k8s.io/client-go/tools/cache"
    )
    
    // CustomResourceDefinitionInformer provides access to a shared informer and lister for
    // CustomResourceDefinitions.
    type CustomResourceDefinitionInformer interface {
    	Informer() cache.SharedIndexInformer
    	Lister() v1beta1.CustomResourceDefinitionLister
    }
    
    type customResourceDefinitionInformer struct {
    	factory          internalinterfaces.SharedInformerFactory
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Feb 08 02:16:47 UTC 2020
    - 3.9K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/internal/generic/doc.go

    limitations under the License.
    */
    
    // Package generic contains a typed wrapper over cache SharedIndexInformer
    // and Lister (maybe eventually should have a home there?)
    //
    // This interface is being experimented with as an easier way to write controllers
    // with a bit less boilerplate.
    //
    // Informer/Lister classes are thin wrappers providing a type-safe interface
    // over regular interface{}-based Informers/Listers
    //
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 12 18:58:24 UTC 2024
    - 1.1K bytes
    - Viewed (0)
  9. staging/src/k8s.io/apiserver/pkg/admission/configuration/validating_webhook_manager.go

    	informer := f.Admissionregistration().V1().ValidatingWebhookConfigurations()
    	manager := &validatingWebhookConfigurationManager{
    		lister:                          informer.Lister(),
    		createValidatingWebhookAccessor: webhook.NewValidatingWebhookAccessor,
    	}
    	manager.lazy.Evaluate = manager.getConfiguration
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jul 13 22:43:12 UTC 2023
    - 5.7K bytes
    - Viewed (0)
  10. staging/src/k8s.io/apiserver/pkg/admission/plugin/resourcequota/admission.go

    }
    
    // SetExternalKubeInformerFactory registers an informer factory into QuotaAdmission
    func (a *QuotaAdmission) SetExternalKubeInformerFactory(f informers.SharedInformerFactory) {
    	a.quotaAccessor.lister = f.Core().V1().ResourceQuotas().Lister()
    }
    
    // SetQuotaConfiguration assigns and initializes configuration and evaluator for QuotaAdmission
    func (a *QuotaAdmission) SetQuotaConfiguration(c quota.Configuration) {
    	a.quotaConfiguration = c
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 23 10:34:50 UTC 2022
    - 5.8K bytes
    - Viewed (0)
Back to top