- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 63 for sortBy (0.21 sec)
-
internal/dsync/drwmutex.go
// You should have received a copy of the GNU Affero General Public License // along with this program. If not, see <http://www.gnu.org/licenses/>. package dsync import ( "context" "errors" "math/rand" "sort" "strconv" "sync" "time" xioutil "github.com/minio/minio/internal/ioutil" "github.com/minio/minio/internal/mcontext" "github.com/minio/pkg/v2/console" "github.com/minio/pkg/v2/env" )
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 19.7K bytes - Viewed (0) -
cmd/data-usage-cache.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "context" "errors" "fmt" "io" "math/rand" "net/http" "path" "path/filepath" "sort" "strings" "time" "github.com/cespare/xxhash/v2" "github.com/dustin/go-humanize" "github.com/klauspost/compress/zstd" "github.com/minio/madmin-go/v3" "github.com/minio/minio/internal/bucket/lifecycle"
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 41.4K bytes - Viewed (1) -
cmd/admin-handlers.go
for _, v := range entryMap { if stale { lockEntries = append(lockEntries, *v) continue } if len(v.ServerList) >= v.Quorum { lockEntries = append(lockEntries, *v) } } sort.Sort(lockEntries) return lockEntries } // PeerLocks holds server information result of one node type PeerLocks struct { Addr string Locks map[string][]lockRequesterInfo }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 29 17:39:04 GMT 2024 - 97.8K bytes - Viewed (2) -
internal/logger/logger.go
} // uniq swaps away duplicate elements in data, returning the size of the // unique set. data is expected to be pre-sorted, and the resulting set in // the range [0:size] will remain in sorted order. Uniq, following a // sort.Sort call, can be used to prepare arbitrary inputs for use as sets. func uniq(data sort.Interface) (size int) { p, l := 0, data.Len() if l <= 1 { return l } for i := 1; i < l; i++ {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat May 04 00:17:57 GMT 2024 - 12.4K bytes - Viewed (0) -
internal/store/queuestore.go
for k := range store.entries { l = append(l, k) } // Sort entries... sort.Slice(l, func(i, j int) bool { return store.entries[l[i]] < store.entries[l[j]] }) store.RUnlock() return l, nil } // list will read all entries from disk. // Entries are returned sorted by modtime, oldest first. // Underlying entry list in store is *not* updated.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 25 16:44:20 GMT 2024 - 7.1K bytes - Viewed (0) -
cmd/warm-backend-gcs.go
err = BucketNotFound{Bucket: bucket} case "conflict": if message == "You already own this bucket. Please select another name." { err = BucketAlreadyOwnedByYou{Bucket: bucket} break } if message == "Sorry, that name is not available. Please try a different one." { err = BucketAlreadyExists{Bucket: bucket} break } err = BucketNotEmpty{Bucket: bucket} } return err
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 5.9K bytes - Viewed (0) -
cmd/net_test.go
sortedIPList: []string{"192.168.1.106", "127.0.0.1"}, }, // With a list of only one element nothing to sort. { ipList: []string{"hostname"}, sortedIPList: []string{"hostname"}, }, // With a list of only one element nothing to sort. { ipList: []string{"127.0.0.1"}, sortedIPList: []string{"127.0.0.1"}, },
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 08:43:09 GMT 2024 - 9.3K bytes - Viewed (0) -
cmd/background-newdisks-heal-ops.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "context" "encoding/json" "errors" "fmt" "io" "os" "sort" "strings" "sync" "time" "github.com/dustin/go-humanize" "github.com/minio/madmin-go/v3" "github.com/minio/minio-go/v7/pkg/set" "github.com/minio/minio/internal/config" "github.com/minio/pkg/v2/env"
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.7K bytes - Viewed (0) -
cmd/metrics-v3.go
collectorPaths := make([]collectorPath, 0, len(collectors)) for path, collector := range collectors { gatherers[path] = mustRegister(collector) collectorPaths = append(collectorPaths, path) } slices.Sort(collectorPaths) return &metricsV3Collection{ mgMap: mgMap, bucketMGMap: bucketMGMap, mgGatherers: gatherers, collectorPaths: collectorPaths, }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu May 02 17:37:57 GMT 2024 - 10.7K bytes - Viewed (0) -
cmd/metacache-stream.go
// 1. Bool. If false at end of stream. // 2. String. Name of object. Directories contains a trailing slash. // 3. Binary. Blob of metadata. Length 0 on directories. // ... Next element. // // Streams can be assumed to be sorted in ascending order. // If the stream ends before a false boolean it can be assumed it was truncated. const metacacheStreamVersion = 2 // metacacheWriter provides a serializer of metacache objects.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 19.5K bytes - Viewed (0)