- Sort Score
- Result 10 results
- Languages All
Results 21 - 24 of 24 for Reconciled (0.21 sec)
-
pkg/kubelet/cm/dra/types.go
"k8s.io/kubernetes/pkg/kubelet/config" kubecontainer "k8s.io/kubernetes/pkg/kubelet/container" ) // Manager manages all the DRA resource plugins running on a node. type Manager interface { // Start starts the reconcile loop of the manager. // This will ensure that all claims are unprepared even if pods get deleted unexpectedly. Start(activePods ActivePodsFunc, sourcesReady config.SourcesReady) error
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 03 13:23:29 UTC 2024 - 2.1K bytes - Viewed (0) -
pkg/kube/krt/bench_test.go
for _, service := range allServices { if labels.Instance(service.Spec.Selector).Match(pod.Labels) { services = append(services, service) } } return services } func (l *legacy) Reconcile(key types.NamespacedName) error { pod := l.pods.Get(key.Name, key.Namespace) if pod == nil || pod.Status.PodIP == "" { old := l.workloads[key] if old != nil { ev := krt.Event[Workload]{ Old: old,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 09 19:55:53 UTC 2024 - 7K bytes - Viewed (0) -
pkg/zdsapi/zds.proto
} // Delete a workload from the ztunnel. Ztunnel should shutdown the workload's proxy. message DelWorkload { string uid = 2; } // Let ztunnel know that a full snapshot was sent. Ztunnel should reconcile its internal state // and remove internal entries that were not sent. message SnapshotSent { } // Ztunnel ack message. If error is not empty, this is an error message. message Ack { string error = 1; }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 22:07:03 UTC 2024 - 2.7K bytes - Viewed (0) -
pkg/kubelet/types/types.go
limitations under the License. */ package types import ( "net/http" "time" v1 "k8s.io/api/core/v1" "k8s.io/apimachinery/pkg/types" "k8s.io/cri-client/pkg/logs" ) // TODO: Reconcile custom types in kubelet/types and this subpackage // HTTPDoer encapsulates http.Do functionality type HTTPDoer interface { Do(req *http.Request) (*http.Response, error) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 30 13:13:22 UTC 2024 - 3.5K bytes - Viewed (0)