- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 16 for PodController (0.23 sec)
-
pkg/test/framework/components/echo/kube/pod_controller.go
}) }, }) return &podController{ q: q, informer: informer, } } func (c *podController) Run(stop <-chan struct{}) { go c.informer.Run(stop) kube.WaitForCacheSync("pod controller", stop, c.informer.HasSynced) c.q.Run(stop) } func (c *podController) HasSynced() bool { return c.q.HasSynced() } func (c *podController) WaitForSync(stopCh <-chan struct{}) bool {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 09 02:22:47 UTC 2023 - 2.6K bytes - Viewed (0) -
pkg/test/framework/components/echo/kube/workload_manager.go
) type workloadHandler interface { WorkloadReady(w *workload) WorkloadNotReady(w *workload) } type workloadManager struct { workloads []*workload mutex sync.Mutex podController *podController cfg echo.Config ctx resource.Context grpcPort uint16 tls *echoCommon.TLSSettings closing bool stopCh chan struct{} handler workloadHandler }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Aug 14 02:12:37 UTC 2023 - 6.4K bytes - Viewed (0) -
pkg/apis/core/zz_generated.deepcopy.go
// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil. func (in *PodSignature) DeepCopyInto(out *PodSignature) { *out = *in if in.PodController != nil { in, out := &in.PodController, &out.PodController *out = new(v1.OwnerReference) (*in).DeepCopyInto(*out) } return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 22:40:29 UTC 2024 - 181.5K bytes - Viewed (0) -
staging/src/k8s.io/api/core/v1/zz_generated.deepcopy.go
// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil. func (in *PodSignature) DeepCopyInto(out *PodSignature) { *out = *in if in.PodController != nil { in, out := &in.PodController, &out.PodController *out = new(metav1.OwnerReference) (*in).DeepCopyInto(*out) } return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 22:40:29 UTC 2024 - 181.9K bytes - Viewed (0) -
pkg/apis/core/validation/validation.go
if avoidPodEntry.PodSignature.PodController == nil { allErrors = append(allErrors, field.Required(fldPath.Child("PodSignature"), "")) } else { if !*(avoidPodEntry.PodSignature.PodController.Controller) { allErrors = append(allErrors, field.Invalid(fldPath.Child("PodSignature").Child("PodController").Child("Controller"), *(avoidPodEntry.PodSignature.PodController.Controller), "must point to a controller")) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 22:40:29 UTC 2024 - 349.5K bytes - Viewed (0) -
pkg/controller/job/job_controller.go
// expects to observe the tracking finalizer removed. finalizerExpectations *uidTrackingExpectations // A store of jobs jobLister batchv1listers.JobLister // A store of pods, populated by the podController podStore corelisters.PodLister // Jobs that need to be updated queue workqueue.TypedRateLimitingInterface[string] // Orphan deleted pods that still have a Job tracking finalizer to be removed
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/apis/core/validation/validation_test.go
}, }, }, "invalid-podController": { ObjectMeta: metav1.ObjectMeta{ Name: "abc-123", Annotations: map[string]string{ core.PreferAvoidPodsAnnotationKey: ` { "preferAvoidPods": [ { "podSignature": { "podController": { "apiVersion": "v1",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 22:40:29 UTC 2024 - 857.7K bytes - Viewed (0) -
pkg/apis/core/v1/zz_generated.conversion.go
} func autoConvert_v1_PodSignature_To_core_PodSignature(in *v1.PodSignature, out *core.PodSignature, s conversion.Scope) error { out.PodController = (*metav1.OwnerReference)(unsafe.Pointer(in.PodController)) return nil } // Convert_v1_PodSignature_To_core_PodSignature is an autogenerated conversion function.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 22:40:29 UTC 2024 - 472.1K bytes - Viewed (0) -
staging/src/k8s.io/api/core/v1/types.go
// Exactly one field should be set. type PodSignature struct { // Reference to controller whose pods should avoid this node. // +optional PodController *metav1.OwnerReference `json:"podController,omitempty" protobuf:"bytes,1,opt,name=podController"` } // Describe a container image type ContainerImage struct { // Names by which this image is known.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 22:40:29 UTC 2024 - 390.8K bytes - Viewed (0) -
staging/src/k8s.io/api/core/v1/generated.pb.go
if postIndex < 0 { return ErrInvalidLengthGenerated } if postIndex > l { return io.ErrUnexpectedEOF } if m.PodController == nil { m.PodController = &v1.OwnerReference{} } if err := m.PodController.Unmarshal(dAtA[iNdEx:postIndex]); err != nil { return err } iNdEx = postIndex default: iNdEx = preIndex
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 22:40:29 UTC 2024 - 1.8M bytes - Viewed (0)