Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 80 for Heller (0.26 sec)

  1. cmd/iam.go

    		return nil, ctx.Err()
    	}
    }
    
    // PolicyDBSet - sets a policy for a user or group in the PolicyDB. This does
    // not validate if the user/group exists - that is the responsibility of the
    // caller.
    func (sys *IAMSys) PolicyDBSet(ctx context.Context, name, policy string, userType IAMUserType, isGroup bool) (updatedAt time.Time, err error) {
    	if !sys.Initialized() {
    		return updatedAt, errServerNotInitialized
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 21:28:16 GMT 2024
    - 71.1K bytes
    - Viewed (1)
  2. 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)
  3. internal/http/dial_dnscache.go

    	"time"
    )
    
    // LookupHost is a function to make custom lookupHost for optional cached DNS requests
    type LookupHost func(ctx context.Context, host string) (addrs []string, err error)
    
    // DialContextWithLookupHost is a helper function which returns `net.DialContext` function.
    // It randomly fetches an IP via custom LookupHost function and dials it by the given dial
    // function. LookupHost may implement an internal DNS caching implementation, lookupHost
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Jul 03 19:30:51 GMT 2023
    - 2.6K bytes
    - Viewed (0)
  4. internal/bucket/bandwidth/reader.go

    	if r.throttle == nil {
    		return r.r.Read(buf)
    	}
    	if r.lastErr != nil {
    		err = r.lastErr
    		return
    	}
    	b := r.throttle.Burst()  // maximum available tokens
    	need := len(buf)         // number of bytes requested by caller
    	hdr := r.opts.HeaderSize // remaining header bytes
    	var tokens int           // number of tokens to request
    
    	if hdr > 0 { // available tokens go towards header first
    		if hdr < b { // all of header can be accommodated
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Sep 06 03:21:59 GMT 2023
    - 3.1K bytes
    - Viewed (0)
  5. internal/config/help.go

    			Optional:    true,
    		},
    		HelpKV{
    			Key:         Comment,
    			Type:        "sentence",
    			Description: DefaultComment,
    			Optional:    true,
    		},
    	}
    )
    
    // DefaultHelpPostfix - Helper function to add (default: $value) messages in config help
    func DefaultHelpPostfix(subsystem KVS, key string) string {
    	val, found := subsystem.Lookup(key)
    	if !found || val == "" {
    		return ""
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Jun 23 14:45:27 GMT 2023
    - 2.8K bytes
    - Viewed (0)
  6. 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)
  7. 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)
  8. 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)
  9. cmd/namespace-lock.go

    	}
    	const readLock = true
    	for _, path := range li.paths {
    		li.ns.unlock(li.volume, path, readLock)
    	}
    }
    
    func getSource(n int) string {
    	var funcName string
    	pc, filename, lineNum, ok := runtime.Caller(n)
    	if ok {
    		filename = pathutil.Base(filename)
    		funcName = strings.TrimPrefix(runtime.FuncForPC(pc).Name(),
    			"github.com/minio/minio/cmd.")
    	} else {
    		filename = "<unknown>"
    		lineNum = 0
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Jun 05 23:56:35 GMT 2023
    - 9.2K bytes
    - Viewed (0)
  10. cmd/net.go

    		endpoint := fmt.Sprintf("%s://%s", getURLScheme(globalIsTLS), net.JoinHostPort(ip, globalMinioPort))
    		apiEndpoints = append(apiEndpoints, endpoint)
    	}
    
    	return apiEndpoints
    }
    
    // isHostIP - helper for validating if the provided arg is an ip address.
    func isHostIP(ipAddress string) bool {
    	host, _, err := net.SplitHostPort(ipAddress)
    	if err != nil {
    		host = ipAddress
    	}
    	// Strip off IPv6 zone information.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Mar 26 15:00:38 GMT 2024
    - 9.3K bytes
    - Viewed (0)
Back to top