- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 80 for syncFn (0.13 sec)
-
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/kubelet/pod_workers.go
// pod workers have synced (syncPod could be called). Once the pod workers // have synced it returns false if the pod has a sync status until // SyncTerminatedPod completes successfully. If the pod workers have synced, // but the pod does not have a status it returns true. // // Intended for use by subsystem sync loops to avoid performing background setup
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 02 13:22:37 UTC 2024 - 74.8K bytes - Viewed (0) -
pkg/proxy/nftables/proxier.go
defer proxier.mu.Unlock() // don't sync rules till we've received services and endpoints if !proxier.isInitialized() { proxier.logger.V(2).Info("Not syncing nftables until Services and Endpoints have been received from master") return } // // Below this point we will not return until we try to write the nftables rules. // // Keep track of how long syncs take. start := time.Now() defer func() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 08 13:48:54 UTC 2024 - 55.5K bytes - Viewed (0) -
pkg/proxy/winkernel/proxier.go
proxier.mu.Lock() defer proxier.mu.Unlock() // don't sync rules till we've received services and endpoints if !proxier.isInitialized() { klog.V(2).InfoS("Not syncing hns until Services and Endpoints have been received from master") return } // Keep track of how long syncs take. start := time.Now() defer func() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 13:25:06 UTC 2024 - 59K bytes - Viewed (0) -
pkg/controller/job/job_controller.go
syncHandler func(ctx context.Context, jobKey string) error // podStoreSynced returns true if the pod store has been synced at least once. // Added as a member to the struct to allow injection for testing. podStoreSynced cache.InformerSynced // jobStoreSynced returns true if the job store has been synced at least once. // Added as a member to the struct to allow injection for testing. jobStoreSynced cache.InformerSynced
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 10 23:56:37 UTC 2024 - 77.6K bytes - Viewed (0) -
pkg/kubelet/pod_workers_test.go
} if !podWorkers.CouldHaveRunningContainers(types.UID("abc")) { t.Errorf("Expected pod to potentially have running containers (does not exist but not yet synced)") } if podWorkers.ShouldPodContentBeRemoved(types.UID("abc")) { t.Errorf("Expected pod to not be suitable for removal (does not exist but not yet synced)") }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 75.6K bytes - Viewed (0) -
pkg/controller/daemon/daemon_controller.go
// dsStoreSynced returns true if the daemonset store has been synced at least once. // Added as a member to the struct to allow injection for testing. dsStoreSynced cache.InformerSynced // historyLister get list/get history from the shared informers's store historyLister appslisters.ControllerRevisionLister // historyStoreSynced returns true if the history store has been synced at least once.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 51.3K bytes - Viewed (0) -
cmd/kube-controller-manager/app/options/options_test.go
"--concurrent-deployment-syncs=10", "--concurrent-horizontal-pod-autoscaler-syncs=10", "--concurrent-statefulset-syncs=15", "--concurrent-endpoint-syncs=10", "--concurrent-ephemeralvolume-syncs=10", "--concurrent-service-endpoint-syncs=10", "--concurrent-gc-syncs=30", "--concurrent-namespace-syncs=20", "--concurrent-job-syncs=10", "--concurrent-cron-job-syncs=10", "--concurrent-replicaset-syncs=10",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 27 02:59:09 UTC 2024 - 55.1K bytes - Viewed (0) -
pkg/proxy/iptables/proxier.go
defer proxier.mu.Unlock() // don't sync rules till we've received services and endpoints if !proxier.isInitialized() { proxier.logger.V(2).Info("Not syncing iptables until Services and Endpoints have been received from master") return } // The value of proxier.needFullSync may change before the defer funcs run, so // we need to keep track of whether it was set at the *start* of the sync. tryPartialSync := !proxier.needFullSync
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 14:39:54 UTC 2024 - 65.1K bytes - Viewed (0) -
pkg/controller/endpoint/endpoints_controller_test.go
// TestMultipleServiceChanges tests that endpoints that are not created because of an out of sync endpoints cache are eventually recreated // A service will be created. After the endpoints exist, the service will be deleted and the endpoints will not be deleted from the cache immediately. // After the service is recreated, the endpoints will be deleted replicating an out of sync cache. Expect that eventually the endpoints will be recreated.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 06:51:56 UTC 2024 - 87.7K bytes - Viewed (0)