Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 25 for channel (0.2 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. cmd/admin-handlers.go

    			depID: dID,
    		})
    		m.Merge(&mLocal)
    		// Allow half the interval for collecting remote...
    		cctx, cancel := context.WithTimeout(ctx, interval/2)
    		mRemote := collectRemoteMetrics(cctx, types, collectMetricsOpts{
    			hosts: hostMap,
    			disks: diskMap,
    			jobID: jobID,
    			depID: dID,
    		})
    		cancel()
    		m.Merge(&mRemote)
    		if !byHost {
    			m.ByHost = nil
    		}
    		if !byDisk {
    			m.ByDisk = nil
    		}
    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)
  4. operator/cmd/mesh/testdata/manifest-generate/data-snapshot.tar.gz

    The charts in the `manifests` directory are used in istioctl to generate an installation manifest. If `values.yaml` is changed, be sure to update corresponding values changes in [../profiles/default.yaml](../profiles/default.yaml) ## Step 3. Update istioctl schema Istioctl uses a [schema](../../operator/pkg/apis/istio/v1alpha1/values_types.proto) to validate the values. Any changes to the schema must be added here, otherwise istioctl users will see errors. Once the schema file is updated, run: ```bash...
    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)
  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.30.md

      - [Changelog since v1.30.0-alpha.3](#changelog-since-v1300-alpha3)
      - [Changes by Kind](#changes-by-kind-4)
        - [API Change](#api-change-1)
        - [Feature](#feature-2)
        - [Bug or Regression](#bug-or-regression-4)
        - [Other (Cleanup or Flake)](#other-cleanup-or-flake-1)
      - [Dependencies](#dependencies-4)
        - [Added](#added-4)
        - [Changed](#changed-4)
        - [Removed](#removed-4)
    - [v1.30.0-alpha.3](#v1300-alpha3)
    Plain Text
    - Registered: Fri May 03 09:05:14 GMT 2024
    - Last Modified: Wed Apr 17 17:56:15 GMT 2024
    - 227.9K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/util/concurrent/FuturesTest.java

      }
    
      private static void doTestSuccessfulAsList_resultCancelledRacingInputDone() throws Exception {
        // Simple (combined.cancel -> input.cancel -> setOneValue):
        successfulAsList(ImmutableList.of(SettableFuture.create())).cancel(true);
    
        /*
         * Complex (combined.cancel -> input.cancel -> other.set -> setOneValue),
         * to show that this isn't just about problems with the input future we just
         * cancelled:
    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)
  9. okhttp/src/test/java/okhttp3/CallTest.kt

              callB.cancel()
              return MockResponse(body = (nextResponse++).toString())
            }
          }
        callA.enqueue(callback)
        callB.enqueue(callback)
        assertThat(server.takeRequest().path).isEqualTo("/a")
        callback.await(requestA.url).assertBody("A")
        // At this point we know the callback is ready, and that it will receive a cancel failure.
    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)
  10. android/guava/src/com/google/common/collect/Maps.java

      }
    
      /**
       * Computes the difference between two maps. This difference is an immutable snapshot of the state
       * of the maps at the time this method is called. It will never change, even if the maps change at
       * a later time.
       *
       * <p>Since this method uses {@code HashMap} instances internally, the keys of the supplied maps
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed May 01 18:44:57 GMT 2024
    - 159.6K bytes
    - Viewed (0)
Back to top