- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for syncAt (0.19 sec)
-
pkg/kubelet/kubelet.go
// - plegCh: update the runtime cache; sync pod // - syncCh: sync all pods waiting for sync // - housekeepingCh: trigger cleanup of pods // - health manager: sync pods that have failed or in which one or more // containers have failed health checks func (kl *Kubelet) syncLoopIteration(ctx context.Context, configCh <-chan kubetypes.PodUpdate, handler SyncHandler,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 126.1K bytes - Viewed (0) -
pilot/pkg/bootstrap/server.go
} func (s *Server) waitForCacheSync(stop <-chan struct{}) bool { start := time.Now() log.Info("Waiting for caches to be synced") if !kubelib.WaitForCacheSync("server", stop, s.cachesSynced) { log.Errorf("Failed waiting for cache sync") return false } log.Infof("All controller caches have been synced up in %v", time.Since(start)) // At this point, we know that all update events of the initial state-of-the-world have been
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 17:48:28 UTC 2024 - 46.3K bytes - Viewed (0) -
docs/metrics/prometheus/list.md
| `minio_node_iam_last_sync_duration_millis` | Last successful IAM data sync duration in milliseconds. | | `minio_node_iam_since_last_sync_millis` | Time (in milliseconds) since last successful IAM data sync. | | `minio_node_iam_sync_failures` | Number of failed IAM data syncs since server start. | | `minio_node_iam_sync_successes` | Number of successful IAM data syncs since server start. |
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 22:26:54 UTC 2024 - 43.3K bytes - Viewed (0) -
pilot/pkg/config/kube/crdclient/client.go
t0 := time.Now() cl.logger.Infof("Starting Pilot K8S CRD controller") if !kube.WaitForCacheSync("crdclient", stop, cl.informerSynced) { cl.logger.Errorf("Failed to sync Pilot K8S CRD controller cache") return } cl.logger.Infof("Pilot K8S CRD controller synced in %v", time.Since(t0)) cl.queue.Run(stop) cl.logger.Infof("controller terminated") } func (cl *Client) informerSynced() bool {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 00:12:28 UTC 2024 - 13.7K bytes - Viewed (0) -
pilot/pkg/model/endpointshards.go
} } return res } // EndpointIndex is a mutex protected index of endpoint shards type EndpointIndex struct { mu sync.RWMutex // keyed by svc then ns shardsBySvc map[string]map[string]*EndpointShards // We'll need to clear the cache in-sync with endpoint shards modifications. cache XdsCache } func NewEndpointIndex(cache XdsCache) *EndpointIndex { return &EndpointIndex{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 15.6K bytes - Viewed (0) -
cmd/bucket-replication.go
rinfos := replicatedInfos{Targets: make([]replicatedTargetInfo, 0, len(dsc.targetsMap))} var wg sync.WaitGroup var mu sync.Mutex for _, tgtEntry := range dsc.targetsMap { if !tgtEntry.Replicate { continue } // if dobj.TargetArn is not empty string, this is a case of specific target being re-synced. if dobj.TargetArn != "" && dobj.TargetArn != tgtEntry.Arn { continue }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 06:56:12 UTC 2024 - 114.4K bytes - Viewed (0) -
cmd/metrics-v2.go
Help: "Time (in milliseconds) since last successful IAM data sync", Type: gaugeMetric, }, Value: float64(sinceLastSyncMillis), }, { Description: MetricDescription{ Namespace: nodeMetricNamespace, Subsystem: iamSubsystem, Name: "sync_successes", Help: "Number of successful IAM data syncs since server uptime", Type: counterMetric, },
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 22:26:54 UTC 2024 - 131.9K bytes - Viewed (0) -
pilot/pkg/xds/delta.go
firstRequest.Store(false) return status.Error(codes.Unavailable, "server warmup not complete; try again") } // Check if server is ready to accept clients and process new requests. // Currently ready means caches have been synced and hence can build // clusters correctly. Without this check, InitContext() call below would // initialize with empty config, leading to reconnected Envoys loosing
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 25.6K bytes - Viewed (0) -
go.mod
go.uber.org/atomic v1.11.0 go.uber.org/zap v1.27.0 goftp.io/server/v2 v2.0.1 golang.org/x/crypto v0.24.0 golang.org/x/exp v0.0.0-20240604190554-fc45aab8b7f8 golang.org/x/oauth2 v0.21.0 golang.org/x/sync v0.7.0 golang.org/x/sys v0.21.0 golang.org/x/term v0.21.0 golang.org/x/time v0.5.0 google.golang.org/api v0.184.0 gopkg.in/yaml.v2 v2.4.0 gopkg.in/yaml.v3 v3.0.1 ) require (
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 22:53:53 UTC 2024 - 11.5K bytes - Viewed (0) -
pkg/kubelet/kubelet_test.go
} } // testPodSyncLoopHandler is a lifecycle.PodSyncLoopHandler that is used for testing. type testPodSyncLoopHandler struct { // list of pods to sync podsToSync []*v1.Pod } // ShouldSync evaluates if the pod should be synced from the kubelet. func (a *testPodSyncLoopHandler) ShouldSync(pod *v1.Pod) bool { for _, podToSync := range a.podsToSync { if podToSync.UID == pod.UID { return true
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 106.9K bytes - Viewed (0)