- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 124 for recordDef (0.14 sec)
-
pkg/controller/nodeipam/ipam/range_allocator.go
clusterCIDRs: allocatorParams.ClusterCIDRs, cidrSets: cidrSets, nodeLister: nodeInformer.Lister(), nodesSynced: nodeInformer.Informer().HasSynced, broadcaster: eventBroadcaster, recorder: recorder, queue: workqueue.NewNamedRateLimitingQueue(workqueue.DefaultControllerRateLimiter(), "cidrallocator_node"), } if allocatorParams.ServiceCIDR != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 10:06:15 UTC 2024 - 16.2K bytes - Viewed (0) -
pkg/kubelet/cm/container_manager_linux.go
// Absolute cgroupfs path to a cgroup that Kubelet needs to place all pods under. // This path include a top level container for enforcing Node Allocatable. cgroupRoot CgroupName // Event recorder interface. recorder record.EventRecorder // Interface for QoS cgroup management qosContainerManager QOSContainerManager // Interface for exporting and allocating devices reported by device plugins.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 10:18:16 UTC 2024 - 35.1K bytes - Viewed (0) -
pkg/controller/disruption/disruption.go
if err != nil { dc.recorder.Eventf(pdb, v1.EventTypeWarning, "NoPods", "Failed to get pods: %v", err) return err } if len(pods) == 0 { dc.recorder.Eventf(pdb, v1.EventTypeNormal, "NoPods", "No matching pods found") } expectedCount, desiredHealthy, unmanagedPods, err := dc.getExpectedPodCount(ctx, pdb, pods) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 36.1K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set.go
eventBroadcaster := record.NewBroadcaster(record.WithContext(ctx)) recorder := eventBroadcaster.NewRecorder(scheme.Scheme, v1.EventSource{Component: "statefulset-controller"}) ssc := &StatefulSetController{ kubeClient: kubeClient, control: NewDefaultStatefulSetControl( NewStatefulPodControl( kubeClient, podInformer.Lister(), pvcInformer.Lister(), recorder),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 18.5K bytes - Viewed (0) -
pkg/controller/nodeipam/ipam/range_allocator_test.go
if !ok { t.Logf("%v: found non-default implementation of CIDRAllocator, skipping white-box test...", tc.description) return } rangeAllocator.nodesSynced = test.AlwaysReady rangeAllocator.recorder = testutil.NewFakeRecorder() go allocator.Run(tCtx) // this is a bit of white box testing // pre allocate the cidrs as per the test for idx, allocatedList := range tc.allocatedCIDRs {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 10:06:15 UTC 2024 - 25.2K bytes - Viewed (0) -
cmd/kubemark/app/hollow_node.go
} eventBroadcaster := events.NewBroadcaster(&events.EventSinkImpl{Interface: client.EventsV1()}) recorder := eventBroadcaster.NewRecorder(legacyscheme.Scheme, "kube-proxy") hollowProxy := kubemarkproxy.NewHollowProxy( config.NodeName, client, client.CoreV1(), eventBroadcaster, recorder, ) return hollowProxy.Run() } return nil
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 08:58:18 UTC 2024 - 11K bytes - Viewed (0) -
src/cmd/compile/internal/types2/api.go
// omitted. // // For (possibly parenthesized) identifiers denoting built-in // functions, the recorded signatures are call-site specific: // if the call result is not a constant, the recorded type is // an argument-specific signature. Otherwise, the recorded type // is invalid. // // The Types map does not record the type of every identifier,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 10 13:48:53 UTC 2024 - 17.4K bytes - Viewed (0) -
src/go/types/unify.go
// // Unification typically requires multiple calls u.unify(x, y) to // a given unifier u, with various combinations of types x and y. // In each call, additional type parameter types may be determined // as a side effect and recorded in u. // If a call fails (returns false), unification fails. // // In the unification context, structural equivalence of two types // ignores the difference between a defined type and its underlying
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 11 16:24:39 UTC 2024 - 27.9K bytes - Viewed (0) -
pkg/controller/testutil/test_utils.go
Events []*v1.Event clock clock.Clock } // Event emits a fake event to the fake recorder func (f *FakeRecorder) Event(obj runtime.Object, eventtype, reason, message string) { f.generateEvent(obj, metav1.Now(), eventtype, reason, message) } // Eventf emits a fake formatted event to the fake recorder func (f *FakeRecorder) Eventf(obj runtime.Object, eventtype, reason, messageFmt string, args ...interface{}) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 28 08:48:22 UTC 2024 - 15.6K bytes - Viewed (0) -
pkg/kubelet/images/image_gc_manager_test.go
fakeRuntime := &containertest.FakeRuntime{} return &realImageGCManager{ runtime: fakeRuntime, policy: policy, imageRecords: make(map[string]*imageRecord), statsProvider: mockStatsProvider, recorder: &record.FakeRecorder{}, tracer: noopoteltrace.NewTracerProvider().Tracer(""), }, fakeRuntime } // Accessors used for thread-safe testing. func (im *realImageGCManager) imageRecordsLen() int {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 22 15:38:20 UTC 2024 - 29.2K bytes - Viewed (0)