- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 29 for dela (0.16 sec)
-
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 != "" {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 12.2K bytes - Viewed (0) -
internal/event/target/postgresql.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 PostgreSQL database. func (target *PostgreSQLTarget) Close() error { close(target.quitCh) if target.updateStmt != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 17:51:07 GMT 2024 - 13.3K bytes - Viewed (0) -
cmd/admin-handlers-config-kv.go
"github.com/minio/minio/internal/config/subnet" "github.com/minio/minio/internal/logger" "github.com/minio/mux" "github.com/minio/pkg/v2/policy" ) // DelConfigKVHandler - DELETE /minio/admin/v3/del-config-kv func (a adminAPIHandlers) DelConfigKVHandler(w http.ResponseWriter, r *http.Request) { ctx := r.Context() objectAPI, cred := validateAdminReq(ctx, w, r, policy.ConfigUpdateAdminAction) if objectAPI == nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 15.7K bytes - Viewed (0) -
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) -
docs/batch-jobs/README.md
token: "Bearer xxxxx" # optional authentication token for the notification endpoint retry: attempts: 10 # number of retries for the job before giving up delay: "500ms" # least amount of delay between each retry ``` You can create and run multiple 'replication' jobs at a time there are no predefined limits set. ## Batch Jobs Terminology ### Job
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Oct 06 06:00:43 GMT 2022 - 4.8K bytes - Viewed (0) -
cmd/config-current.go
scannerCycle.Store(scannerCfg.Cycle) scannerExcessObjectVersions.Store(scannerCfg.ExcessVersions) scannerExcessFolders.Store(scannerCfg.ExcessFolders) configLogIf(ctx, scannerSleeper.Update(scannerCfg.Delay, scannerCfg.MaxWait)) } case config.LoggerWebhookSubSys: loggerCfg, err := logger.LookupConfigForSubSys(ctx, s, config.LoggerWebhookSubSys) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 30.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) -
internal/dsync/dsync_test.go
dm.refreshInterval = testDrwMutexUnlockCallTimeout if !dm.GetLock(context.Background(), nil, id, source, Options{Timeout: 5 * time.Minute}) { t.Fatal("GetLock() should be successful") } // Add delay to lock server responses to ensure that lock does not timeout for i := range lockServers { lockServers[i].setResponseDelay(5 * testDrwMutexUnlockCallTimeout) defer lockServers[i].setResponseDelay(0) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Dec 24 03:49:07 GMT 2022 - 11K bytes - Viewed (0) -
internal/config/scanner/scanner.go
delay := env.Get(EnvDelayLegacy, "") if delay == "" { delay = env.Get(EnvDelay, kvs.GetWithDefault(Delay, DefaultKVS)) } cfg.Delay, err = strconv.ParseFloat(delay, 64) if err != nil { return err } maxWait := env.Get(EnvMaxWaitLegacy, "") if maxWait == "" { maxWait = env.Get(EnvMaxWait, kvs.GetWithDefault(MaxWait, DefaultKVS)) } cfg.MaxWait, err = time.ParseDuration(maxWait) if err != nil { return err
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 11 01:10:30 GMT 2024 - 5.5K bytes - Viewed (0)