- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 823 for syncAt (0.14 sec)
-
pkg/proxy/metrics/metrics.go
}, ) // SyncProxyRulesLastTimestamp is the timestamp proxy rules were last // successfully synced. SyncProxyRulesLastTimestamp = metrics.NewGauge( &metrics.GaugeOpts{ Subsystem: kubeProxySubsystem, Name: "sync_proxy_rules_last_timestamp_seconds", Help: "The last time proxy rules were successfully synced", StabilityLevel: metrics.ALPHA, }, )
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 14:39:54 UTC 2024 - 13.7K bytes - Viewed (0) -
pkg/kube/krt/singleton.go
v := d.val.Load() if v == nil { return nil } return []T{*v} } func (d *static[T]) Register(f func(o Event[T])) Syncer { return registerHandlerAsBatched[T](d, f) } func (d *static[T]) RegisterBatch(f func(o []Event[T], initialSync bool), runExistingState bool) Syncer { d.eventHandlers.Insert(f) if runExistingState { v := d.val.Load() if v != nil { f([]Event[T]{{ New: v,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 10 23:33:56 UTC 2024 - 4.2K bytes - Viewed (0) -
istioctl/pkg/writer/pilot/testdata/multiXdsStatusMultiPilot.txt
NAME CLUSTER CDS LDS EDS RDS ECDS ISTIOD VERSION proxy1 cluster1 STALE SYNCED SYNCED NOT SENT SYNCED istiod1 1.20 proxy2 cluster2 STALE SYNCED STALE SYNCED STALE istiod2 1.19 proxy3 cluster3 NOT SENT ERROR STALE NOT SENT NOT SENT istiod3 1.20
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 06 03:42:52 UTC 2024 - 522 bytes - Viewed (0) -
pkg/proxy/healthcheck/healthcheck_test.go
// Should return 200 "OK" irrespective of node syncs hs.SyncNode(makeNode(tweakTainted("other"))) testHTTPHandler(hsTest, http.StatusOK, t) // Should return 200 "OK" irrespective of node syncs hs.SyncNode(makeNode(tweakTainted(ToBeDeletedTaint))) testHTTPHandler(hsTest, http.StatusOK, t) // Should return 200 "OK" irrespective of node syncs hs.SyncNode(makeNode(tweakTainted("other")))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 26 13:27:41 UTC 2024 - 21.4K bytes - Viewed (0) -
istioctl/pkg/writer/pilot/testdata/multiXdsStatusSinglePilot.txt
NAME CLUSTER CDS LDS EDS RDS ECDS ISTIOD VERSION proxy1 cluster1 STALE SYNCED SYNCED NOT SENT NOT SENT istiod1 1.20
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 06 03:42:52 UTC 2024 - 300 bytes - Viewed (0) -
pkg/kubelet/status/status_manager_test.go
} } func TestChangedStatus(t *testing.T) { syncer := newTestManager(&fake.Clientset{}) testPod := getTestPod() syncer.SetPodStatus(testPod, getRandomPodStatus()) verifyUpdates(t, syncer, 1) syncer.SetPodStatus(testPod, getRandomPodStatus()) verifyUpdates(t, syncer, 1) } func TestChangedStatusKeepsStartTime(t *testing.T) { syncer := newTestManager(&fake.Clientset{}) testPod := getTestPod()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 02 16:27:19 UTC 2024 - 68.1K bytes - Viewed (0) -
pkg/kube/multicluster/secretcontroller_test.go
{ID: "config", SyncStatus: "synced"}, {ID: "c0", SecretName: "istio-system/s0", SyncStatus: "synced"}, {ID: "c1", SecretName: "istio-system/s1", SyncStatus: "synced"}, }) // Remove one c.DeleteSecret("s1") assert.EventuallyEqual(t, c.controller.ListRemoteClusters, []cluster.DebugInfo{ {ID: "config", SyncStatus: "synced"}, {ID: "c0", SecretName: "istio-system/s0", SyncStatus: "synced"}, }) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 15:07:03 UTC 2024 - 17.6K bytes - Viewed (0) -
pkg/controller/resourcequota/resource_quota_controller.go
if err := rq.resyncMonitors(ctx, newResources); err != nil { utilruntime.HandleError(fmt.Errorf("failed to sync resource monitors: %v", err)) return } // at this point, we've synced the new resources to our monitors, so record that fact. oldResources = newResources // wait for caches to fill for a while (our sync period).
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 21.3K bytes - Viewed (0) -
pilot/pkg/config/kube/ingress/status_test.go
func testRunningAddressesWithService(t *testing.T) { syncer := makeStatusSyncer(t, "istio-ingress") address := syncer.runningAddresses() if len(address) != 1 || address[0] != serviceIP { t.Errorf("Address is not correctly set to service ip") } } func testRunningAddressesWithHostname(t *testing.T) { syncer := makeStatusSyncer(t, "istio-ingress-hostname") address := syncer.runningAddresses()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 5.8K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/README.md
## Where does it come from? `apiextensions-apiserver` is synced from https://github.com/kubernetes/kubernetes/blob/master/staging/src/k8s.io/apiextensions-apiserver.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Sep 08 06:41:15 UTC 2023 - 742 bytes - Viewed (0)