- Sort Score
- Result 10 results
- Languages All
Results 421 - 430 of 620 for uint24 (0.13 sec)
-
cmd/warm-backend-s3.go
destObj := object if s3.Prefix != "" { destObj = fmt.Sprintf("%s/%s", s3.Prefix, object) } return destObj } func (s3 *warmBackendS3) PutWithMeta(ctx context.Context, object string, r io.Reader, length int64, meta map[string]string) (remoteVersionID, error) { res, err := s3.client.PutObject(ctx, s3.Bucket, s3.getDest(object), r, length, minio.PutObjectOptions{ SendContentMd5: true, StorageClass: s3.StorageClass,
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Oct 31 22:10:24 UTC 2024 - 5.7K bytes - Viewed (0) -
internal/config/scanner/scanner.go
// Sleep always or based on incoming S3 requests. IdleMode int32 // 0 => on, 1 => off // Alert upon this many excess object versions ExcessVersions int64 // 100 // Alert upon this many excess sub-folders per folder in an erasure set. ExcessFolders int64 // 50000 // MaxWait is maximum wait time between operations MaxWait time.Duration // Cycle is the time.Duration between each scanner cycles Cycle time.Duration
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 5.5K bytes - Viewed (0) -
tensorflow/c/eager/c_api_test_util.cc
} TFE_Op* SendOp(TFE_Context* ctx, TFE_TensorHandle* in, const std::string& op_name, const std::string& send_device, const std::string& recv_device, tensorflow::uint64 send_device_incarnation) { TF_Status* status = TF_NewStatus(); TFE_Op* op = TFE_NewOp(ctx, op_name.c_str(), status); CHECK_EQ(TF_OK, TF_GetCode(status)) << TF_Message(status); TFE_OpAddInput(op, in, status);
Registered: Tue Nov 05 12:39:12 UTC 2024 - Last Modified: Wed Feb 21 22:37:46 UTC 2024 - 23.5K bytes - Viewed (0) -
cmd/benchmark-utils_test.go
b.ResetTimer() for i := 0; i < b.N; i++ { // insert the object. objInfo, err := obj.PutObject(context.Background(), bucket, "object"+strconv.Itoa(i), mustGetPutObjReader(b, bytes.NewReader(textData), int64(len(textData)), md5hex, sha256hex), ObjectOptions{}) if err != nil { b.Fatal(err) } if objInfo.ETag != md5hex {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Dec 23 15:46:00 UTC 2022 - 8.2K bytes - Viewed (0) -
migrator/migrator.go
DB *gorm.DB gorm.Dialector } type printSQLLogger struct { logger.Interface } func (l *printSQLLogger) Trace(ctx context.Context, begin time.Time, fc func() (sql string, rowsAffected int64), err error) { sql, _ := fc() fmt.Println(sql + ";") l.Interface.Trace(ctx, begin, fc, err) } // GormDataTypeInterface gorm data type interface type GormDataTypeInterface interface {
Registered: Sun Nov 03 09:35:10 UTC 2024 - Last Modified: Fri Apr 26 07:15:49 UTC 2024 - 29K bytes - Viewed (0) -
internal/event/target/nsq.go
Topic string `json:"topic"` TLS struct { Enable bool `json:"enable"` SkipVerify bool `json:"skipVerify"` } `json:"tls"` QueueDir string `json:"queueDir"` QueueLimit uint64 `json:"queueLimit"` } // Validate NSQArgs fields func (n NSQArgs) Validate() error { if !n.Enable { return nil } if n.NSQDAddress.IsEmpty() { return errors.New("empty nsqdAddress") }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 7.1K bytes - Viewed (0) -
cmd/metrics-v3-system-drive.go
) // label constants const ( driveL = "drive" poolIndexL = "pool_index" setIndexL = "set_index" driveIndexL = "drive_index" apiL = "api" sectorSize = uint64(512) kib = float64(1 << 10) driveHealthOffline = float64(0) driveHealthOnline = float64(1) driveHealthHealing = float64(2) ) var allDriveLabels = []string{driveL, poolIndexL, setIndexL, driveIndexL}
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun May 12 17:23:50 UTC 2024 - 7.9K bytes - Viewed (0) -
docs/debugging/inspect/decrypt-v1.go
id, err := hex.DecodeString(keyHex[:8]) if err != nil { return err } key, err := hex.DecodeString(keyHex[8:]) if err != nil { return err } // Verify that CRC is ok. want := binary.LittleEndian.Uint32(id) got := crc32.ChecksumIEEE(key) if want != got { return fmt.Errorf("Invalid key checksum, want %x, got %x", want, got) } stream, err := sio.AES_256_GCM.Stream(key) if err != nil { return err }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Apr 11 21:22:47 UTC 2024 - 1.6K bytes - Viewed (0) -
cmd/bucket-handlers_test.go
req, err = newTestSignedRequestV4(http.MethodPost, getDeleteMultipleObjectsURL("", testCase.bucket), int64(len(testCase.objects)), bytes.NewReader(testCase.objects), testCase.accessKey, testCase.secretKey, nil) } else { req, err = newTestRequest(http.MethodPost, getDeleteMultipleObjectsURL("", testCase.bucket), int64(len(testCase.objects)), bytes.NewReader(testCase.objects)) } if err != nil {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jun 10 15:50:49 UTC 2024 - 39.8K bytes - Viewed (0) -
internal/once/init.go
"sync" "sync/atomic" ) // Inspired from Golang sync.Once but it is only marked // initialized when the provided function returns nil. // Init represents the structure. type Init struct { done uint32 m sync.Mutex } // Do is similar to sync.Once.Do - makes one successful // call to the function. ie, it invokes the function // if it is not successful yet. func (l *Init) Do(f func() error) error {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue May 09 04:20:31 UTC 2023 - 2.1K bytes - Viewed (0)