Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 20 for received1 (0.09 sec)

  1. doc/go1.17_spec.html

    </pre>
    
    
    <h3 id="Receive_operator">Receive operator</h3>
    
    <p>
    For an operand <code>ch</code> of <a href="#Channel_types">channel type</a>,
    the value of the receive operation <code>&lt;-ch</code> is the value received
    from the channel <code>ch</code>. The channel direction must permit receive operations,
    and the type of the receive operation is the element type of the channel.
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Oct 10 18:25:45 UTC 2024
    - 211.6K bytes
    - Viewed (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)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 99.7K bytes
    - Viewed (0)
  3. cmd/metrics-v2.go

    		Type:      counterMetric,
    	}
    }
    
    func getRepReceivedOperationsMD(namespace MetricNamespace) MetricDescription {
    	help := "Total number of objects received by this cluster"
    	if namespace == bucketMetricNamespace {
    		help = "Total number of objects received by this bucket from another source bucket"
    	}
    	return MetricDescription{
    		Namespace: namespace,
    		Subsystem: replicationSubsystem,
    		Name:      receivedCount,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 131.9K bytes
    - Viewed (0)
  4. manifests/addons/dashboards/istio-service-dashboard.json

              "format": "time_series",
              "hide": false,
              "intervalFactor": 1,
              "legendFormat": "",
              "refId": "A"
            }
          ],
          "title": "TCP Received Bytes",
          "type": "stat"
        },
        {
          "datasource": {
            "type": "prometheus",
            "uid": "${datasource}"
          },
          "fieldConfig": {
            "defaults": {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Mar 27 03:47:04 UTC 2024
    - 111.8K bytes
    - Viewed (0)
  5. docs/metrics/prometheus/grafana/bucket/minio-bucket.json

              "interval": "1m",
              "intervalFactor": 2,
              "legendFormat": "Data Received [{{bucket}}]",
              "refId": "A"
            }
          ],
          "title": "Total Data Received Rate",
          "type": "timeseries"
        },
        {
          "datasource": {
            "type": "prometheus",
            "uid": "${DS_PROMETHEUS}"
          },
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 11:11:51 UTC 2024
    - 101.8K bytes
    - Viewed (0)
  6. okhttp/src/test/java/okhttp3/CacheTest.kt

          """
          $url
          GET
          0
          HTTP/1.1 200 OK
          7
          :status: 200 OK
          :version: HTTP/1.1
          etag: foo
          content-length: 3
          OkHttp-Received-Millis: ${System.currentTimeMillis()}
          X-Android-Response-Source: NETWORK 200
          OkHttp-Sent-Millis: ${System.currentTimeMillis()}
    
          TLS_ECDHE_RSA_WITH_AES_256_CBC_SHA
          1
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Apr 10 19:46:48 UTC 2024
    - 108.6K bytes
    - Viewed (0)
  7. okhttp/src/test/java/okhttp3/CallTest.kt

        val receivedAt = System.currentTimeMillis()
        recordedResponse.assertCode(200)
          .assertSuccessful()
          .assertHeaders(
            Headers.Builder()
              .add("content-type", "text/plain")
              .add("content-length", "3")
              .build(),
          )
          .assertBody("abc")
          .assertSentRequestAtMillis(sentAt, receivedAt)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Apr 10 19:46:48 UTC 2024
    - 142.5K bytes
    - Viewed (0)
  8. cmd/bucket-replication.go

    	ReplicationTimestamp = "replication-timestamp"
    	// ReplicaStatus - this header is present if a replica was received by this cluster for this object version
    	ReplicaStatus = "replica-status"
    	// ReplicaTimestamp - the last time a replica was received by this cluster for this object version
    	ReplicaTimestamp = "replica-timestamp"
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 06:49:55 UTC 2024
    - 116.1K bytes
    - Viewed (0)
  9. manifests/addons/dashboards/istio-workload-dashboard.json

              "intervalFactor": 1,
              "legendFormat": "{{ source_workload }}.{{ source_workload_namespace}}",
              "refId": "B",
              "step": 2
            }
          ],
          "title": "Bytes Received from Incoming TCP Connection",
          "type": "timeseries"
        },
        {
          "datasource": {
            "type": "prometheus",
            "uid": "${datasource}"
          },
          "fieldConfig": {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Mar 27 03:47:04 UTC 2024
    - 102.7K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/util/concurrent/ClosingFuture.java

      }
    
      /**
       * Marks this step as the last step in the {@code ClosingFuture} pipeline. When this step is done,
       * {@code receiver} will be called with an object that contains the result of the operation. The
       * receiver can store the {@link ValueAndCloser} outside the receiver for later synchronous use.
       *
       * <p>After calling this method, you may not call {@link #finishToFuture()}, this method again, or
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Oct 08 19:36:35 UTC 2024
    - 98.5K bytes
    - Viewed (0)
Back to top