- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 87 for Reconciled (0.3 sec)
-
pkg/webhooks/validation/controller/controller.go
return c } func (c *Controller) Reconcile(key types.NamespacedName) error { name := key.Name whc := c.webhooks.Get(name, "") scope := scope.WithLabels("webhook", name) // Stop early if webhook is not present, rather than attempting (and failing) to reconcile permanently // If the webhook is later added a new reconciliation request will trigger it to update
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 28 16:52:19 UTC 2024 - 11.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/peerproxy/peerproxy_handler.go
storageversionManager storageversion.Manager // proxy transport proxyTransport http.RoundTripper // identity for this server serverId string // reconciler that is used to fetch host port of peer apiserver when proxying request to a peer reconciler reconcilers.PeerEndpointLeaseReconciler serializer runtime.NegotiatedSerializer
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 19 00:36:22 UTC 2023 - 11.5K bytes - Viewed (0) -
pilot/pkg/config/kube/gateway/controller.go
}), ) } else { c.statusController.Store(nil) } } // Reconcile takes in a current snapshot of the gateway-api configs, and regenerates our internal state. // Any status updates required will be enqueued as well. func (c *Controller) Reconcile(ps *model.PushContext) error { t0 := time.Now() defer func() { log.Debugf("reconcile complete in %v", time.Since(t0)) }()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Mar 30 05:26:03 UTC 2024 - 13.5K bytes - Viewed (0) -
pkg/controlplane/reconcilers/lease.go
epAdapter EndpointsAdapter masterLeases Leases stopReconcilingCalled atomic.Bool reconcilingLock sync.Mutex } // NewLeaseEndpointReconciler creates a new LeaseEndpoint reconciler func NewLeaseEndpointReconciler(epAdapter EndpointsAdapter, masterLeases Leases) EndpointReconciler { return &leaseEndpointReconciler{ epAdapter: epAdapter, masterLeases: masterLeases, } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 24 09:23:05 UTC 2023 - 11.3K bytes - Viewed (0) -
pkg/controlplane/reconcilers/lease_test.go
t.Errorf("unexpected error remove endpoints: %v", err) } // reconcile endpoints in another goroutine err = r.ReconcileEndpoints(test.serviceName, netutils.ParseIPSloppy(test.ip), test.endpointPorts, false) if err != nil { t.Errorf("unexpected error reconciling: %v", err) } } else { // reconcile endpoints first
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 24 09:23:05 UTC 2023 - 28.7K bytes - Viewed (0) -
cni/pkg/nodeagent/informers.go
"istio.io/istio/pkg/monitoring" ) var ( eventTypeTag = monitoring.CreateLabel("type") EventTotals = monitoring.NewSum( "nodeagent_reconcile_events_total", "The total number of node agent reconcile events.", ) ) type K8sHandlers interface { GetPodIfAmbient(podName, podNamespace string) (*corev1.Pod, error) GetActiveAmbientPodSnapshot() []*corev1.Pod Start() } type InformerHandlers struct {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 21:31:35 UTC 2024 - 11.8K bytes - Viewed (0) -
cni/pkg/nodeagent/informers_test.go
types.MergePatchType, labelsPatch, metav1.PatchOptions{}) assert.NoError(t, err) // wait for another two update events // total 3 update at before unlabel point: 1. init ns reconcile 2. ns label reconcile 3. pod annotation update mt.Assert(EventTotals.Name(), map[string]string{"type": "update"}, monitortest.AtLeast(5)) waitForMockCalls() assertPodNotAnnotated(t, client, pod)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 05:10:23 UTC 2024 - 22.2K bytes - Viewed (0) -
pkg/kubelet/config/config_test.go
// If status is not changed, no reconcile should be triggered channel <- CreatePodUpdate(op, TestSource, pods...) expectNoPodUpdate(t, ch) // If the pod status is changed and not updated, a reconcile should be triggered pods, podWithStatusChange = newTestPods(true, false) channel <- CreatePodUpdate(op, TestSource, pods...) expectPodUpdate(t, ch, CreatePodUpdate(kubetypes.RECONCILE, TestSource, podWithStatusChange))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 17.1K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/attach_detach_controller_test.go
// Add a new pod between DSW ppoulator and reconciler run _, err = adc.kubeClient.CoreV1().Pods(newPod.ObjectMeta.Namespace).Create(tCtx, newPod, metav1.CreateOptions{}) if err != nil { t.Fatalf("Run failed with error. Failed to create a new pod: <%v>", err) } extraPodsNum++ podInformer.GetIndexer().Add(newPod) } go adc.reconciler.Run(tCtx) go adc.desiredStateOfWorldPopulator.Run(tCtx)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 11:00:37 UTC 2024 - 24.2K bytes - Viewed (0) -
pkg/kubelet/kubelet_node_status.go
} } // tryRegisterWithAPIServer makes an attempt to register the given node with // the API server, returning a boolean indicating whether the attempt was // successful. If a node with the same name already exists, it reconciles the // value of the annotation for controller-managed attach-detach of attachable // persistent volumes for the node. func (kl *Kubelet) tryRegisterWithAPIServer(node *v1.Node) bool {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 31.1K bytes - Viewed (0)