- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 25 for dele (0.01 seconds)
-
internal/store/queuestore_test.go
} } itemKeys := store.List() // Remove all the items. if len(itemKeys) == 20 { for _, key := range itemKeys { err := store.Del(key) if err != nil { t.Fatal("queue store Del failed with ", err) } } } else { t.Fatalf("List() Expected: 20, got %d", len(itemKeys)) } keys := store.List() if len(keys) != 0 {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 10.2K bytes - Click Count (0) -
cmd/object-handlers-common.go
func setPutObjHeaders(w http.ResponseWriter, objInfo ObjectInfo, del bool, h http.Header) { // We must not use the http.Header().Set method here because some (broken) // clients expect the ETag header key to be literally "ETag" - not "Etag" (case-sensitive). // Therefore, we have to set the ETag directly as map entry. if objInfo.ETag != "" && !del { w.Header()[xhttp.ETag] = []string{`"` + objInfo.ETag + `"`} }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Wed Jul 23 12:36:06 GMT 2025 - 15.2K bytes - Click Count (0) -
cmd/xl-storage-format-v2_test.go
}, { name: "del-on-one", input: [][]xlMetaV2ShallowVersion{ 0: {vDelMarker, vObj}, // disk 0 1: {vObj}, // disk 1 2: {vObj}, // disk 2 }, quorum: 2, reqVersions: 0, want: []xlMetaV2ShallowVersion{vObj}, }, { name: "del-on-two", input: [][]xlMetaV2ShallowVersion{Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 37.8K bytes - Click Count (0) -
cmd/generic-handlers.go
r.URL.Scheme = "https" } r.URL.Host = getHostFromSrv(sr) // Make sure we remove any existing headers before // proxying the request to another node. for k := range w.Header() { w.Header().Del(k) } globalForwarder.ServeHTTP(w, r) return } h.ServeHTTP(w, r) }) } // addCustomHeadersMiddleware adds various HTTP(S) response headers.
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 20.7K bytes - Click Count (1) -
cmd/data-scanner_test.go
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 12K bytes - Click Count (0) -
.teamcity/src/main/kotlin/model/PerformanceTestBucketProvider.kt
val windowsScript = """ mkdir $performanceTestSplitDirectoryName del /f /q $performanceTestSplitDirectoryName\include-$fileNamePostfix del /f /q $performanceTestSplitDirectoryName\exclude-$fileNamePostfix $linesWithEcho echo Performance tests to be ${action}d in this buildCreated: Wed Dec 31 11:36:14 GMT 2025 - Last Modified: Thu Jul 10 02:18:03 GMT 2025 - 16.6K bytes - Click Count (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) } // Close - closes underneath connections to MySQL database. func (target *MySQLTarget) Close() error { close(target.quitCh) if target.updateStmt != nil {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Mar 30 00:56:02 GMT 2025 - 11.6K bytes - Click Count (0) -
internal/event/target/nats.go
if os.IsNotExist(eErr) { return nil } return eErr } if err := target.send(eventData); err != nil { return err } return target.store.Del(key) } // Close - closes underneath connections to NATS server. func (target *NATSTarget) Close() (err error) { close(target.quitCh) if target.stanConn != nil {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Apr 27 04:30:57 GMT 2025 - 13.5K bytes - Click Count (0) -
internal/event/target/amqp.go
return nil } return eErr } if err := target.send(eventData, ch, confirms); err != nil { return err } // Delete the event from store. return target.store.Del(key) } // Close - does nothing and available for interface compatibility. func (target *AMQPTarget) Close() error { close(target.quitCh) if target.conn != nil { return target.conn.Close() }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Thu Aug 21 04:25:07 GMT 2025 - 10K bytes - Click Count (0) -
cmd/signature-v2.go
if !compareSignatureV2(gotSignature, expectedSignature) { return ErrSignatureDoesNotMatch } r.Form.Del(xhttp.Expires) return ErrNone } func getReqAccessKeyV2(r *http.Request) (auth.Credentials, bool, APIErrorCode) { if accessKey := r.Form.Get(xhttp.AmzAccessKeyID); accessKey != "" {Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 12.2K bytes - Click Count (0)