Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for Informer (0.84 sec)

  1. pkg/kube/krt/informer.go

    	}
    	return a
    }
    
    var _ internalCollection[controllers.Object] = &informer[controllers.Object]{}
    
    func (i *informer[I]) _internalHandler() {}
    
    func (i *informer[I]) Synced() Syncer {
    	return channelSyncer{
    		name:   i.collectionName,
    		synced: i.synced,
    	}
    }
    
    // nolint: unused // (not true, its to implement an interface)
    func (i *informer[I]) dump() {
    	i.log.Errorf(">>> BEGIN DUMP")
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jun 10 11:01:46 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  2. pkg/controller/nodeipam/node_ipam_controller.go

    		if err != nil {
    			return nil, err
    		}
    	}
    
    	ic.nodeLister = nodeInformer.Lister()
    	ic.nodeInformerSynced = nodeInformer.Informer().HasSynced
    
    	return ic, nil
    }
    
    // Run starts an asynchronous loop that monitors the status of cluster nodes.
    func (nc *Controller) Run(ctx context.Context) {
    	defer utilruntime.HandleCrash()
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 06 16:18:38 UTC 2024
    - 5.4K bytes
    - Viewed (0)
  3. pkg/scheduler/framework/plugins/tainttoleration/taint_toleration.go

    	return clusterEventWithHint
    }
    
    // isSchedulableAfterNodeChange is invoked for all node events reported by
    // an informer. It checks whether that change made a previously unschedulable
    // pod schedulable.
    func (pl *TaintToleration) isSchedulableAfterNodeChange(logger klog.Logger, pod *v1.Pod, oldObj, newObj interface{}) (framework.QueueingHint, error) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  4. cni/pkg/nodeagent/cni-watcher.go

    	IPs          []IPConfig
    }
    
    // IPConfig contains an interface/gateway/address combo defined for a newly-started pod by CNI.
    // This is "from the horse's mouth" so to speak and will be populated before Kube is informed of the
    // pod IP.
    type IPConfig struct {
    	Interface *int
    	Address   net.IPNet
    	Gateway   net.IP
    }
    
    type CniPluginServer struct {
    	cniListenServer       *http.Server
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 21:31:35 UTC 2024
    - 6.7K bytes
    - Viewed (0)
Back to top