- Sort Score
- Result 10 results
- Languages All
Results 31 - 36 of 36 for Adel (0.15 sec)
-
internal/store/queuestore.go
} if err = json.Unmarshal(eventData, &item); err != nil { return item, err } return item, nil } // Del - Deletes an entry from the store. func (store *QueueStore[_]) Del(key string) error { store.Lock() defer store.Unlock() return store.del(key) } // DelList - Deletes a list of entries from the store. // Returns an error even if one key fails to be deleted.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 25 16:44:20 GMT 2024 - 7.1K bytes - Viewed (0) -
internal/crypto/header.go
// It has the same semantics as RemoveSensitiveEntries. func RemoveSensitiveHeaders(h http.Header) { h.Del(xhttp.AmzServerSideEncryptionCustomerKey) h.Del(xhttp.AmzServerSideEncryptionCopyCustomerKey) h.Del(xhttp.AmzMetaUnencryptedContentLength) h.Del(xhttp.AmzMetaUnencryptedContentMD5) } // SSECopy represents AWS SSE-C for copy requests. It provides // functionality to handle SSE-C copy requests.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 2.9K bytes - Viewed (0) -
internal/store/store.go
// Store - Used to persist items. type Store[I any] interface { Put(item I) error PutMultiple(item []I) error Get(key string) (I, error) GetRaw(key string) ([]byte, error) Len() int List() ([]string, error) Del(key string) error DelList(key []string) error Open() error Delete() error Extension() string } // Key denotes the key present in the store. type Key struct { Name string IsLast bool }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 25 16:44:20 GMT 2024 - 3.5K bytes - Viewed (0) -
internal/bucket/lifecycle/lifecycle_test.go
isDelMarker: true, expectedAction: DeleteVersionAction, }, // Should not expire a delete marker; ExpiredObjectDeleteAllVersions applies only when current version is not a DEL marker. {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:11:10 GMT 2024 - 53.2K bytes - Viewed (0) -
internal/event/target/mysql.go
} if err := target.send(eventData); err != nil { if IsConnErr(err) { return store.ErrNotConnected } return err } // Delete the event from store. return target.store.Del(key.Name) } // Close - closes underneath connections to MySQL database. func (target *MySQLTarget) Close() error { close(target.quitCh) if target.updateStmt != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Oct 07 15:07:38 GMT 2023 - 11.5K bytes - Viewed (0) -
cmd/object-handlers_test.go
if err != nil { t.Fatalf("Test %d: Failed to create HTTP request for Put Object: <ERROR> %v", i+1, err) } // Removes auth header if test case requires it. if testCase.removeAuthHeader { req.Header.Del("Authorization") } switch testCase.fault { case malformedEncoding: req, err = malformChunkSizeSigV4(req, testCase.chunkSize-1) case signatureMismatch: req, err = malformDataSigV4(req, 'z')
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 160K bytes - Viewed (0)