- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 42 for syncAt (0.24 sec)
-
pkg/scheduler/schedule_one_test.go
limitations under the License. */ package scheduler import ( "context" "errors" "fmt" "math" "math/rand" "reflect" "regexp" goruntime "runtime" "sort" "strconv" "sync" "testing" "time" "github.com/google/go-cmp/cmp" v1 "k8s.io/api/core/v1" eventsv1 "k8s.io/api/events/v1" "k8s.io/apimachinery/pkg/api/resource" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:20:55 UTC 2024 - 128.1K bytes - Viewed (0) -
pkg/controller/job/job_controller_test.go
defer close(stopCh) go sharedInformers.Core().V1().Pods().Informer().Run(stopCh) cache.WaitForCacheSync(stopCh, podInformer.HasSynced) // Make sure the first syncJob sets the expectations, even after the caches synced. gotExpectedUIDs = manager.finalizerExpectations.getExpectedUIDs(jobKey) if diff := cmp.Diff(uids, gotExpectedUIDs); diff != "" {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 15:36:36 UTC 2024 - 229.2K bytes - Viewed (0) -
pkg/kubelet/kubelet_test.go
} } // testPodSyncLoopHandler is a lifecycle.PodSyncLoopHandler that is used for testing. type testPodSyncLoopHandler struct { // list of pods to sync podsToSync []*v1.Pod } // ShouldSync evaluates if the pod should be synced from the kubelet. func (a *testPodSyncLoopHandler) ShouldSync(pod *v1.Pod) bool { for _, podToSync := range a.podsToSync { if podToSync.UID == pod.UID { return true
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 106.9K bytes - Viewed (0) -
api/maven-api-model/src/main/mdo/maven.mdo
tools placing it in the repository. Valid values are: {@code none} (default), {@code converted} (repository manager converted this from an Maven 1 POM), {@code partner} (directly synced from a partner Maven 2 repository), {@code deployed} (was deployed from a Maven 2 instance), {@code verified} (has been hand verified as correct and final). </description>
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Tue Apr 23 13:29:46 UTC 2024 - 115.1K bytes - Viewed (0) -
src/cmd/go/alldocs.go
// for more information. // // # Sync workspace build list to modules // // Usage: // // go work sync // // Sync syncs the workspace's build list back to the // workspace's modules // // The workspace's build list is the set of versions of all the // (transitive) dependency modules used to do builds in the workspace. go // work sync generates that build list using the Minimal Version Selection
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 11 16:54:28 UTC 2024 - 142.4K bytes - Viewed (0) -
pkg/controller/garbagecollector/garbagecollector_test.go
// // Setting the period to 200ms allows the WaitForCacheSync() to check // for cache sync ~2 times in every wait.PollImmediateUntil() loop. // // The 1s sleep in the test allows GetDeletableResources and // gc.resyncMonitors to run ~5 times to ensure the changes to the // fakeDiscoveryClient are picked up. go gc.Sync(tCtx, fakeDiscoveryClient, 200*time.Millisecond)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 111.6K bytes - Viewed (0) -
cmd/object-handlers_test.go
) { // used for storing the uploadID's parsed on concurrent HTTP requests for NewMultipart upload on the same object. testUploads := struct { sync.Mutex uploads []string }{} objectName := "test-object-new-multipart-parallel" var wg sync.WaitGroup for i := 0; i < 10; i++ { wg.Add(1) // Initiate NewMultipart upload on the same object 10 times concurrrently. go func() {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:50:49 UTC 2024 - 161.9K bytes - Viewed (0) -
cmd/server_test.go
package cmd import ( "bytes" "context" "encoding/xml" "fmt" "io" "math/rand" "net/http" "net/url" "reflect" "regexp" "runtime" "strings" "sync" "testing" "time" "github.com/dustin/go-humanize" "github.com/minio/minio-go/v7/pkg/set" xhttp "github.com/minio/minio/internal/http" "github.com/minio/pkg/v3/policy" )
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 115.3K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/schema/cel/validation_test.go
See the License for the specific language governing permissions and limitations under the License. */ package cel import ( "bytes" "context" "flag" "fmt" "math" "strings" "sync" "testing" "time" "github.com/stretchr/testify/assert" "github.com/stretchr/testify/require" "k8s.io/klog/v2" "k8s.io/kube-openapi/pkg/validation/strfmt" "k8s.io/utils/ptr"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 17:14:10 UTC 2024 - 159.9K bytes - Viewed (0) -
cmd/admin-handlers.go
"encoding/pem" "errors" "fmt" "hash/crc32" "io" "math" "net/http" "net/url" "os" "path" "path/filepath" "regexp" "runtime" "sort" "strconv" "strings" "sync/atomic" "time" "github.com/dustin/go-humanize" "github.com/klauspost/compress/zip" "github.com/minio/madmin-go/v3" "github.com/minio/madmin-go/v3/estream" "github.com/minio/minio-go/v7/pkg/set"
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 98K bytes - Viewed (0)