- Sort Score
- Result 10 results
- Languages All
Results 121 - 130 of 190 for idempotency (0.17 sec)
-
src/cmd/go/main.go
telemetry.Start() // Open the telemetry counter file so counters can be written to it. handleChdirFlag() toolchain.Select() telemetry.StartWithUpload() // Run the upload process. Opening the counter file is idempotent. flag.Usage = base.Usage flag.Parse() telemetry.Inc("go/invocations") telemetry.CountFlags("go/flag:", *flag.CommandLine) args := flag.Args() if len(args) < 1 { base.Usage() }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 21:09:11 UTC 2024 - 10K bytes - Viewed (0) -
pkg/volume/util/fsquota/project.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 20 14:49:03 UTC 2023 - 10.6K bytes - Viewed (0) -
pkg/kubelet/pod/pod_manager.go
pod, ok := pm.podByFullName[podFullName] return pod, ok } func (pm *basicManager) TranslatePodUID(uid types.UID) kubetypes.ResolvedPodUID { // It is safe to type convert to a resolved UID because type conversion is idempotent. if uid == "" { return kubetypes.ResolvedPodUID(uid) } pm.lock.RLock() defer pm.lock.RUnlock() if translated, ok := pm.translationByUID[kubetypes.MirrorPodUID(uid)]; ok { return translated
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 06:06:00 UTC 2024 - 11.9K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/apis/meta/v1/micro_time_test.go
time := MicroTime{} if err := time.Unmarshal(data); err != nil { t.Fatalf("Failed to unmarshal output: '%v': %v", input, err) } if !reflect.DeepEqual(input, time) { t.Errorf("Marshal->Unmarshal is not idempotent: '%v' vs '%v'", input, time) } } } func TestMicroTimeEqual(t *testing.T) { t1 := NewMicroTime(time.Now()) cases := []struct { name string x *MicroTime y *MicroTime
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 21:48:10 UTC 2024 - 11.1K bytes - Viewed (0) -
src/cmd/compile/internal/syntax/parser_test.go
"path/filepath" "regexp" "runtime" "strings" "sync" "testing" "time" ) var ( fast = flag.Bool("fast", false, "parse package files in parallel") verify = flag.Bool("verify", false, "verify idempotent printing") src_ = flag.String("src", "parser.go", "source file to parse") skip = flag.String("skip", "", "files matching this regular expression are skipped by TestStdLib") ) func TestParse(t *testing.T) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Mar 14 16:30:19 UTC 2024 - 12.2K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/tests/split_into_island_per_op.mlir
// RUN: tf-opt -tf-executor-split-into-island-per-op %s --split-input-file --verify-diagnostics | FileCheck %s // All tests also test for idempotence. // Test that functions must have a single graph op in their body, otherwise, the // pass will signal failure. // expected-error@+1 {{expected function to contain only a graph_op}} func.func @multiple_func_body_ops() { tf_executor.graph { tf_executor.island { "tf.NoOp"() : () -> ()
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Mon Oct 30 06:52:55 UTC 2023 - 20.2K bytes - Viewed (0) -
pkg/registry/core/service/ipallocator/controller/repair.go
// * Migrates old versions of Kubernetes services into the atomic ipallocator model automatically // // Can be run at infrequent intervals, and is best performed on startup of the master. // Is level driven and idempotent - all valid ClusterIPs will be updated into the ipallocator // map at the end of a single execution loop if no race is encountered. // // TODO: allocate new IPs if necessary // TODO: perform repair? type Repair struct {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Sep 30 15:46:06 UTC 2023 - 13.8K bytes - Viewed (0) -
pkg/kubelet/cm/memorymanager/policy_static.go
if err := p.validateState(s); err != nil { klog.ErrorS(err, "Invalid state, please drain node and remove policy state file") return err } return nil } // Allocate call is idempotent func (p *staticPolicy) Allocate(s state.State, pod *v1.Pod, container *v1.Container) (rerr error) { // allocate the memory only for guaranteed pods if v1qos.GetPodQOS(pod) != v1.PodQOSGuaranteed { return nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Nov 12 07:34:55 UTC 2023 - 34K bytes - Viewed (0) -
platforms/software/signing/src/integTest/groovy/org/gradle/plugins/signing/SigningPublicationsIntegrationSpec.groovy
} @Issue([ "https://github.com/gradle/gradle/issues/21857", "https://github.com/gradle/gradle/issues/22375" ]) def "sign publication should be idempotent"() { given: buildFile << """ apply plugin: 'maven-publish' ${keyInfo.addAsPropertiesScript()} publishing { publications {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jan 09 01:09:32 UTC 2024 - 26.9K bytes - Viewed (0) -
pkg/kube/krt/README.md
### Transformation constraints In order for the framework to properly handle dependencies and events, transformation functions must adhere by a few properties. Basically, Transformations must be stateless and idempotent. * Any querying of other `Collection`s _must_ be done through `krt.Fetch`. * Querying other data stores that may change is not permitted. * Querying external state (e.g. making HTTP calls) is not permitted.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Dec 18 17:21:50 UTC 2023 - 11.8K bytes - Viewed (0)