- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 27 for 1100 (0.23 sec)
-
cmd/object-api-datatypes.go
var ObjectsVersionCountIntervals = [dataUsageVersionLen]objectHistogramInterval{ {"UNVERSIONED", 0, 0}, {"SINGLE_VERSION", 1, 1}, {"BETWEEN_2_AND_10", 2, 9}, {"BETWEEN_10_AND_100", 10, 99}, {"BETWEEN_100_AND_1000", 100, 999}, {"BETWEEN_1000_AND_10000", 1000, 9999}, {"GREATER_THAN_10000", 10000, math.MaxInt64}, } // BucketInfo - represents bucket metadata. type BucketInfo struct { // Name of the bucket. Name string
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 20.8K bytes - Viewed (0) -
chainable_api.go
} // Scopes pass current database connection to arguments `func(DB) DB`, which could be used to add conditions dynamically // // func AmountGreaterThan1000(db *gorm.DB) *gorm.DB { // return db.Where("amount > ?", 1000) // } // // func OrderStatus(status []string) func (db *gorm.DB) *gorm.DB { // return func (db *gorm.DB) *gorm.DB { // return db.Scopes(AmountGreaterThan1000).Where("status in (?)", status) // }
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Wed Apr 17 03:38:55 GMT 2024 - 14.3K bytes - Viewed (1) -
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/admin-heal-ops.go
) const ( // a heal sequence with this many un-consumed heal result // items blocks until heal-status consumption resumes or is // aborted due to timeout. maxUnconsumedHealResultItems = 1000 // if no heal-results are consumed (via the heal-status API) // for this timeout duration, the heal sequence is aborted. healUnconsumedTimeout = 24 * time.Hour // time-duration to keep heal sequence state after it
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 25.1K bytes - Viewed (1) -
cmd/admin-router.go
adminAPIClientDevExtraTime = "/speedtest/client/devnull/extratime" ) var gzipHandler = func() func(http.Handler) http.HandlerFunc { 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") } return gz }() // Set of handler options as bit flags
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Mar 10 21:09:36 GMT 2024 - 25.5K bytes - Viewed (0) -
cmd/peer-rest-server.go
// STREAMS // Set an output capacity of 100 for consoleLog and listenRPC // There is another buffer that will buffer events. consoleLogRPC = grid.NewStream[*grid.MSS, grid.NoPayload, *grid.Bytes](grid.HandlerConsoleLog, grid.NewMSS, nil, grid.NewBytes).WithOutCapacity(100)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 51.8K bytes - Viewed (0) -
cmd/object-api-listobjects_test.go
shouldPass bool }{ {testBuckets[0], "unique/", "", "/", 1000, false, resultCases[0], ListObjectVersionsInfo{}, nil, true}, {testBuckets[0], "unique/folder", "", "/", 1000, false, resultCases[0], ListObjectVersionsInfo{}, nil, true}, {testBuckets[0], "unique/", "", "", 1000, false, resultCases[1], ListObjectVersionsInfo{}, nil, true}, {testBuckets[1], "unique/", "", "/", 1000, false, resultCases[0], ListObjectVersionsInfo{}, nil, true},
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 11:07:40 GMT 2024 - 73.1K bytes - Viewed (0) -
cmd/admin-bucket-handlers.go
tgt.HealthCheckDuration = target.HealthCheckDuration } } target = tgt } // enforce minimum bandwidth limit as 100MBps if target.BandwidthLimit > 0 && target.BandwidthLimit < 100*1000*1000 { writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErrWithErr(ErrReplicationBandwidthLimitError, err), r.URL) return } if err = globalBucketTargetSys.SetTarget(ctx, bucket, &target, update); err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 32.5K bytes - Viewed (0) -
cmd/api-response.go
"github.com/minio/minio/internal/logger" "github.com/minio/pkg/v2/policy" xxml "github.com/minio/xxml" ) const ( maxObjectList = 1000 // Limit number of objects in a listObjectsResponse/listObjectsVersionsResponse. maxDeleteList = 1000 // Limit number of objects deleted in a delete call. maxUploadsList = 10000 // Limit number of uploads in a listUploadsResponse.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 33.3K bytes - Viewed (2) -
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)