Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 8 of 8 for Channel (0.05 seconds)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
Back to Top