- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for resync (0.26 sec)
-
cmd/bucket-replication.go
Path: path, Error: errStr, } } // delete resync metadata from replication resync state in memory func (p *ReplicationPool) deleteResyncMetadata(ctx context.Context, bucket string) { if p == nil { return } p.resyncer.Lock() delete(p.resyncer.statusMap, bucket) defer p.resyncer.Unlock() globalSiteResyncMetrics.deleteBucket(bucket) }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 112.2K bytes - Viewed (1) -
cmd/site-replication.go
} } return pi, true } // startResync initiates resync of data to peerSite specified. The overall site resync status // is maintained in .minio.sys/buckets/site-replication/resync/<deployment-id.meta>, while collecting // individual bucket resync status in .minio.sys/buckets/<bucket-name>/replication/resync.bin
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 25 15:50:16 GMT 2024 - 184.1K bytes - Viewed (1) -
CHANGELOG/CHANGELOG-1.4.md
If this happens to you, you can wait at most 10 minutes for the replication controller to start a resync, the extra pods will then be deleted. Or, you can manually trigger a resync by change the replicas in the spec of the replication controller. ### kubectl delete: < v1.4.0 client vs >=v1.4.0 cluster
Plain Text - Registered: Fri May 03 09:05:14 GMT 2024 - Last Modified: Thu Dec 24 02:28:26 GMT 2020 - 133.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/CallTest.kt
assertThat(expected.message).isEqualTo("Already Executed") } assertThat(server.takeRequest().headers["User-Agent"]).isEqualTo("SyncApiTest") } @Test fun illegalToExecuteTwice_Async() { server.enqueue( MockResponse( headers = headersOf("Content-Type", "text/plain"), body = "abc", ), ) val request = Request.Builder()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 10 19:46:48 GMT 2024 - 142.5K bytes - Viewed (0) -
fastapi/routing.py
errors: List[Any] = [] async with AsyncExitStack() as async_exit_stack: solved_result = await solve_dependencies( request=request, dependant=dependant, body=body, dependency_overrides_provider=dependency_overrides_provider, async_exit_stack=async_exit_stack, )
Python - Registered: Sun Apr 28 07:19:10 GMT 2024 - Last Modified: Tue Apr 02 02:48:51 GMT 2024 - 170.1K bytes - Viewed (0) -
api/go1.3.txt
pkg syscall (netbsd-386), const MCL_FUTURE ideal-int pkg syscall (netbsd-386), const MS_ASYNC = 1 pkg syscall (netbsd-386), const MS_ASYNC ideal-int pkg syscall (netbsd-386), const MS_INVALIDATE = 2 pkg syscall (netbsd-386), const MS_INVALIDATE ideal-int pkg syscall (netbsd-386), const MS_SYNC = 4 pkg syscall (netbsd-386), const MS_SYNC ideal-int pkg syscall (netbsd-386), const PROT_EXEC = 4
Plain Text - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Mon Jun 02 02:45:00 GMT 2014 - 117K bytes - Viewed (0) -
fastapi/applications.py
Python - Registered: Sun Apr 28 07:19:10 GMT 2024 - Last Modified: Tue Apr 02 02:48:51 GMT 2024 - 172.2K bytes - Viewed (0) -
cmd/metrics-v2.go
Subsystem: iamSubsystem, Name: "since_last_sync_millis", Help: "Time (in milliseconds) since last successful IAM data sync.", Type: gaugeMetric, }, Value: float64(sinceLastSyncMillis), }, { Description: MetricDescription{ Namespace: nodeMetricNamespace, Subsystem: iamSubsystem, Name: "sync_successes",
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 25 22:01:31 GMT 2024 - 132.6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/FuturesTest.java
callableBlocking.countDown(); // Need to wait for resultFuture to be returned. assertTrue(executor.awaitTermination(10, SECONDS)); // But once the async function has returned a future we can include that in the toString assertThat(futureResult.toString()) .matches( "CombinedFuture@\\w+\\[status=PENDING,"
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Feb 20 17:00:05 GMT 2024 - 144.5K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/FuturesTest.java
callableBlocking.countDown(); // Need to wait for resultFuture to be returned. assertTrue(executor.awaitTermination(10, SECONDS)); // But once the async function has returned a future we can include that in the toString assertThat(futureResult.toString()) .matches( "CombinedFuture@\\w+\\[status=PENDING,"
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Tue Feb 20 17:00:05 GMT 2024 - 144.5K bytes - Viewed (0)