- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 54 for 5000 (0.13 sec)
-
cmd/metacache-manager.go
} type metacacheManager struct { mu sync.RWMutex init sync.Once buckets map[string]*bucketMetacache trash map[string]metacache // Recently deleted lists. } const metacacheMaxEntries = 5000 // initManager will start async saving the cache. func (m *metacacheManager) initManager() { // Add a transient bucket. // Start saver when object layer is ready. go func() { objAPI := newObjectLayerFn()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Oct 25 00:44:15 GMT 2022 - 5.2K bytes - Viewed (0) -
internal/grid/connection.go
Remote: o.remote, Local: o.local, id: o.id, ctx: o.ctx, outgoing: xsync.NewMapOfPresized[uint64, *muxClient](1000), inStream: xsync.NewMapOfPresized[uint64, *muxServer](1000), outQueue: make(chan []byte, defaultOutQueue), dialer: o.dial, side: ws.StateServerSide, connChange: &sync.Cond{L: &sync.Mutex{}},
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) -
cmd/data-usage_test.go
func TestDataUsageUpdate(t *testing.T) { base := t.TempDir() const bucket = "bucket" files := []usageTestFile{ {name: "rootfile", size: 10000}, {name: "rootfile2", size: 10000}, {name: "dir1/d1file", size: 2000}, {name: "dir2/d2file", size: 300}, {name: "dir1/dira/dafile", size: 100000}, {name: "dir1/dira/dbfile", size: 200000}, {name: "dir1/dira/dirasub/dcfile", size: 1000000},
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Mar 27 15:10:40 GMT 2024 - 14.1K bytes - Viewed (0) -
cmd/storage-datatypes_test.go
for i := 0; i < b.N; i++ { err := v.DecodeMsg(dc) if err != nil { b.Fatal(err) } } } func BenchmarkDecodeDiskInfoMsgp(b *testing.B) { v := DiskInfo{ Total: 1000, Free: 1000, Used: 1000, FSType: "xfs", RootDisk: true, Healing: true, Endpoint: "http://localhost:9001/tmp/drive1", MountPath: "/tmp/drive1", ID: "uuid", Error: "", }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 19 18:05:16 GMT 2022 - 9.4K bytes - Viewed (0) -
cmd/httprange_test.go
}{ {"bytes=0-", 0, 10}, {"bytes=1-", 1, 9}, {"bytes=0-9", 0, 10}, {"bytes=1-10", 1, 9}, {"bytes=1-1", 1, 1}, {"bytes=2-5", 2, 4}, {"bytes=-5", 5, 5}, {"bytes=-1", 9, 1}, {"bytes=-1000", 0, 10}, } for i, testCase := range validRangeSpecs { rs, err := parseRequestRangeSpec(testCase.spec) if err != nil { t.Errorf("unexpected err: %v", err) } o, l, err := rs.GetOffsetLength(resourceSize)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 3.7K bytes - Viewed (0) -
internal/event/rules_test.go
}{ {rulesCase1, "photos.jpg", NewTargetIDSet()}, {rulesCase2, "photos.jpg", NewTargetIDSet(TargetID{"1", "webhook"})}, {rulesCase3, "2010/photos.jpg", NewTargetIDSet(TargetID{"1", "webhook"})}, {rulesCase4, "2000/photos.jpg", NewTargetIDSet()}, } for i, testCase := range testCases { result := testCase.rules.Match(testCase.objectName) if !reflect.DeepEqual(testCase.expectedResult, result) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jun 01 21:59:40 GMT 2021 - 8.8K bytes - Viewed (0) -
cmd/object-api-deleteobject_test.go
oi, err := obj.DeleteObject(context.Background(), testCase.bucketName, testCase.pathToDelete, ObjectOptions{}) t.Log(oi, err) result, err := obj.ListObjects(context.Background(), testCase.bucketName, "", "", "", 1000) if err != nil { t.Errorf("Test %d: %s: Expected to pass, but failed with: <ERROR> %s", i+1, instanceType, err.Error()) continue } if len(result.Objects) != len(testCase.objectsAfterDelete) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Dec 23 15:46:00 GMT 2022 - 3.9K bytes - Viewed (0) -
cmd/kms-router.go
kmsAPI := kmsAPIHandlers{} kmsRouter := router.PathPrefix(kmsPathPrefix).Subrouter() KMSVersions := []string{ kmsAPIVersionPrefix, } gz, err := gzhttp.NewWrapper(gzhttp.MinSize(1000), gzhttp.CompressionLevel(gzip.BestSpeed)) if err != nil { // Static params, so this is very unlikely. logger.Fatal(err, "Unable to initialize server") } for _, version := range KMSVersions {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Aug 19 14:37:53 GMT 2023 - 4.5K bytes - Viewed (0) -
docs/debugging/xl-meta/main.go
} } var ei erasureInfo if err := json.Unmarshal(buf.Bytes(), &ei); err == nil && ei.V2Obj != nil { verID := uuid.UUID(header.VersionID).String() if verID == "00000000-0000-0000-0000-000000000000" { // If the version ID is all zeros, use the signature as version ID. verID = fmt.Sprintf("null/%08x", header.Signature) v0 = verID } idx := ei.V2Obj.EcIndex
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 17:56:22 GMT 2024 - 20.2K bytes - Viewed (1) -
cmd/server_test.go
expectedStrings []string }{ {getListObjectsV1URL(s.endPoint, bucketName, "", "1000", ""), []string{"<Key>foo bar 1</Key>", "<Key>foo bar 2</Key>"}}, {getListObjectsV1URL(s.endPoint, bucketName, "", "1000", "url"), []string{"<Key>foo+bar+1</Key>", "<Key>foo+bar+2</Key>"}}, { getListObjectsV2URL(s.endPoint, bucketName, "", "1000", "", ""), []string{ "<Key>foo bar 1</Key>", "<Key>foo bar 2</Key>", },
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 108K bytes - Viewed (0)