- Sort Score
- Result 10 results
- Languages All
Results 541 - 550 of 620 for uint24 (0.05 sec)
-
internal/ioutil/ioutil_test.go
if string(b) != expected { t.Errorf("AppendFile() failed, expected: %s, got %s", expected, string(b)) } } func TestSkipReader(t *testing.T) { testCases := []struct { src io.Reader skipLen int64 expected string }{ {bytes.NewBuffer([]byte("")), 0, ""}, {bytes.NewBuffer([]byte("")), 1, ""}, {bytes.NewBuffer([]byte("abc")), 0, "abc"}, {bytes.NewBuffer([]byte("abc")), 1, "bc"},
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed May 22 23:07:14 UTC 2024 - 5.5K bytes - Viewed (0) -
internal/kms/kes.go
} } list := make([]madmin.KMSAPI, 0, len(APIs)) for _, api := range APIs { list = append(list, madmin.KMSAPI{ Method: api.Method, Path: api.Path, MaxBody: api.MaxBody, Timeout: int64(api.Timeout.Truncate(time.Second).Seconds()), }) } return list, nil } // Stat returns the current KES status containing a // list of KES endpoints and the default key ID.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Aug 18 06:43:03 UTC 2024 - 7.3K bytes - Viewed (0) -
internal/logger/logrotate.go
// If the directory does not exist, it will be created. Directory string // MaximumFileSize defines the maximum size of each log file in bytes. MaximumFileSize int64 // FileNameFunc specifies the name a new file will take. // FileNameFunc must ensure collisions in filenames do not occur. // Do not rely on timestamps to be unique, high throughput writes
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 5.8K bytes - Viewed (0) -
cmd/admin-handlers-site-replication.go
globalSiteNetPerfRX.Connect() defer globalSiteNetPerfRX.Disconnect() connectTime := time.Now() for { n, err := io.CopyN(xioutil.Discard, r.Body, 128*humanize.KiByte) atomic.AddUint64(&globalSiteNetPerfRX.RX, uint64(n)) if err != nil && err != io.EOF && err != io.ErrUnexpectedEOF { // If there is a disconnection before globalNetPerfMinDuration (we give a margin of error of 1 sec)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 19.4K bytes - Viewed (0) -
common-protos/k8s.io/api/core/v1/generated.proto
// +optional optional int64 tailLines = 7; // If set, the number of bytes to read from the server before terminating the // log output. This may not display a complete final line of logging, and may return // slightly more or slightly less than the specified limit. // +optional optional int64 limitBytes = 8;
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Mon Mar 11 18:43:24 UTC 2024 - 255.8K bytes - Viewed (0) -
cmd/site-replication-utils.go
ReplicatedCount: rs.ReplicatedCount, FailedSize: rs.FailedSize, FailedCount: rs.FailedCount, Bucket: rs.Bucket, Object: rs.Object, NumBuckets: int64(rs.TotBuckets), } for b, st := range rs.BucketStatuses { if st == ResyncFailed { m.FailedBuckets = append(m.FailedBuckets, b) } } return &m } // save in-memory stats to disk
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 8.9K bytes - Viewed (0) -
cmd/bucket-replication-utils_test.go
) var replicatedInfosTests = []struct { name string tgtInfos []replicatedTargetInfo expectedCompletedSize int64 expectedReplicationStatusInternal string expectedReplicationStatus replication.StatusType expectedOpType replication.Type expectedAction replicationAction }{
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Aug 08 20:27:40 UTC 2023 - 9.3K bytes - Viewed (0) -
cmd/metacache-entries.go
// If versioned the latest version will be returned. func (e *metaCacheEntry) fileInfo(bucket string) (FileInfo, error) { if e.isDir() { return FileInfo{ Volume: bucket, Name: e.name, Mode: uint32(os.ModeDir), }, nil } if e.cached != nil { if len(e.cached.versions) == 0 { // This special case is needed to handle xlMeta.versions == 0 return FileInfo{ Volume: bucket,
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 08 15:29:58 UTC 2024 - 24.1K bytes - Viewed (0) -
cmd/object-api-listobjects_test.go
for _, object := range testObjects { md5Bytes := md5.Sum([]byte(object.content)) _, err = obj.PutObject(context.Background(), object.parentBucket, object.name, mustGetPutObjReader(t, bytes.NewBufferString(object.content), int64(len(object.content)), hex.EncodeToString(md5Bytes[:]), ""), ObjectOptions{ Versioned: globalBucketVersioningSys.PrefixEnabled(object.parentBucket, object.name), UserDefined: object.meta, }) if err != nil {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed May 01 11:07:40 UTC 2024 - 73.1K bytes - Viewed (0) -
cmd/bucket-lifecycle-handlers_test.go
rec := httptest.NewRecorder() // construct HTTP request req, err := newTestSignedRequestV4(testCase.method, getBucketLifecycleURL("", testCase.bucketName), int64(len(testCase.body)), bytes.NewReader(testCase.body), testCase.accessKey, testCase.secretKey, nil) if err != nil {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jun 10 15:50:49 UTC 2024 - 11.3K bytes - Viewed (0)