Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 90 for Caller (0.14 sec)

  1. internal/grid/handlers.go

    // Handlers can use this to create a reusable response.
    // The response may be reused, so caller should clear any fields.
    func (h *SingleHandler[Req, Resp]) NewResponse() Resp {
    	return h.newResp()
    }
    
    // NewRequest creates a new request.
    // Handlers can use this to create a reusable request.
    // The request may be reused, so caller should clear any fields.
    func (h *SingleHandler[Req, Resp]) NewRequest() Req {
    	return h.newReq()
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 27.1K bytes
    - Viewed (0)
  2. utils/utils.go

    	yval := reflect.ValueOf(y)
    	if xval.Kind() == reflect.Ptr && xval.IsNil() ||
    		yval.Kind() == reflect.Ptr && yval.IsNil() {
    		return false
    	}
    
    	if valuer, ok := x.(driver.Valuer); ok {
    		x, _ = valuer.Value()
    	}
    	if valuer, ok := y.(driver.Valuer); ok {
    		y, _ = valuer.Value()
    	}
    	return reflect.DeepEqual(x, y)
    }
    
    func ToString(value interface{}) string {
    	switch v := value.(type) {
    	case string:
    Go
    - Registered: Sun May 05 09:35:13 GMT 2024
    - Last Modified: Mon Apr 22 06:43:02 GMT 2024
    - 3.8K bytes
    - Viewed (0)
  3. internal/grid/connection.go

    	if err != nil {
    		return nil, err
    	}
    	cl.subroute = &c.subID
    	return cl, nil
    }
    
    // Request allows to do a single remote request.
    // 'req' will not be used after the call and caller can reuse.
    // If no deadline is set on ctx, a 1-minute deadline will be added.
    func (c *Connection) Request(ctx context.Context, h HandlerID, req []byte) ([]byte, error) {
    	if !h.valid() {
    		return nil, ErrUnknownHandler
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 42.6K bytes
    - Viewed (0)
  4. internal/cachevalue/cache.go

    // An Update function must be set to provide an updated value when needed.
    type Cache[T any] struct {
    	// updateFn must return an updated value.
    	// If an error is returned the cached value is not set.
    	// Only one caller will call this function at any time, others will be blocking.
    	// The returned value can no longer be modified once returned.
    	// Should be set before calling Get().
    	updateFn func() (T, error)
    
    	// ttl for a cached value.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Mar 01 16:00:42 GMT 2024
    - 4.2K bytes
    - Viewed (0)
  5. internal/config/storageclass/storage-class.go

    //
    // -- if input is RRS but RRS is not configured/initialized '-1' parity
    //
    //	for RRS is assumed, the caller is expected to choose the right parity
    //	at that point.
    //
    // -- if input is STANDARD but STANDARD is not configured/initialized '-1' parity
    //
    //	is returned, the caller is expected to choose the right parity
    //	at that point.
    func (sCfg *Config) GetParityForSC(sc string) (parity int) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 11.8K bytes
    - Viewed (0)
  6. src/builtin/builtin.go

    // the usual way, and then F returns to its caller. To the caller G, the
    // invocation of F then behaves like a call to panic, terminating G's
    // execution and running any deferred functions. This continues until all
    // functions in the executing goroutine have stopped, in reverse order. At
    // that point, the program is terminated with a non-zero exit code. This
    // termination sequence is called panicking and can be controlled by the
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Thu Apr 11 20:22:45 GMT 2024
    - 12.7K bytes
    - Viewed (0)
  7. cmd/iam-store.go

    // Assumes that c.Lock is held by caller.
    func (c *iamCache) buildUserGroupMemberships() {
    	for group, gi := range c.iamGroupsMap {
    		c.updateGroupMembershipsMap(group, &gi)
    	}
    }
    
    // updateGroupMembershipsMap - updates the memberships map for a
    // group. IMPORTANT: Assumes c.Lock() is held by caller.
    func (c *iamCache) updateGroupMembershipsMap(group string, gi *GroupInfo) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Apr 27 10:04:10 GMT 2024
    - 75.2K bytes
    - Viewed (2)
  8. cmd/storage-errors.go

    // errLessData - returned when less data available than what was requested.
    var errLessData = StorageErr("less data available than what was requested")
    
    // errMoreData = returned when more data was sent by the caller than what it was supposed to.
    var errMoreData = StorageErr("more data was sent than what was advertised")
    
    // indicates readDirFn to return without further applying the fn()
    var errDoneForNow = errors.New("done for now")
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 6.4K bytes
    - Viewed (0)
  9. cmd/storage-datatypes.go

    // Make sure to bump the internode version at storage-rest-common.go
    type RawFileInfo struct {
    	// Content of entire xl.meta (may contain data depending on what was requested by the caller.
    	Buf []byte `msg:"b,allownil"`
    }
    
    // FileInfo - represents file stat information.
    // The above means that any added/deleted fields are incompatible.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 15.3K bytes
    - Viewed (0)
  10. cmd/update.go

    		// CRI-O, Containerd etc..
    		// Fallback to our container specific ENVs if they are set.
    		return env.IsSet("MINIO_ACCESS_KEY_FILE")
    	}
    
    	// Log error, as we will not propagate it to caller
    	internalLogIf(GlobalContext, err)
    
    	return err == nil
    }
    
    // IsDCOS returns true if minio is running in DCOS.
    func IsDCOS() bool {
    	// http://mesos.apache.org/documentation/latest/docker-containerizer/
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 24 04:08:47 GMT 2024
    - 18.7K bytes
    - Viewed (0)
Back to top