Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 548 for returns (0.15 sec)

  1. internal/grid/types.go

    	return &ArrayOf[T]{
    		ePool: sync.Pool{New: func() any {
    			return newFn()
    		}},
    	}
    }
    
    // New returns a new empty Array.
    func (p *ArrayOf[T]) New() *Array[T] {
    	return &Array[T]{
    		p: p,
    	}
    }
    
    // NewWith returns a new Array with the provided value (not copied).
    func (p *ArrayOf[T]) NewWith(val []T) *Array[T] {
    	return &Array[T]{
    		p:   p,
    		val: val,
    	}
    }
    
    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)
  2. internal/hash/checksum.go

    		return ChecksumSHA1
    	case "SHA256":
    		return ChecksumSHA256
    	case "":
    		return ChecksumNone
    	}
    	return ChecksumInvalid
    }
    
    // String returns the type as a string.
    func (c ChecksumType) String() string {
    	switch {
    	case c.Is(ChecksumCRC32):
    		return "CRC32"
    	case c.Is(ChecksumCRC32C):
    		return "CRC32C"
    	case c.Is(ChecksumSHA1):
    		return "SHA1"
    	case c.Is(ChecksumSHA256):
    		return "SHA256"
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 11.9K bytes
    - Viewed (0)
  3. internal/event/rules.go

    	return targetIDs
    }
    
    // Clone - returns copy of this rules.
    func (rules Rules) Clone() Rules {
    	rulesCopy := make(Rules)
    
    	for pattern, targetIDSet := range rules {
    		rulesCopy[pattern] = targetIDSet.Clone()
    	}
    
    	return rulesCopy
    }
    
    // Union - returns union with given rules as new rules.
    func (rules Rules) Union(rules2 Rules) Rules {
    	nrules := rules.Clone()
    
    	for pattern, targetIDSet := range rules2 {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 2.7K bytes
    - Viewed (0)
  4. internal/logger/target/kafka/kafka_scram_client_contrib.go

    // conversation forward.  It returns a string to be sent to the server or an
    // error if the server message is invalid.  Calling Step after a conversation
    // completes is also an error.
    func (x *XDGSCRAMClient) Step(challenge string) (response string, err error) {
    	response, err = x.ClientConversation.Step(challenge)
    	return
    }
    
    // Done returns true if the conversation is completed or has errored.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Nov 09 04:04:01 GMT 2023
    - 3.3K bytes
    - Viewed (1)
  5. cmd/xl-storage-meta-inline.go

    const xlMetaInlineDataVer = 1
    
    // versionOK returns whether the version is ok.
    func (x xlMetaInlineData) versionOK() bool {
    	if len(x) == 0 {
    		return true
    	}
    	return x[0] > 0 && x[0] <= xlMetaInlineDataVer
    }
    
    // afterVersion returns the payload after the version, if any.
    func (x xlMetaInlineData) afterVersion() []byte {
    	if len(x) == 0 {
    		return x
    	}
    	return x[1:]
    }
    
    // find the data with key s.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 9.5K bytes
    - Viewed (0)
  6. internal/config/identity/openid/openid.go

    	return provider.User{ID: userid, Enabled: true}, nil
    }
    
    // ProviderEnabled returns true if any vendor specific provider is enabled.
    func (r Config) ProviderEnabled() bool {
    	if !r.Enabled {
    		return false
    	}
    	for _, v := range r.arnProviderCfgsMap {
    		if v.provider != nil {
    			return true
    		}
    	}
    	return false
    }
    
    // GetRoleInfo - returns ARN to policies map if a role policy based openID
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Nov 16 04:42:31 GMT 2023
    - 16.5K bytes
    - Viewed (0)
  7. internal/bucket/replication/datatypes.go

    	Failed StatusType = "FAILED"
    
    	// Replica - this is a replica.
    	Replica StatusType = "REPLICA"
    )
    
    // String returns string representation of status
    func (s StatusType) String() string {
    	return string(s)
    }
    
    // Empty returns true if this status is not set
    func (s StatusType) Empty() bool {
    	return string(s) == ""
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Mar 08 19:08:18 GMT 2024
    - 1.5K bytes
    - Viewed (0)
  8. cmd/metrics-v2_gen.go

    				return
    			}
    		case "dependBucketTargetSys":
    			z.dependBucketTargetSys, bts, err = msgp.ReadBoolBytes(bts)
    			if err != nil {
    				err = msgp.WrapError(err, "dependBucketTargetSys")
    				return
    			}
    		default:
    			bts, err = msgp.Skip(bts)
    			if err != nil {
    				err = msgp.WrapError(err)
    				return
    			}
    		}
    	}
    	o = bts
    	return
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Mar 10 09:15:15 GMT 2024
    - 19.2K bytes
    - Viewed (0)
  9. internal/logger/targets.go

    	consoleTgt Target
    )
    
    // SystemTargets returns active targets.
    // Returned slice may not be modified in any way.
    func SystemTargets() []Target {
    	swapSystemMuRW.RLock()
    	defer swapSystemMuRW.RUnlock()
    
    	res := systemTargets
    	return res
    }
    
    // AuditTargets returns active audit targets.
    // Returned slice may not be modified in any way.
    func AuditTargets() []Target {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 02 22:56:14 GMT 2024
    - 6.1K bytes
    - Viewed (0)
  10. internal/disk/stat_netbsd.go

    	}
    	if info.Free > info.Total {
    		return info, fmt.Errorf("detected free space (%d) > total drive space (%d), fs corruption at (%s). please run 'fsck'", info.Free, info.Total, path)
    	}
    	info.Used = info.Total - info.Free
    	return info, nil
    }
    
    // GetDriveStats returns IO stats of the drive by its major:minor
    func GetDriveStats(major, minor uint32) (iostats IOStats, err error) {
    	return IOStats{}, errors.New("operation unsupported")
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Feb 26 19:34:50 GMT 2024
    - 1.8K bytes
    - Viewed (0)
Back to top