Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 173 for Observe (0.17 sec)

  1. doc/go_mem.html

    <p>
    A read <i>r</i> of a memory location <i>x</i>
    holding a value
    that is not larger than a machine word must observe
    some write <i>w</i> such that <i>r</i> does not happen before <i>w</i>
    and there is no write <i>w'</i> such that <i>w</i> happens before <i>w'</i>
    and <i>w'</i> happens before <i>r</i>.
    That is, each read must observe a value written by a preceding or concurrent write.
    </p>
    
    <p>
    HTML
    - Registered: Tue May 07 11:14:38 GMT 2024
    - Last Modified: Mon Mar 04 15:54:42 GMT 2024
    - 26.6K bytes
    - Viewed (0)
  2. cmd/http-stats.go

    		return
    	}
    
    	if w != nil {
    		// Increment the prometheus http request response histogram with API, Bucket
    		bucketHTTPRequestsDuration.With(prometheus.Labels{
    			"api":    api,
    			"bucket": bucket,
    		}).Observe(w.TimeToFirstByte.Seconds())
    	}
    
    	bh.Lock()
    	defer bh.Unlock()
    
    	hstats, ok := bh.httpStats[bucket]
    	if !ok {
    		hstats = bucketHTTPAPIStats{
    			currentS3Requests: &HTTPAPIStats{},
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Mar 10 09:15:15 GMT 2024
    - 11.4K bytes
    - Viewed (0)
  3. cmd/tier_test.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"testing"
    	"time"
    )
    
    func TestTierMetrics(t *testing.T) {
    	tier := "WARM-1"
    	globalTierMetrics.Observe(tier, 200*time.Millisecond)
    	expSuccess := 10
    	expFailure := 5
    	for i := 0; i < expSuccess; i++ {
    		globalTierMetrics.logSuccess(tier)
    	}
    	for i := 0; i < expFailure; i++ {
    		globalTierMetrics.logFailure(tier)
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Dec 21 04:13:40 GMT 2023
    - 1.5K bytes
    - Viewed (0)
  4. cmd/metrics-v2_test.go

    		// observations. This is to test the channel based
    		// synchronization used internally.
    		select {
    		case <-ticker.C:
    			ttfbHist.With(prometheus.Labels{"api": obs.label}).Observe(obs.val)
    		}
    	}
    
    	metrics := getHistogramMetrics(ttfbHist, getBucketTTFBDistributionMD(), false)
    	// additional labels for +Inf for all histogram metrics
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Mar 04 18:05:56 GMT 2024
    - 2.3K bytes
    - Viewed (0)
  5. cmd/tier.go

    		Buckets: []float64{0.01, 0.1, 1, 2, 5, 10, 60, 5 * 60, 15 * 60, 30 * 60},
    	}, []string{"tier"}),
    }
    
    func (t *tierMetrics) Observe(tier string, dur time.Duration) {
    	t.histogram.With(prometheus.Labels{"tier": tier}).Observe(dur.Seconds())
    }
    
    func (t *tierMetrics) logSuccess(tier string) {
    	t.Lock()
    	defer t.Unlock()
    
    	stat := t.requestsCount[tier]
    	stat.success++
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 17 05:09:58 GMT 2024
    - 15.5K bytes
    - Viewed (0)
  6. docs/pt/docs/tutorial/path-params.md

    ```JSON
    {"item_id":3}
    ```
    
    !!! check "Verifique"
    	Observe que o valor recebido pela função (e também retornado por ela) é `3`, como um Python `int`, não como uma string `"3"`.
    
    Plain Text
    - Registered: Sun May 05 07:19:11 GMT 2024
    - Last Modified: Thu Apr 18 19:53:19 GMT 2024
    - 9.7K bytes
    - Viewed (0)
  7. docs/pt/docs/tutorial/path-operation-configuration.md

    # Configuração da Operação de Rota
    
    Existem vários parâmetros que você pode passar para o seu *decorador de operação de rota* para configurá-lo.
    
    !!! warning "Aviso"
        Observe que esses parâmetros são passados diretamente para o *decorador de operação de rota*, não para a sua *função de operação de rota*.
    
    ## Código de Status da Resposta
    
    Você pode definir o `status_code` (HTTP) para ser usado na resposta da sua *operação de rota*.
    
    Plain Text
    - Registered: Sun May 05 07:19:11 GMT 2024
    - Last Modified: Tue Oct 17 05:59:11 GMT 2023
    - 5.9K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/util/concurrent/SequentialExecutor.java

       * worker runs and exhausts the queue, another thread enqueues a task and fails to schedule the
       * worker, and then the first thread's call to delegate.execute() returns. Without this counter,
       * it would observe the QUEUING state and set it to QUEUED, and the worker would never be
       * scheduled again for future submissions.
       */
      @GuardedBy("queue")
      private long workerRunCount = 0;
    
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Thu Feb 01 21:46:34 GMT 2024
    - 10.6K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/util/concurrent/AtomicLongMap.java

       *
       * The problem with these is that remove(K, long) has to be done in two phases by definition ---
       * first decrementing to zero, and then removing. putIfAbsent or replace could observe the
       * intermediate zero-state. Ways we could deal with this are:
       *
       * - Don't define any of the ConcurrentMap operations. This is the current state of affairs.
       *
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Apr 01 16:15:01 GMT 2024
    - 14.1K bytes
    - Viewed (0)
  10. docs/pt/docs/python-types.md

    Ao fazer isso, seu editor pode fornecer suporte mesmo durante o processamento de itens da lista:
    
    <img src="/img/python-types/image05.png">
    
    Sem tipos, isso é quase impossível de alcançar.
    
    Observe que a variável `item` é um dos elementos da lista `items`.
    
    E, ainda assim, o editor sabe que é um `str` e fornece suporte para isso.
    
    #### `Tuple` e `Set`
    
    Você faria o mesmo para declarar `tuple`s e `set`s:
    
    Plain Text
    - Registered: Sun May 05 07:19:11 GMT 2024
    - Last Modified: Fri Mar 22 01:42:11 GMT 2024
    - 9.6K bytes
    - Viewed (0)
Back to top