- Sort Score
- Num 10 results
- Language All
Results 1 - 8 of 8 for Channel (0.05 seconds)
-
cmd/bucket-replication.go
configFile := path.Join(bucketMetaPrefix, bucket, replicationDir, resyncFileName) return saveConfig(ctx, objectAPI, configFile, buf) } // getReplicationDiff returns un-replicated objects in a channel. // If a non-nil channel is returned it must be consumed fully or // the provided context must be canceled.
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 118.2K bytes - Click Count (0) -
cmd/admin-handlers.go
return } setEventStreamHeaders(w) // Trace Publisher and peer-trace-client uses nonblocking send and hence does not wait for slow receivers. // Keep 100k buffered channel. // If receiver cannot keep up with that we drop events. traceCh := make(chan []byte, 100000) peers, _ := newPeerRestClients(globalEndpoints)
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 99.7K bytes - Click Count (0) -
cmd/metrics-v2.go
wg.Add(2) go publish(ReportMetrics(GlobalContext, c.metricsGroups)) go publish(globalNotificationSys.GetClusterMetrics(GlobalContext)) wg.Wait() } // ReportMetrics reports serialized metrics to the channel passed for the metrics generated. func ReportMetrics(ctx context.Context, metricsGroups []*MetricsGroupV2) <-chan MetricV2 { ch := make(chan MetricV2) go func() { defer xioutil.SafeClose(ch)
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 133.6K bytes - Click Count (0) -
CHANGELOG/CHANGELOG-1.4.md
* etcd: watcher centralize error handling ([#32907](https://github.com/kubernetes/kubernetes/pull/32907), [@hongchaodeng](https://github.com/hongchaodeng)) * etcd: stop watcher when watch channel is closed ([#33003](https://github.com/kubernetes/kubernetes/pull/33003), [@hongchaodeng](https://github.com/hongchaodeng))
Created: Fri Dec 26 09:05:12 GMT 2025 - Last Modified: Thu Dec 24 02:28:26 GMT 2020 - 133.5K bytes - Click Count (0) -
okhttp/src/jvmMain/resources/okhttp3/internal/publicsuffix/PublicSuffixDatabase.list
cesena-forlì.it cesenaforli.it cesenaforlì.it cf cf-ipfs.com cfa cfd cfolks.pl cg ch ch.eu.org ch.it ch.trendhosting.cloud chambagri.fr championship.aero chanel channel channelsdvr.net charity charter.aero chase chat cheap cheap.jp cherkassy.ua cherkasy.ua chernigov.ua chernihiv.ua chernivtsi.ua chernovtsy.ua chiba.jp
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Tue May 27 22:00:49 GMT 2025 - 129.6K bytes - Click Count (3) -
okhttp/src/androidMain/assets/PublicSuffixDatabase.list
cesena-forlì.it cesenaforli.it cesenaforlì.it cf cf-ipfs.com cfa cfd cfolks.pl cg ch ch.eu.org ch.it ch.trendhosting.cloud chambagri.fr championship.aero chanel channel channelsdvr.net charity charter.aero chase chat cheap cheap.jp cherkassy.ua cherkasy.ua chernigov.ua chernihiv.ua chernivtsi.ua chernovtsy.ua chiba.jp
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Tue Dec 31 14:50:53 GMT 2024 - 129.6K bytes - Click Count (2) -
CHANGELOG/CHANGELOG-1.5.md
* Fix base image pinning during upgrades via cluster/gce/upgrade.sh ([#33147](https://github.com/kubernetes/kubernetes/pull/33147), [@vishh](https://github.com/vishh)) * Remove the flannel experimental overlay ([#33862](https://github.com/kubernetes/kubernetes/pull/33862), [@luxas](https://github.com/luxas))
Created: Fri Dec 26 09:05:12 GMT 2025 - Last Modified: Thu Dec 24 02:28:26 GMT 2020 - 136.4K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/URLConnectionTest.kt
.status("ICY 200 OK") .addHeader("Accept-Ranges: none") .addHeader("Content-Type: audio/mpeg") .addHeader("icy-br:128") .addHeader("ice-audio-info: bitrate=128;samplerate=44100;channels=2") .addHeader("icy-br:128") .addHeader("icy-description:Rock") .addHeader("icy-genre:riders") .addHeader("icy-name:A2RRock") .addHeader("icy-pub:1")
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Sat Jun 21 20:36:35 GMT 2025 - 133.2K bytes - Click Count (0)