- Sort Score
- Result 10 results
- Languages All
Results 151 - 160 of 1,199 for syncAt (0.2 sec)
-
api/openapi-spec/v3/apis__coordination.k8s.io__v1_openapi.json
NotOlderThan\n is interpreted as \"data at least as new as the provided `resourceVersion`\"\n and the bookmark event is send when the state is synced\n to a `resourceVersion` at least as fresh as the one provided by the ListOptions.\n If `resourceVersion` is unset, this is interpreted as \"consistent read\" and the\n bookmark event is send when the state is synced at least to the moment\n when request started being processed.\n- `resourceVersionMatch` set to any other value or unset\n Invalid error...
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 08 04:18:56 UTC 2024 - 136.6K bytes - Viewed (0) -
src/runtime/race/testdata/waitgroup_test.go
package race_test import ( "runtime" "sync" "testing" "time" ) func TestNoRaceWaitGroup(t *testing.T) { var x int _ = x var wg sync.WaitGroup n := 1 for i := 0; i < n; i++ { wg.Add(1) j := i go func() { x = j wg.Done() }() } wg.Wait() } func TestRaceWaitGroup(t *testing.T) { var x int _ = x var wg sync.WaitGroup n := 2 for i := 0; i < n; i++ {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Nov 03 22:09:38 UTC 2017 - 5.3K bytes - Viewed (0) -
cmd/site-replication.go
}) if err != nil { return errSRBucketMetaError(err) } } } } // Order matters from now on how the information is // synced to remote sites. // Policies should be synced first. { // Replicate IAM policies on local to all peers. allPolicyDocs, err := globalIAMSys.ListPolicyDocs(ctx, "") if err != nil { return errSRBackendIssue(err) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 184.3K bytes - Viewed (0) -
test/fixedbugs/issue27938.go
// a qualified identifier with non-existing package. package p type _ struct { F sync.Mutex // ERROR "undefined: sync|expected package|reference to undefined name" } type _ struct { sync.Mutex // ERROR "undefined: sync|expected package|reference to undefined name" } type _ interface { sync.Mutex // ERROR "undefined: sync|expected package|expected signature or type name|reference to undefined name"
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jul 06 00:02:11 UTC 2022 - 696 bytes - Viewed (0) -
pkg/controller/daemon/daemon_controller.go
// dsStoreSynced returns true if the daemonset store has been synced at least once. // Added as a member to the struct to allow injection for testing. dsStoreSynced cache.InformerSynced // historyLister get list/get history from the shared informers's store historyLister appslisters.ControllerRevisionLister // historyStoreSynced returns true if the history store has been synced at least once.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 51.3K bytes - Viewed (0) -
api/go1.23.txt
pkg sync/atomic, func OrInt64(*int64, int64) int64 #61395 pkg sync/atomic, func OrUint32(*uint32, uint32) uint32 #61395 pkg sync/atomic, func OrUint64(*uint64, uint64) uint64 #61395 pkg sync/atomic, func OrUintptr(*uintptr, uintptr) uintptr #61395 pkg sync/atomic, method (*Int32) And(int32) int32 #61395 pkg sync/atomic, method (*Int32) Or(int32) int32 #61395 pkg sync/atomic, method (*Int64) And(int64) int64 #61395
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jun 05 20:48:49 UTC 2024 - 8.4K bytes - Viewed (0) -
pkg/kube/util.go
// * Cluster.CertificateAuthority. While this reads from files, the result is not attached to the request and is instead // entirely local } return nil } type Syncer interface { HasSynced() bool } func AllSynced[T Syncer](syncers []T) bool { for _, h := range syncers { if !h.HasSynced() { return false } } return true
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 05:10:23 UTC 2024 - 18.6K bytes - Viewed (0) -
platforms/ide/tooling-api/src/crossVersionTest/groovy/org/gradle/integtests/tooling/r22/CancellationCrossVersionSpec.groovy
def sync = server.expectAndBlock("registered") def resultHandler = new TestResultHandler() when: withConnection { ProjectConnection connection -> def build = connection.newBuild() build.forTasks(':sub:broken') build.withCancellationToken(cancel.token()) build.run(resultHandler) sync.waitForAllPendingCalls(resultHandler)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Sep 26 14:49:20 UTC 2023 - 8.2K bytes - Viewed (0) -
api/openapi-spec/v3/apis__networking.k8s.io__v1alpha1_openapi.json
NotOlderThan\n is interpreted as \"data at least as new as the provided `resourceVersion`\"\n and the bookmark event is send when the state is synced\n to a `resourceVersion` at least as fresh as the one provided by the ListOptions.\n If `resourceVersion` is unset, this is interpreted as \"consistent read\" and the\n bookmark event is send when the state is synced at least to the moment\n when request started being processed.\n- `resourceVersionMatch` set to any other value or unset\n Invalid error...
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 08 04:18:56 UTC 2024 - 196.5K bytes - Viewed (0) -
pkg/proxy/ipvs/ipset_test.go
expectedEntries []string }{ { name: "normal ipset sync", set: &utilipset.IPSet{ Name: "foo", }, setType: utilipset.HashIPPort, ipv6: false, activeEntries: []string{"172.17.0.4,tcp:80"}, currentEntries: nil, expectedEntries: []string{"172.17.0.4,tcp:80"}, }, { name: "ipset IPv6 sync with no new entries", set: &utilipset.IPSet{ Name: "abz", },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Dec 19 01:20:51 UTC 2023 - 7.5K bytes - Viewed (0)