- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 25 for prestart (0.22 sec)
-
cmd/admin-handlers.go
// ---------- // Supports following actions: // - restart (restarts all the MinIO instances in a setup) // - stop (stops all the MinIO instances in a setup) // - freeze (freezes all incoming S3 API calls) // - unfreeze (unfreezes previously frozen S3 API calls) // // This newer API now returns back status per remote peer and local regarding // if a "restart/stop" was successful or not. Service signal now supports
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 97.3K bytes - Viewed (2) -
cmd/admin-handlers_test.go
globalObjLayerMutex.Lock() globalObjectAPI = objLayer globalObjLayerMutex.Unlock() return objLayer, erasureDirs, nil } // cmdType - Represents different service subcomands like status, stop // and restart. type cmdType int const ( restartCmd cmdType = iota stopCmd ) // toServiceSignal - Helper function that translates a given cmdType // value to its corresponding serviceSignal value.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 13.8K bytes - Viewed (0) -
cmd/notification.go
// 'freeze' is 'false' would resume all S3 API calls again. // NOTE: once a tenant is frozen either two things needs to // happen before resuming normal operations. // - Server needs to be restarted 'mc admin service restart' // - 'freeze' should be set to 'false' for this call // to resume normal operations. func (sys *NotificationSys) ServiceFreeze(ctx context.Context, freeze bool) []NotificationPeerErr {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 12 18:13:36 GMT 2024 - 44.5K bytes - Viewed (0) -
cmd/encryption-v1.go
// requested range starts, along with the DARE sequence number within // that part. For single part objects, the partStart will be 0. func (o *ObjectInfo) GetDecryptedRange(rs *HTTPRangeSpec) (encOff, encLength, skipLen int64, seqNumber uint32, partStart int, err error) { if _, ok := crypto.IsEncrypted(o.UserDefined); !ok { err = errors.New("Object is not encrypted") return }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 36.5K bytes - Viewed (0) -
cmd/service.go
"runtime" "syscall" xioutil "github.com/minio/minio/internal/ioutil" ) // Type of service signals currently supported. type serviceSignal int const ( serviceRestart serviceSignal = iota // Restarts the server. serviceStop // Stops the server. serviceReloadDynamic // Reload dynamic config values. serviceFreeze // Freeze all S3 API calls.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Wed Feb 28 07:02:14 GMT 2024 - 3.8K bytes - Viewed (0) -
cmd/healthcheck-handler.go
return } } writeResponse(w, http.StatusOK, nil, mimeNone) } // LivenessCheckHandler checks whether MinIO is up. It differs from the // readiness handler since a failing liveness check causes pod restarts // in K8S environments. Therefore, it does not contact external systems. func LivenessCheckHandler(w http.ResponseWriter, r *http.Request) { if objLayer := newObjectLayerFn(); objLayer == nil {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Wed Apr 03 21:13:20 GMT 2024 - 6.5K bytes - Viewed (0) -
cmd/erasure-server-pool-decom.go
Pools []PoolStatus `msg:"pls"` // Value should not be saved when we have not loaded anything yet. dontSave bool `msg:"-"` } // A decommission resumable tells us if decommission is worth // resuming upon restart of a cluster. func (p *poolMeta) returnResumablePools() []PoolStatus { var newPools []PoolStatus for _, pool := range p.Pools { if pool.Decommission == nil { continue }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 41.3K bytes - Viewed (1) -
cmd/prepare-storage.go
for _, file := range files { go removeAll(file) } // Remove the entire folder in case there are leftovers that didn't get cleaned up before restart. go removeAll(pathJoin(diskPath, minioMetaTmpBucket+"-old")) // Renames and schedules for purging all bucket metacache. go renameAllBucketMetacache(diskPath) }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 15 08:25:46 GMT 2024 - 11.1K bytes - Viewed (0) -
cni/pkg/nodeagent/ztunnelserver.go
if err != nil { return nil, fmt.Errorf("failed to resolve unix addr: %w", err) } // remove potentially existing address // Remove unix socket before use, if one is leftover from previous CNI restart if err := os.Remove(addr); err != nil && !os.IsNotExist(err) { // Anything other than "file not found" is an error. return nil, fmt.Errorf("failed to remove unix://%s: %w", addr, err) }
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 12.4K bytes - Viewed (0) -
cni/test/install_cni.go
return checkBinDir(t, tempCNIBinDir, "add", "istio-cni") }, retry.Delay(time.Millisecond*10), retry.Timeout(time.Second*5)) compareConfResult(resultFile, expectedOutputFile, t) // Test script restart by removing configuration if chainedCNIPlugin { rmCNIConfig(resultFile, t) } else if err := os.Remove(resultFile); err != nil { t.Fatalf("error removing CNI config file: %s", resultFile) }
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 12.5K bytes - Viewed (0)