- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 17 for healthcheck (0.19 sec)
-
cmd/healthcheck-router.go
healthCheckPathPrefix = minioReservedBucketPath + healthCheckPath ) // registerHealthCheckRouter - add handler functions for liveness and readiness routes. func registerHealthCheckRouter(router *mux.Router) { // Healthcheck router healthRouter := router.PathPrefix(healthCheckPathPrefix).Subrouter() // Cluster check handler to verify cluster is active
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Jan 23 11:12:47 GMT 2023 - 2.3K bytes - Viewed (0) -
cmd/healthcheck-handler.go
// Verify if KMS is reachable if its configured if GlobalKMS != nil { ctx, cancel := context.WithTimeout(r.Context(), time.Minute) defer cancel() if _, err := GlobalKMS.GenerateKey(ctx, "", kms.Context{"healthcheck": ""}); err != nil { switch r.Method { case http.MethodHead: apiErr := toAPIError(r.Context(), err) writeResponse(w, apiErr.HTTPStatusCode, nil, mimeNone) case http.MethodGet:
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 03 21:13:20 GMT 2024 - 6.5K bytes - Viewed (0) -
cmd/object-api-common.go
type storageOpts struct { cleanUp bool healthCheck bool } // Depending on the disk type network or local, initialize storage API. func newStorageAPI(endpoint Endpoint, opts storageOpts) (storage StorageAPI, err error) { if endpoint.IsLocal { storage, err := newXLStorage(endpoint, opts.cleanUp) if err != nil { return nil, err } return newXLStorageDiskIDCheck(storage, opts.healthCheck), nil }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 2.1K bytes - Viewed (0) -
cni/pkg/iptables/iptables.go
) // TODO BML I don't think we need UDP? TCP healthcheck redir should catch everything. // This is effectively an analog for Istio's old-style podSpec-based health check rewrites. // Before Istio would update the pod manifest to rewrite healthchecks to go to sidecar Envoy port 15021, // so that it could distinguish things that can be unauthenticated (healthchecks) from other kinds of node traffic
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue May 07 19:54:50 GMT 2024 - 19.7K bytes - Viewed (0) -
cmd/xl-storage-disk-id-check.go
e.mu.Lock() defer e.mu.Unlock() return e.lastMinuteLatency.getTotal() } func newXLStorageDiskIDCheck(storage *xlStorage, healthCheck bool) *xlStorageDiskIDCheck { xl := xlStorageDiskIDCheck{ storage: storage, health: newDiskHealthTracker(), healthCheck: healthCheck && globalDriveMonitoring, metricsCache: cachevalue.New[DiskMetrics](), } xl.SetDiskID(emptyDiskID)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 33K bytes - Viewed (0) -
cmd/format-erasure_test.go
for _, erasureDir := range erasureDirs { defer os.RemoveAll(erasureDir) } endpoints := mustGetNewEndpoints(0, 8, erasureDirs...) storageDisks, errs := initStorageDisksWithErrors(endpoints, storageOpts{cleanUp: false, healthCheck: false}) for _, err := range errs { if err != nil && err != errDiskNotFound { t.Fatal(err) } } format := newFormatErasureV3(1, 8)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 15 08:25:46 GMT 2024 - 12.9K bytes - Viewed (0) -
cmd/storage-rest-client.go
func newStorageRESTClient(endpoint Endpoint, healthCheck bool, gm *grid.Manager) (*storageRESTClient, error) { serverURL := &url.URL{ Scheme: endpoint.Scheme, Host: endpoint.Host, Path: path.Join(storageRESTPrefix, endpoint.Path, storageRESTVersion), } restClient := rest.NewClient(serverURL, globalInternodeTransport, newCachedAuthToken()) if healthCheck { // Use a separate client to avoid recursive calls.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 26.1K bytes - Viewed (0) -
cmd/bucket-targets.go
lastOnline time.Time lastHCAt time.Time offlineDuration time.Duration latency latencyStat } // isOffline returns current liveness result of remote target. Add endpoint to // healthCheck map if missing and default to online status func (sys *BucketTargetSys) isOffline(ep *url.URL) bool { sys.hMutex.RLock() defer sys.hMutex.RUnlock() if h, ok := sys.hc[ep.Host]; ok { return !h.Online }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 20.9K bytes - Viewed (0) -
cni/pkg/nodeagent/net.go
s.currentPodSnapshot.Ensure(string(pod.UID)) openNetns, err := s.getOrOpenNetns(pod, netNs) if err != nil { return err } // Handle node healthcheck probe rewrites err = addPodToHostNSIpset(pod, podIPs, &s.hostsideProbeIPSet) if err != nil { log.Errorf("failed to add pod to ipset: %s/%s %v", pod.Namespace, pod.Name, err) return err }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 12.2K bytes - Viewed (1) -
internal/rest/client.go
attempt := uint(0) for { if atomic.LoadInt32(&c.connected) == closed { return } if c.HealthCheckFn() { if atomic.CompareAndSwapInt32(&c.connected, offline, online) { now := time.Now() disconnected := now.Sub(c.LastConn()) logger.Event(context.Background(), "healthcheck", "Client '%s' re-connected in %s", c.url.String(), disconnected) atomic.StoreInt64(&c.lastConn, now.UnixNano()) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 14.4K bytes - Viewed (0)