Search Options

Results per page
Sort
Preferred Languages
Advance

Results 101 - 110 of 677 for Contexto (0.09 sec)

  1. cmd/iam-store.go

    	getUsersSysType() UsersSysType
    	loadPolicyDoc(ctx context.Context, policy string, m map[string]PolicyDoc) error
    	loadPolicyDocWithRetry(ctx context.Context, policy string, m map[string]PolicyDoc, retries int) error
    	loadPolicyDocs(ctx context.Context, m map[string]PolicyDoc) error
    	loadUser(ctx context.Context, user string, userType IAMUserType, m map[string]UserIdentity) error
    	loadSecretKey(ctx context.Context, user string, userType IAMUserType) (string, error)
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Oct 14 16:35:37 UTC 2024
    - 83.2K bytes
    - Viewed (0)
  2. internal/grid/grid.go

    type ConnDialer func(ctx context.Context, address string) (net.Conn, error)
    
    // ConnectWSWithRoutePath is like ConnectWS but with a custom grid route path.
    func ConnectWSWithRoutePath(dial ContextDialer, auth AuthFn, tls *tls.Config, routePath string) func(ctx context.Context, remote string) (net.Conn, error) {
    	return func(ctx context.Context, remote string) (net.Conn, error) {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  3. cmd/metrics-v3-cache.go

    		nodesUpDown:         newNodesUpDownCache(),
    	}
    }
    
    type nodesOnline struct {
    	Online, Offline int
    }
    
    func newNodesUpDownCache() *cachevalue.Cache[nodesOnline] {
    	loadNodesUpDown := func(ctx context.Context) (v nodesOnline, err error) {
    		v.Online, v.Offline = globalNotificationSys.GetPeerOnlineCount()
    		return
    	}
    	return cachevalue.NewFromFunc(1*time.Minute,
    		cachevalue.Opts{ReturnLastGood: true},
    		loadNodesUpDown)
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu May 09 00:51:34 UTC 2024
    - 8.1K bytes
    - Viewed (0)
  4. cmd/healthcheck-handler.go

    				apiErr := toAPIError(r.Context(), err)
    				writeResponse(w, apiErr.HTTPStatusCode, nil, mimeNone)
    			case http.MethodGet:
    				writeErrorResponse(r.Context(), w, toAPIError(r.Context(), err), r.URL)
    			}
    			return
    		}
    	}
    
    	if globalEtcdClient != nil {
    		// Borrowed from
    		// https://github.com/etcd-io/etcd/blob/main/etcdctl/ctlv3/command/ep_command.go#L118
    		ctx, cancel := context.WithTimeout(r.Context(), defaultContextTimeout)
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Jun 26 07:44:34 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  5. 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 Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Sep 17 16:45:46 UTC 2024
    - 74.6K bytes
    - Viewed (0)
  6. internal/grid/muxserver.go

    	clientPingInterval time.Duration
    }
    
    func newMuxStateless(ctx context.Context, msg message, c *Connection, handler StatelessHandler) *muxServer {
    	var cancel context.CancelFunc
    	ctx = setCaller(ctx, c.remote)
    	if msg.DeadlineMS > 0 {
    		ctx, cancel = context.WithTimeout(ctx, time.Duration(msg.DeadlineMS)*time.Millisecond)
    	} else {
    		ctx, cancel = context.WithCancel(ctx)
    	}
    	m := muxServer{
    		ID:        msg.MuxID,
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 9.7K bytes
    - Viewed (0)
  7. callbacks/create.go

    						if _, isZero := pkField.ValueOf(db.Statement.Context, rv); isZero {
    							db.AddError(pkField.Set(db.Statement.Context, rv, insertID))
    							insertID += pkField.AutoIncrementIncrement
    						}
    					}
    				}
    			case reflect.Struct:
    				_, isZero := pkField.ValueOf(db.Statement.Context, db.Statement.ReflectValue)
    				if isZero {
    					db.AddError(pkField.Set(db.Statement.Context, db.Statement.ReflectValue, insertID))
    				}
    			}
    Registered: Sun Oct 27 09:35:08 UTC 2024
    - Last Modified: Mon Apr 08 03:29:55 UTC 2024
    - 12.5K bytes
    - Viewed (0)
  8. cmd/admin-handlers-users_test.go

    	}
    }
    
    func (c *check) mustGetIAMUserInfo(ctx context.Context, admClnt *madmin.AdminClient, accessKey string) madmin.UserInfo {
    	c.Helper()
    	ui, err := admClnt.GetUserInfo(ctx, accessKey)
    	if err != nil {
    		c.Fatalf("should be able to get user info: %v", err)
    	}
    	return ui
    }
    
    func (c *check) mustNotCreateIAMUser(ctx context.Context, admClnt *madmin.AdminClient) {
    	c.Helper()
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sun Sep 22 00:33:43 UTC 2024
    - 47.3K bytes
    - Viewed (0)
  9. cmd/bucket-metadata-sys.go

    	sys.Set(meta.Name, meta)
    	globalNotificationSys.LoadBucketMetadata(bgContext(ctx), meta.Name) // Do not use caller context here
    	return nil
    }
    
    // Delete delete the bucket metadata for the specified bucket.
    // must be used by all callers instead of using Update() with nil configData.
    func (sys *BucketMetadataSys) Delete(ctx context.Context, bucket string, configFile string) (updatedAt time.Time, err error) {
    	if configFile == bucketLifecycleConfig {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Aug 28 15:32:18 UTC 2024
    - 20.4K bytes
    - Viewed (0)
  10. gorm.go

    	}
    
    	if config.PropagateUnscoped {
    		txConfig.PropagateUnscoped = true
    	}
    
    	if config.Context != nil || config.PrepareStmt || config.SkipHooks {
    		tx.Statement = tx.Statement.clone()
    		tx.Statement.DB = tx
    	}
    
    	if config.Context != nil {
    		tx.Statement.Context = config.Context
    	}
    
    	if config.PrepareStmt {
    		var preparedStmt *PreparedStmtDB
    
    Registered: Sun Oct 27 09:35:08 UTC 2024
    - Last Modified: Wed Oct 09 11:29:48 UTC 2024
    - 12.1K bytes
    - Viewed (0)
Back to top