- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 139 for syncs (0.19 sec)
-
src/testing/testing.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 76.1K bytes - Viewed (0) -
pilot/pkg/model/push_context.go
// See the License for the specific language governing permissions and // limitations under the License. package model import ( "cmp" "encoding/json" "fmt" "math" "sort" "strings" "sync" "time" "go.uber.org/atomic" "k8s.io/apimachinery/pkg/types" extensions "istio.io/api/extensions/v1alpha1" meshconfig "istio.io/api/mesh/v1alpha1" networking "istio.io/api/networking/v1alpha3"
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 09:02:11 UTC 2024 - 91.8K bytes - Viewed (0) -
cluster/gce/windows/k8s-node-setup.psm1
# kube-proxy --master=https://35.239.84.171 # --kubeconfig=/var/lib/kube-proxy/kubeconfig --cluster-cidr=10.64.0.0/14 # --oom-score-adj=-998 --v=2 # --iptables-sync-period=1m --iptables-min-sync-period=10s # --ipvs-sync-period=1m --ipvs-min-sync-period=10s # And also with various volumeMounts and "securityContext: privileged: true". $default_kubeproxy_args = @(` "--kubeconfig=${env:KUBEPROXY_KUBECONFIG}",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 21:13:22 UTC 2024 - 88.3K bytes - Viewed (0) -
src/cmd/dist/test.go
buildmode: "pie", ldflags: "-linkmode=internal", pkg: "os/user", }) } } // sync tests if t.hasParallelism() { t.registerTest("sync -cpu=10", &goTest{ variant: "cpu10", timeout: 120 * time.Second, cpu: "10", pkg: "sync", }) } const cgoHeading = "Testing cgo" if t.cgoEnabled { t.registerCgoTests(cgoHeading) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 20 16:01:35 UTC 2024 - 50K bytes - Viewed (0) -
pkg/kubelet/status/status_manager_test.go
status.Message = "second version bump" m.SetPodStatus(pod, status) t.Logf("sync batch before syncPods pushes latest status, resulting in one update during the batch") m.syncBatch(true) verifyUpdates(t, m, 0) verifyActions(t, m, []core.Action{getAction(), patchAction()}) t.Logf("Nothing left in the channel to sync") verifyActions(t, m, []core.Action{}) t.Log("Unchanged status should not send an update")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 02 16:27:19 UTC 2024 - 68.1K bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/pv_controller.go
// The binding is not completed; let PVC sync handle it logger.V(4).Info("Synchronizing PersistentVolume, volume not bound yet, waiting for syncClaim to fix it", "volumeName", volume.Name) } else { // Dangling PV; try to re-establish the link in the PVC sync
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 08:42:31 UTC 2024 - 89.2K bytes - Viewed (0) -
src/os/os_test.go
{"Seek", func(f *File) error { _, err := f.Seek(0, io.SeekStart); return err }}, {"Stat", func(f *File) error { _, err := f.Stat(); return err }}, {"Sync", func(f *File) error { return f.Sync() }}, {"Truncate", func(f *File) error { return f.Truncate(0) }}, {"Write", func(f *File) error { _, err := f.Write(make([]byte, 0)); return err }},
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 83.1K bytes - Viewed (0) -
pkg/volume/testing/testing.go
See the License for the specific language governing permissions and limitations under the License. */ package testing import ( "fmt" "os" "path/filepath" goruntime "runtime" "strings" "sync" "testing" "time" "k8s.io/klog/v2" "k8s.io/apimachinery/pkg/util/sets" "k8s.io/utils/exec" testingexec "k8s.io/utils/exec/testing" utilstrings "k8s.io/utils/strings" v1 "k8s.io/api/core/v1"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 12:32:15 UTC 2024 - 53.3K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/customresource_handler.go
See the License for the specific language governing permissions and limitations under the License. */ package apiserver import ( "fmt" "net/http" "sort" "strings" "sync" "sync/atomic" "time" "sigs.k8s.io/structured-merge-diff/v4/fieldpath" apiextensionshelpers "k8s.io/apiextensions-apiserver/pkg/apihelpers" apiextensionsinternal "k8s.io/apiextensions-apiserver/pkg/apis/apiextensions"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 28 19:06:46 UTC 2024 - 52.9K bytes - Viewed (0) -
cmd/erasure-object.go
ReadData: readData, Healing: false, } mrfCheck := make(chan FileInfo) defer xioutil.SafeClose(mrfCheck) var rw sync.Mutex // Ask for all disks first; go func() { ctx, cancel := context.WithCancel(ctx) defer cancel() wg := sync.WaitGroup{} for i, disk := range disks { if disk == nil { done <- false continue } if !disk.IsOnline() {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 78.6K bytes - Viewed (0)