Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 25 for inicial (0.18 sec)

  1. internal/grid/README.md

    ## Streaming Requests
    
    Streams consists of an initial request with payload and allows for full two-way communication between the client and server.
    
    The handler function has this signature.
    
    Sample handler:
    ```go
        handler :=  func(ctx context.Context, payload []byte, in <-chan []byte, out chan<- []byte) *RemoteErr {
            fmt.Println("Got request with initial payload", p, "from", GetCaller(ctx context.Context))
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 9.4K bytes
    - Viewed (0)
  2. docs/sts/web-identity.md

    `https://minio-node-1.example.org/oauth_callback` and all is well.
    
    For deployments with a load-balancer (LB), it is required that the LB is configured to send requests from the same user/client-app to the same backend MinIO server (at least for the initial login request and subsequent redirection, as the OpenID auth flow's state parameter is currently local to the MinIO server). For this setup, set the `MINIO_BROWSER_REDIRECT_URL` parameter to the publicly/client-accessible endpoint for the MinIO Console....
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 19.2K bytes
    - Viewed (1)
  3. docs/kms/README.md

    ### 1. Fetch the root identity
    
    As the initial step, fetch the private key and certificate of the root identity:
    
    ```sh
    curl -sSL --tlsv1.2 \
         -O 'https://raw.githubusercontent.com/minio/kes/master/root.key' \
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 7.1K bytes
    - Viewed (0)
  4. cmd/metrics.go

    		prometheus.NewDesc(
    			prometheus.BuildFQName(healMetricsNamespace, "time", "since_last_activity"),
    			"Time elapsed (in nano seconds) since last self healing activity. This is set to -1 until initial self heal activity",
    			nil, nil),
    		prometheus.GaugeValue,
    		float64(dur),
    	)
    	for k, v := range bgSeq.getScannedItemsMap() {
    		ch <- prometheus.MustNewConstMetric(
    			prometheus.NewDesc(
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 02 06:48:36 GMT 2024
    - 16.9K bytes
    - Viewed (0)
  5. internal/grid/types.go

    }
    
    // JSON is a wrapper around a T object that can be serialized.
    // There is an internal value
    type JSON[T any] struct {
    	p   *JSONPool[T]
    	val *T
    }
    
    // NewJSON returns a new JSONPool.
    // No initial value is set.
    func (p *JSONPool[T]) NewJSON() *JSON[T] {
    	var j JSON[T]
    	j.p = p
    	return &j
    }
    
    // NewJSONWith returns a new JSON with the provided value.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Apr 01 23:42:09 GMT 2024
    - 15.4K bytes
    - Viewed (0)
  6. cmd/object-multipart-handlers.go

    	// Read compression metadata preserved in the init multipart for the decision.
    	_, isCompressed := mi.UserDefined[ReservedMetadataPrefix+"compression"]
    	// Compress only if the compression is enabled during initial multipart.
    	var idxCb func() []byte
    	if isCompressed {
    		wantEncryption := crypto.Requested(r.Header) || isEncrypted
    		s2c, cb := newS2CompressReader(reader, actualPartSize, wantEncryption)
    		idxCb = cb
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Mar 28 17:44:56 GMT 2024
    - 39K bytes
    - Viewed (0)
  7. docs/sts/etcd.md

      --listen-client-urls http://0.0.0.0:2379 \
      --advertise-client-urls http://0.0.0.0:2379 \
      --listen-peer-urls http://0.0.0.0:2380 \
      --initial-advertise-peer-urls http://0.0.0.0:2380 \
      --initial-cluster s1=http://0.0.0.0:2380 \
      --initial-cluster-token tkn \
      --initial-cluster-state new
    ```
    
    You may also setup etcd with TLS following this documentation [here](https://coreos.com/etcd/docs/latest/op-guide/security.html)
    
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Sep 29 04:28:45 GMT 2022
    - 3.4K bytes
    - Viewed (0)
  8. internal/grid/muxclient.go

    func (m *muxClient) RequestStateless(h HandlerID, req []byte, out chan<- Response) {
    	if m.init {
    		out <- Response{Err: errors.New("mux client already used")}
    	}
    	m.init = true
    
    	// Try to grab an initial block.
    	m.singleResp = false
    	msg := message{
    		Op:         OpConnectMux,
    		Handler:    h,
    		Flags:      FlagEOF,
    		Payload:    req,
    		DeadlineMS: uint32(m.deadline.Milliseconds()),
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 14.2K bytes
    - Viewed (0)
  9. cmd/dynamic-timeouts_test.go

    	timeout := newDynamicTimeout(time.Minute, time.Second)
    
    	initial := timeout.Timeout()
    
    	for i := 0; i < dynamicTimeoutLogSize; i++ {
    		timeout.LogFailure()
    	}
    
    	adjusted := timeout.Timeout()
    
    	if initial >= adjusted {
    		t.Errorf("Failure to increase timeout, expected %v to be more than %v", adjusted, initial)
    	}
    }
    
    func TestDynamicTimeoutDualIncrease(t *testing.T) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Oct 14 10:08:40 GMT 2022
    - 5.4K bytes
    - Viewed (0)
  10. cmd/leak-detect_test.go

    	}
    	return snapshot
    }
    
    // CompareCurrentSnapshot - Compares the initial relevant stack trace with the current one (during the time of invocation).
    func (initialSnapShot LeakDetect) CompareCurrentSnapshot() []string {
    	var stackDiff []string
    	for _, g := range pickRelevantGoroutines() {
    		// Identify the Go routines those were not present in the initial snapshot.
    		// In other words a stack diff.
    		if !initialSnapShot.relevantRoutines[g] {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 5.2K bytes
    - Viewed (0)
Back to top