- Sort Score
- Num 10 results
- Language All
Results 331 - 340 of 696 for writer (0.05 seconds)
-
build-logic/documentation/src/test/resources/org/gradle/test/JavaClass.java
/** * Not a setter. */ public void setIgnoreMe1() { } /** * Not a setter. */ public void setIgnoreMe2(String a, int b) { } /** * A write-only property. */ public void setWriteOnly(JavaInterface value) { } /** * A property. */ public JavaInterface getSomeProp() { return this; } /**Created: Wed Dec 31 11:36:14 GMT 2025 - Last Modified: Wed Dec 09 08:14:05 GMT 2020 - 1.1K bytes - Click Count (0) -
cmd/api-headers.go
e.Encode(response) return bytesBuffer.Bytes() } // Write parts count func setPartsCountHeaders(w http.ResponseWriter, objInfo ObjectInfo) { if strings.Contains(objInfo.ETag, "-") && len(objInfo.Parts) > 0 { w.Header()[xhttp.AmzMpPartsCount] = []string{strconv.Itoa(len(objInfo.Parts))} } } // Write object header
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 8.6K bytes - Click Count (0) -
tests/scanner_valuer_test.go
package tests_test import ( "context" "database/sql" "database/sql/driver" "encoding/json" "errors" "fmt" "reflect" "regexp" "strconv" "testing" "time" "gorm.io/gorm" "gorm.io/gorm/clause" . "gorm.io/gorm/utils/tests" ) func TestScannerValuer(t *testing.T) { DB.Migrator().DropTable(&ScannerValuerStruct{}) if err := DB.Migrator().AutoMigrate(&ScannerValuerStruct{}); err != nil {
Created: Sun Dec 28 09:35:17 GMT 2025 - Last Modified: Wed Jun 07 07:02:07 GMT 2023 - 10.6K bytes - Click Count (0) -
.github/workflows/notify-translations.yml
Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Fri Nov 21 13:03:21 GMT 2025 - 1.7K bytes - Click Count (0) -
.github/workflows/publish.yml
Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Fri Nov 21 13:03:21 GMT 2025 - 1K bytes - Click Count (0) -
utils/utils_test.go
{"error not equal", errors.New("1"), errors.New("2"), false}, {"driver.Valuer equal", ModifyAt{Time: now, Valid: true}, ModifyAt{Time: now, Valid: true}, true}, {"driver.Valuer not equal", ModifyAt{Time: now, Valid: true}, ModifyAt{Time: now.Add(time.Second), Valid: true}, false}, {"driver.Valuer equal (ptr to nil ptr)", (*ModifyAt)(nil), &ModifyAt{}, false}, } for _, test := range assertEqualTests {Created: Sun Dec 28 09:35:17 GMT 2025 - Last Modified: Fri Sep 19 01:49:06 GMT 2025 - 4.9K bytes - Click Count (0) -
docs/distributed/DESIGN.md
sip := siphash.New(id[:]) sip.Write([]byte(key)) return int(sip.Sum64() % uint64(cardinality)) } ``` Input for the key is the object name specified in `PutObject()`, returns a unique index. This index is one of the erasure sets where the object will reside. This function is a consistent hash for a given object name i.e for a given object name the index returned is always the same.
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Wed Feb 26 09:25:50 GMT 2025 - 8K bytes - Click Count (2) -
internal/kms/secret-key.go
} const randSize = 28 random, err := sioutil.Random(randSize) if err != nil { return DEK{}, err } iv, nonce := random[:16], random[16:] prf := hmac.New(sha256.New, s.key) prf.Write(iv) key := prf.Sum(make([]byte, 0, prf.Size())) block, err := aes.NewCipher(key) if err != nil { return DEK{}, err } aead, err := cipher.NewGCM(block) if err != nil { return DEK{}, err
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Mon Apr 21 16:23:51 GMT 2025 - 8.4K bytes - Click Count (0) -
internal/config/crypto.go
if len(metadata) > MaxMetadataSize { return nil, errors.New("config: encryption metadata is too large") } header[0] = Version binary.LittleEndian.PutUint32(header[1:], uint32(len(metadata))) buffer.Write(header[:]) buffer.Write(metadata) return io.MultiReader( &buffer, stream.EncryptReader(plaintext, nonce, nil), ), nil } // Decrypt decrypts the ciphertext using a key managed by the KMS.
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri May 16 14:27:42 GMT 2025 - 4.7K bytes - Click Count (0) -
cmd/bucket-replication-handlers.go
return } if _, err = globalBucketMetadataSys.Update(ctx, bucket, bucketReplicationConfig, configData); err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } // Write success response. writeSuccessResponseHeadersOnly(w) } // GetBucketReplicationConfigHandler - GET Bucket replication configuration. // ---------- // Gets the replication configuration for a bucket.
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Thu Aug 15 12:04:40 GMT 2024 - 23.3K bytes - Click Count (0)