- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 357 for once (0.12 sec)
-
operator/cmd/mesh/profile-diff_test.go
} func TestProfileDiffDirect(t *testing.T) { cases := []profileDiffTestcase{ { // We won't be parsing with Cobra, but this is the command equivalent args: "profile diff default openshift", // This is just one of the many differences expectedString: "+ profile: openshift", // The profile doesn't change istiocoredns, so we shouldn't see this in the diff notExpected: "- istiocoredns:",
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Jan 10 05:10:03 GMT 2024 - 3.6K bytes - Viewed (1) -
cni/pkg/nodeagent/pod_cache.go
Netns: newnetns, } return p.UpsertPodCacheWithNetns(string(pod.UID), wl), nil } // Update the cache with the given Netns. If there is already a Netns for the given uid, we return it, and close the one provided. func (p *podNetnsCache) UpsertPodCacheWithNetns(uid string, workload WorkloadInfo) Netns { // lock current snapshot pod map p.mu.Lock() defer p.mu.Unlock()
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 4.5K bytes - Viewed (0) -
istioctl/pkg/workload/workload_test.go
want map[string]string }{ {name: "empty", arg: []string{""}, want: map[string]string{"": ""}}, {name: "one-valid", arg: []string{"key=value"}, want: map[string]string{"key": "value"}}, {name: "one-valid-double-equals", arg: []string{"key==value"}, want: map[string]string{"key": "=value"}}, {name: "one-key-only", arg: []string{"key"}, want: map[string]string{"key": ""}}, } for _, tt := range tests {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Mar 27 16:59:05 GMT 2024 - 14.6K bytes - Viewed (0) -
cmd/metacache-entries.go
// Entries without metadata will only be present in non-recursive scans. metadata []byte // cached contains the metadata if decoded. cached *xlMetaV2 // Indicates the entry can be reused and only one reference to metadata is expected. reusable bool } // isDir returns if the entry is representing a prefix directory. func (e metaCacheEntry) isDir() bool {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 16:43:43 GMT 2024 - 23.2K bytes - Viewed (0) -
cmd/metrics-realtime.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 10 16:28:08 GMT 2024 - 6.1K bytes - Viewed (0) -
src/cmd/asm/internal/arch/riscv64.go
// assembler. package arch import ( "cmd/internal/obj" "cmd/internal/obj/riscv" ) // IsRISCV64AMO reports whether the op (as defined by a riscv.A* // constant) is one of the AMO instructions that requires special // handling. func IsRISCV64AMO(op obj.As) bool { switch op { case riscv.ASCW, riscv.ASCD, riscv.AAMOSWAPW, riscv.AAMOSWAPD, riscv.AAMOADDW, riscv.AAMOADDD,
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Sun Mar 15 08:13:28 GMT 2020 - 943 bytes - Viewed (0) -
istioctl/pkg/util/handlers/handlers.go
// Pod is referred to using something like "deployment/httpbin". Use the kubectl // libraries to look up the resource name, find the pods it selects, and return // one of those pods. builder := factory.NewBuilder(). WithScheme(kubelib.IstioScheme, kubelib.IstioScheme.PrioritizedVersionsAllGroups()...). NamespaceParam(ns).DefaultNamespace(). SingleResourceType()
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Feb 06 15:01:41 GMT 2024 - 6.2K bytes - Viewed (0) -
cmd/erasure-healing-common_test.go
fourNanoSecs := time.Unix(4, 0).UTC() modTimesThreeNone := make([]time.Time, 16) modTimesThreeFour := make([]time.Time, 16) for i := 0; i < 16; i++ { // Have 13 good xl.meta, 12 for default parity count = 4 (EC:4) and one // to be tampered with. if i > 12 { modTimesThreeFour[i] = fourNanoSecs modTimesThreeNone[i] = timeSentinel continue } modTimesThreeFour[i] = threeNanoSecs
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jan 30 20:43:25 GMT 2024 - 23K bytes - Viewed (1) -
internal/bucket/bandwidth/measurement.go
) const ( // betaBucket is the weight used to calculate exponential moving average betaBucket = 0.1 // Number of averages considered = 1/(1-betaObject) ) // bucketMeasurement captures the bandwidth details for one bucket type bucketMeasurement struct { lock sync.Mutex bytesSinceLastWindow uint64 // Total bytes since last window was processed startTime time.Time // Start time for window
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Jun 03 20:41:51 GMT 2023 - 2.9K bytes - Viewed (0) -
cmd/net.go
scheme = u.Scheme // Use the given parameter again if url.Parse() // didn't return any useful result. if addr == "" { addr = hostAddr scheme = "http" } // At this point, addr can be one of the following form: // ":9000" // "localhost:9000" // "localhost" <- in this case, we check for scheme host, port, err := net.SplitHostPort(addr) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Mar 26 15:00:38 GMT 2024 - 9.3K bytes - Viewed (0)