- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 41 for del (0.13 sec)
-
cmd/handler-utils.go
success = true // Make sure we remove any existing headers before // proxying the request to another node. for k := range w.Header() { w.Header().Del(k) } f := handlers.NewForwarder(&handlers.Forwarder{ PassHost: true, RoundTripper: ep.Transport, ErrorHandler: func(w http.ResponseWriter, r *http.Request, err error) { success = false
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 15.5K bytes - Viewed (3) -
cmd/storage-datatypes.go
// Indicates if the version is the latest IsLatest bool `msg:"is"` // Deleted is set when this FileInfo represents // a deleted marker for a versioned bucket. Deleted bool `msg:"del"` // TransitionStatus is set to Pending/Complete for transitioned // entries based on state of transition TransitionStatus string `msg:"ts"` // TransitionedObjName is the object name on the remote tier corresponding
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 15.3K bytes - Viewed (0) -
cmd/test-utils_test.go
} // Anonymous request return early. if accessKey == "" || secretKey == "" { return req, nil } if signer == signerV2 { err = signRequestV2(req, accessKey, secretKey) req.Header.Del("x-amz-content-sha256") } else { req.Header.Set("x-amz-content-sha256", "92b165232fbd011da355eca0b033db22b934ba9af0145a437a832d27310b89f9") err = signRequestV4(req, accessKey, secretKey) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 17:26:51 GMT 2024 - 76.2K bytes - Viewed (0) -
cni/pkg/nodeagent/ztunnelserver_test.go
errChan <- ztunnelServer.PodDeleted(ctx, uid) }() // read the msg to delete from ztunnel m, fds = readRequest(t, ztunClient) assert.Equal(t, len(fds), 0) assert.Equal(t, m.Payload.(*zdsapi.WorkloadRequest_Del).Del.Uid, uid) sendAck(ztunClient) assert.NoError(t, <-errChan) ztunClient.Close() // this will retry for a bit, so shouldn't flake mt.Assert(ztunnelConnected.Name(), nil, monitortest.Exactly(0)) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 8.6K bytes - Viewed (0) -
cni/cmd/istio-cni/main.go
// to https://github.com/uber-go/zap/issues/328 _ = log.Sync() }() // TODO: implement plugin version funcs := skel.CNIFuncs{ Add: plugin.CmdAdd, Del: plugin.CmdDelete, Check: plugin.CmdCheck, } err := skel.PluginMainFuncsWithError(funcs, version.All, fmt.Sprintf("CNI plugin istio-cni %v", istioversion.Info.Version)) if err != nil {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 13:56:46 GMT 2024 - 1.9K bytes - Viewed (0) -
cmd/erasure-server-pool-rebalance.go
} // Apply lifecycle rules on the objects that are expired. if filterLifecycle(bucket, version.Name, version) { expired++ continue } // any object with only single DEL marker we don't need // to rebalance, just skip it, this also includes // any other versions that have already expired. remainingVersions := len(fivs.Versions) - expired
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 19:29:28 GMT 2024 - 27.2K 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) -
cmd/s3-zip-handlers.go
defer rc.Close() if err = setObjectHeaders(w, fileObjInfo, nil, opts); err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } // s3zip does not allow ranges w.Header().Del(xhttp.AcceptRanges) setHeadGetRespHeaders(w, r.Form) httpWriter := xioutil.WriteOnClose(w) // Write object content to response body if _, err = xioutil.Copy(httpWriter, rc); err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 09 10:41:25 GMT 2024 - 15.8K bytes - Viewed (0) -
cmd/erasure-server-pool-decom.go
expired++ decommissioned++ stopFn(errors.New("ILM expired object/version will be skipped")) continue } // any object with only single DEL marker we don't need // to decommission, just skip it, this also includes // any other versions that have already expired. remainingVersions := len(fivs.Versions) - expired
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 15:18:21 GMT 2024 - 41.5K bytes - Viewed (1) -
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.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 11 01:08:52 GMT 2024 - 20.7K bytes - Viewed (0)