Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for Channel (0.32 sec)

  1. doc/go1.17_spec.html

    <p>
    A send statement sends a value on a channel.
    The channel expression must be of <a href="#Channel_types">channel type</a>,
    the channel direction must permit send operations,
    and the type of the value to be sent must be <a href="#Assignability">assignable</a>
    to the channel's element type.
    </p>
    
    <pre class="ebnf">
    SendStmt = Channel "&lt;-" Expression .
    Channel  = Expression .
    </pre>
    
    <p>
    HTML
    - Registered: Tue May 07 11:14:38 GMT 2024
    - Last Modified: Thu Apr 11 20:22:45 GMT 2024
    - 211.6K bytes
    - Viewed (0)
  2. 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.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 112.2K bytes
    - Viewed (1)
  3. operator/cmd/mesh/testdata/manifest-generate/data-snapshot.tar.gz

    mountPath: /var/run/secrets/workload-spiffe-credentials {{- end }} {{- if eq .Values.global.pilotCertProvider "istiod" }} - mountPath: /var/run/secrets/istio name: istiod-ca-cert {{- end }} - mountPath: /var/lib/istio/data name: istio-data # SDS channel between istioagent and Envoy - mountPath: /etc/istio/proxy name: istio-envoy {{- if eq .Values.global.jwtPolicy "third-party-jwt" }} - mountPath: /var/run/secrets/tokens name: istio-token {{- end }} - name: istio-podinfo mountPath: /etc/istio/pod...
    Others
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed Jan 10 05:10:03 GMT 2024
    - 198.1K bytes
    - Viewed (1)
  4. 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)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Apr 29 17:39:04 GMT 2024
    - 97.8K bytes
    - Viewed (2)
  5. 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)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 22:01:31 GMT 2024
    - 132.6K bytes
    - Viewed (0)
  6. okhttp/src/test/resources/okhttp3/internal/publicsuffix/public_suffix_list.dat

    cern
    
    // cfa : 2014-08-28 CFA Institute
    cfa
    
    // cfd : 2014-12-11 ShortDot SA
    cfd
    
    // chanel : 2015-04-09 Chanel International B.V.
    chanel
    
    // channel : 2014-05-08 Charleston Road Registry Inc.
    channel
    
    // charity : 2018-04-11 Public Interest Registry
    charity
    
    // chase : 2015-04-30 JPMorgan Chase Bank, National Association
    chase
    
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Wed Dec 20 23:27:07 GMT 2023
    - 240.3K bytes
    - Viewed (3)
  7. 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))
    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)
  8. 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))
    Plain Text
    - Registered: Fri May 03 09:05:14 GMT 2024
    - Last Modified: Thu Dec 24 02:28:26 GMT 2020
    - 136.4K bytes
    - Viewed (1)
  9. okhttp/src/test/java/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")
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Jan 20 10:30:28 GMT 2024
    - 131.7K bytes
    - Viewed (0)
Back to top