- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 39 for membership (0.18 sec)
-
analysis/analysis-api-impl-base/src/org/jetbrains/kotlin/analysis/api/impl/base/util/LibraryUtils.kt
* * Note that, if [CoreJarFileSystem] is not given, a fresh instance will be used, which will create fresh instances of [VirtualFile], * resulting in potential hash mismatch (e.g., if used in scope membership check). * * By default, given [jar], the root, will be included. Pass [includeRoot = false] if not needed.
Registered: Wed Jun 12 09:53:16 UTC 2024 - Last Modified: Wed Sep 06 07:36:11 UTC 2023 - 3.6K bytes - Viewed (0) -
cmd/kubeadm/app/util/etcd/etcd.go
type etcdClient interface { // Close shuts down the client's etcd connections. Close() error // Endpoints lists the registered endpoints for the client. Endpoints() []string // MemberList lists the current cluster membership. MemberList(ctx context.Context) (*clientv3.MemberListResponse, error) // MemberAdd adds a new member into the cluster. MemberAdd(ctx context.Context, peerAddrs []string) (*clientv3.MemberAddResponse, error)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 11:04:08 UTC 2024 - 21.2K bytes - Viewed (0) -
pkg/kube/namespace/filter.go
} // update filter state d.discoveryNamespaces = newDiscoveryNamespaces d.discoverySelectors = selectors } // namespaceCreated: if newly created namespace is selected, update namespace membership func (d *discoveryNamespacesFilter) namespaceCreatedLocked(ns metav1.ObjectMeta) (membershipChanged bool) { if d.isSelectedLocked(ns.Labels) { d.discoveryNamespaces.Insert(ns.Name)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 10 17:12:52 UTC 2024 - 9.3K bytes - Viewed (0) -
platforms/core-configuration/model-core/src/test/groovy/org/gradle/model/internal/manage/projection/ModelSetModelProjectionTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Sep 28 09:51:04 UTC 2023 - 4.7K bytes - Viewed (0) -
istioctl/pkg/xds/client.go
if isMCP { // Special credentials handling when using ASM Managed Control Plane. mem, err := getHubMembership(ctx, kubeClient) if err != nil { return nil, fmt.Errorf("failed to query Hub membership: %w", err) } aud = []string{mem.WorkloadIdentityPool} } k8sCreds, err := kubeClient.CreatePerRPCCredentials(ctx, ns, serviceAccount, aud, defaultExpirationSeconds) if err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Dec 19 22:42:42 UTC 2023 - 3.7K bytes - Viewed (0) -
pilot/pkg/xds/eds.go
inboundServiceDeletes.Increment() s.Env.EndpointIndex.DeleteServiceShard(shard, hostname, namespace, false) } else { inboundServiceUpdates.Increment() } } // EDSUpdate computes destination address membership across all clusters and networks. // This is the main method implementing EDS. // It replaces InstancesByPort in model - instead of iterating over all endpoints it uses
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 02 15:58:06 UTC 2024 - 9.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/authentication/request/headerrequest/requestheader.go
// nameHeaders are the headers to check (in order, case-insensitively) for an identity. The first header with a value wins. nameHeaders StringSliceProvider // groupHeaders are the headers to check (case-insensitively) for group membership. All values of all headers will be added. groupHeaders StringSliceProvider // extraHeaderPrefixes are the head prefixes to check (case-insensitively) for filling in
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 18:19:54 UTC 2024 - 6.1K bytes - Viewed (0) -
platforms/core-configuration/file-collections/src/test/groovy/org/gradle/api/internal/file/collections/DirectoryFileTreeTest.groovy
where: visitor << [new TestVisitor(true)] // stopping at a given point assumes the order is fixed, so only reproducible visitor makes sense here } def "can test for file membership - isReproducible: #visitor.isReproducibleFileOrder"() { given: def rootDir = temporaryFolder.createDir("root") def rootTextFile = rootDir.file("a.txt").createFile()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Sep 28 09:51:04 UTC 2023 - 9.6K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/sets/set.go
for item := range s2 { if !s1.Has(item) { return false } } return true } // Equal returns true if and only if s1 is equal (as a set) to s2. // Two sets are equal if their membership is identical. // (In practice, this means same elements, order doesn't matter) func (s1 Set[T]) Equal(s2 Set[T]) bool { return len(s1) == len(s2) && s1.IsSuperset(s2) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 19:51:18 UTC 2024 - 5.8K bytes - Viewed (0) -
cmd/kubeadm/app/util/etcd/etcd_test.go
return nil } // Endpoints lists the registered endpoints for the client. func (f *fakeEtcdClient) Endpoints() []string { return f.endpoints } // MemberList lists the current cluster membership. func (f *fakeEtcdClient) MemberList(_ context.Context) (*clientv3.MemberListResponse, error) { return &clientv3.MemberListResponse{ Members: f.members, }, nil } // MemberAdd adds a new member into the cluster.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Jan 14 13:07:56 UTC 2024 - 20.3K bytes - Viewed (0)