Search Options

Results per page
Sort
Preferred Languages
Advance

Results 151 - 160 of 1,949 for _context (0.04 sec)

  1. cmd/bucket-replication-utils.go

    // parse size from content-range header
    func parseSizeFromContentRange(h http.Header) (sz int64, err error) {
    	cr := h.Get(xhttp.ContentRange)
    	if cr == "" {
    		return sz, fmt.Errorf("Content-Range not set")
    	}
    	parts := contentRangeRegexp.FindStringSubmatch(cr)
    	if len(parts) != 4 {
    		return sz, fmt.Errorf("invalid Content-Range header %s", cr)
    	}
    	if parts[3] == "*" {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 26.1K bytes
    - Viewed (0)
  2. internal/grid/stream.go

    	// Canceling the context will cause the context cancellation error to be returned.
    	responses <-chan Response
    	cancel    context.CancelCauseFunc
    
    	// Requests sent to the server.
    	// If the handler is defined with 0 incoming capacity this will be nil.
    	// Channel *must* be closed to signal the end of the stream.
    	// If the request context is canceled, the stream will no longer process requests.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 3.1K bytes
    - Viewed (0)
  3. internal/kms/stub.go

    func (s StubKMS) Version(ctx context.Context) (string, error) {
    	return "stub", nil
    }
    
    // APIs returns supported APIs
    func (s StubKMS) APIs(ctx context.Context) ([]madmin.KMSAPI, error) {
    	return []madmin.KMSAPI{
    		{Method: http.MethodGet, Path: "stub/path"},
    	}, nil
    }
    
    // Status returns a set of endpoints and their KMS status.
    func (s StubKMS) Status(context.Context) (map[string]madmin.ItemState, error) {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Aug 18 06:43:03 UTC 2024
    - 3.6K bytes
    - Viewed (0)
  4. internal/dsync/locker.go

    	Lock(ctx context.Context, args LockArgs) (bool, error)
    
    	// Do read unlock for given LockArgs. It should return
    	// * a boolean to indicate success/failure of the operation
    	// * an error on failure of unlock request operation.
    	// Canceling the context will abort the remote call.
    	// In that case, the resource may or may not be unlocked.
    	RUnlock(ctx context.Context, args LockArgs) (bool, error)
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Jan 18 20:44:38 UTC 2022
    - 2.7K bytes
    - Viewed (0)
  5. internal/once/init.go

    	return nil
    }
    
    // DoWithContext is similar to Do except that it accepts a context as an argument to be passed.
    func (l *Init) DoWithContext(ctx context.Context, f func(context.Context) error) error {
    	if atomic.LoadUint32(&l.done) == 0 {
    		return l.doWithContext(ctx, f)
    	}
    	return nil
    }
    
    func (l *Init) doWithContext(ctx context.Context, f func(context.Context) error) error {
    	l.m.Lock()
    	defer l.m.Unlock()
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue May 09 04:20:31 UTC 2023
    - 2.1K bytes
    - Viewed (0)
  6. association.go

    			relValuesMap, _ := schema.GetIdentityFieldValuesMapFromValues(association.DB.Statement.Context, values, rel.FieldSchema.PrimaryFields)
    
    			cleanUpDeletedRelations := func(data reflect.Value) {
    				if _, zero := rel.Field.ValueOf(association.DB.Statement.Context, data); !zero {
    					fieldValue := reflect.Indirect(rel.Field.ReflectValueOf(association.DB.Statement.Context, data))
    					primaryValues := make([]interface{}, len(rel.FieldSchema.PrimaryFields))
    
    Registered: Sun Dec 28 09:35:17 UTC 2025
    - Last Modified: Sun Oct 26 12:09:12 UTC 2025
    - 23.6K bytes
    - Viewed (0)
  7. cmd/bucket-quota.go

    	bucketStorageCache.InitOnce(10*time.Second,
    		cachevalue.Opts{ReturnLastGood: true, NoWait: true},
    		func(ctx context.Context) (DataUsageInfo, error) {
    			if objAPI == nil {
    				return DataUsageInfo{}, errServerNotInitialized
    			}
    			ctx, done := context.WithTimeout(ctx, 2*time.Second)
    			defer done()
    
    			return loadDataUsageFromBackend(ctx, objAPI)
    		},
    	)
    }
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 4.4K bytes
    - Viewed (0)
  8. cmd/erasure-server-pool.go

    func (z *erasureServerPools) StorageInfo(ctx context.Context, metrics bool) StorageInfo {
    	return globalNotificationSys.StorageInfo(ctx, z, metrics)
    }
    
    func (z *erasureServerPools) NSScanner(ctx context.Context, updates chan<- DataUsageInfo, wantCycle uint32, healScanMode madmin.HealScanMode) error {
    	// Updates must be closed before we return.
    	defer xioutil.SafeClose(updates)
    
    	ctx, cancel := context.WithCancel(ctx)
    	defer cancel()
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 89.2K bytes
    - Viewed (0)
  9. cmd/iam.go

    // only via IAM notifications.
    func (sys *IAMSys) LoadGroup(ctx context.Context, objAPI ObjectLayer, group string) error {
    	if !sys.Initialized() {
    		return errServerNotInitialized
    	}
    
    	return sys.store.GroupNotificationHandler(ctx, group)
    }
    
    // LoadPolicy - reloads a specific canned policy from backend disks or etcd.
    func (sys *IAMSys) LoadPolicy(ctx context.Context, objAPI ObjectLayer, policyName string) error {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Wed Oct 15 17:00:45 UTC 2025
    - 76.5K bytes
    - Viewed (0)
  10. docs/es/docs/tutorial/cors.md

    * `allow_headers` - Una lista de headers de request HTTP que deberían estar soportados para requests cross-origin. Por defecto es `[]`. Puedes usar `['*']` para permitir todos los headers. Los headers `Accept`, `Accept-Language`, `Content-Language` y `Content-Type` siempre están permitidos para <a href="https://developer.mozilla.org/en-US/docs/Web/HTTP/CORS#simple_requests" class="external-link" rel="noopener" target="_blank">requests CORS simples</a>.
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Wed Dec 17 20:41:43 UTC 2025
    - 5.9K bytes
    - Viewed (0)
Back to top