- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 137 for Sets (0.13 sec)
-
istioctl/pkg/waypoint/waypoint.go
"istio.io/istio/pkg/config/schema/gvk" "istio.io/istio/pkg/kube" "istio.io/istio/pkg/slices" "istio.io/istio/pkg/util/sets" ) var ( revision = "" waitReady bool allNamespaces bool deleteAll bool trafficType = "" validTrafficTypes = sets.New(constants.ServiceTraffic, constants.WorkloadTraffic, constants.AllTraffic, constants.NoTraffic)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed May 08 19:45:58 GMT 2024 - 15.5K bytes - Viewed (0) -
cni/pkg/nodeagent/podcgroupns.go
can extract a pod uid from it. if we can, open the netns, and save a map of uid->netns-fd */ podUIDNetns := make(PodToNetns) netnsObserved := sets.New[uint64]() entries, err := fs.ReadDir(p.proc, ".") if err != nil { return nil, err } desiredUIDs := sets.New(maps.Keys(pods)...) for _, entry := range entries { // we can't break here because we need to close all the netns we opened
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 11K bytes - Viewed (0) -
cmd/metrics-v3-types.go
} metrics = append(metrics, prometheus.MustNewConstMetric(promDesc, desc.Type.toProm(), v.Value, labelValues...)) } } return metrics } // Set - sets a metric value along with any provided labels. It is used only // with Gauge and Counter metrics. // // If the MetricName given here is not present in the `MetricsGroup`'s // descriptors, this function panics. //
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 30 15:05:22 GMT 2024 - 14.7K bytes - Viewed (0) -
cni/pkg/nodeagent/net.go
} return nil } func pruneHostIPset(expected sets.Set[netip.Addr], hostsideProbeSet *ipset.IPSet) error { actualIPSetContents, err := hostsideProbeSet.ListEntriesByIP() if err != nil { log.Warnf("unable to list IPSet: %v", err) return err } actual := sets.New[netip.Addr](actualIPSetContents...) stales := actual.DifferenceInPlace(expected)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 12.2K bytes - Viewed (1) -
istioctl/pkg/injector/injector-list_test.go
"k8s.io/apimachinery/pkg/runtime" "istio.io/api/annotation" "istio.io/api/label" "istio.io/istio/pkg/config/constants" "istio.io/istio/pkg/kube" "istio.io/istio/pkg/test/util/assert" "istio.io/istio/pkg/util/sets" ) func Test_extractRevisionFromPod(t *testing.T) { cases := []struct { name string pod *corev1.Pod expectedRevision string }{ { name: "no rev",
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu May 02 21:29:40 GMT 2024 - 2.9K bytes - Viewed (0) -
cmd/object-api-interface.go
r.ReplicationStatusInternal = rstatus r.Targets = replicationStatusesMap(rstatus) return } // SetEvalMetadataFn sets the metadata evaluation function func (o *ObjectOptions) SetEvalMetadataFn(f EvalMetadataFn) { o.EvalMetadataFn = f } // SetEvalRetentionBypassFn sets the retention bypass function func (o *ObjectOptions) SetEvalRetentionBypassFn(f EvalRetentionBypassFn) { o.EvalRetentionBypassFn = f }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 17K bytes - Viewed (0) -
analysis/analysis-api-fir/src/org/jetbrains/kotlin/analysis/api/fir/scopes/DeclarationsInPackageProvider.kt
* stub-indexing binary libraries). And in general, querying the symbol names provider might be faster since its sets are cached, which is * not necessarily the case for declaration providers (e.g. the IDE declaration provider hitting the index without caching). * * However, since symbol names providers may not be able to compute name sets per their contract, we may have to fall back to the
Plain Text - Registered: Fri Apr 26 08:18:10 GMT 2024 - Last Modified: Tue Apr 23 10:55:55 GMT 2024 - 5.4K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/Multisets.java
} @Override Set<E> createElementSet() { return Sets.filter(unfiltered.elementSet(), predicate); } @Override Iterator<E> elementIterator() { throw new AssertionError("should never be called"); } @Override Set<Entry<E>> createEntrySet() { return Sets.filter( unfiltered.entrySet(), new Predicate<Entry<E>>() {
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed May 01 18:44:57 GMT 2024 - 41.7K bytes - Viewed (0) -
cmd/erasure-server-pool.go
// Return the disks belonging to the poolIdx, and setIdx. func (z *erasureServerPools) GetDisks(poolIdx, setIdx int) ([]StorageAPI, error) { if poolIdx < len(z.serverPools) && setIdx < len(z.serverPools[poolIdx].sets) { return z.serverPools[poolIdx].sets[setIdx].getDisks(), nil } return nil, fmt.Errorf("Matching pool %s, set %s not found", humanize.Ordinal(poolIdx+1), humanize.Ordinal(setIdx+1)) } // Return the count of disks in each pool
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 80.5K bytes - Viewed (0) -
internal/http/listener.go
ClientWriteTimeout time.Duration SendBufSize int // SO_SNDBUF size for the socket connection, NOTE: this sets server and client connection RecvBufSize int // SO_RECVBUF size for the socket connection, NOTE: this sets server and client connection Interface string // This is a VRF device passed via `--interface` flag Trace func(msg string) // Trace when starting. }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 5.6K bytes - Viewed (0)