Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 25 for dele (0.01 seconds)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. cmd/data-scanner_test.go

           </Rule>
           <Rule>
                   <ID>delete-all-versions</ID>
                   <Status>Enabled</Status>
                   <Filter>
                           <Tag>
                           <Key>del-all</Key>
                           <Value>true</Value>
                           </Tag>
                   </Filter>
                   <Expiration>
                           <Days>1</Days>
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 12K bytes
    - Click Count (0)
  6. .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 build
    Created: Wed Dec 31 11:36:14 GMT 2025
    - Last Modified: Thu Jul 10 02:18:03 GMT 2025
    - 16.6K bytes
    - Click Count (0)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to Top