Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 44 for corev1informers (0.36 sec)

  1. pkg/controller/disruption/disruption.go

    func NewDisruptionController(
    	ctx context.Context,
    	podInformer coreinformers.PodInformer,
    	pdbInformer policyinformers.PodDisruptionBudgetInformer,
    	rcInformer coreinformers.ReplicationControllerInformer,
    	rsInformer appsv1informers.ReplicaSetInformer,
    	dInformer appsv1informers.DeploymentInformer,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 36.1K bytes
    - Viewed (0)
  2. pkg/scheduler/scheduler.go

    	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
    	"k8s.io/apimachinery/pkg/util/wait"
    	utilfeature "k8s.io/apiserver/pkg/util/feature"
    	"k8s.io/client-go/dynamic/dynamicinformer"
    	"k8s.io/client-go/informers"
    	coreinformers "k8s.io/client-go/informers/core/v1"
    	clientset "k8s.io/client-go/kubernetes"
    	restclient "k8s.io/client-go/rest"
    	"k8s.io/client-go/tools/cache"
    	"k8s.io/klog/v2"
    	configv1 "k8s.io/kube-scheduler/config/v1"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:20:55 UTC 2024
    - 20.8K bytes
    - Viewed (0)
  3. pkg/controller/volume/expand/expand_controller.go

    	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
    	"k8s.io/apimachinery/pkg/types"
    	"k8s.io/apimachinery/pkg/util/runtime"
    	"k8s.io/apimachinery/pkg/util/wait"
    	utilfeature "k8s.io/apiserver/pkg/util/feature"
    	coreinformers "k8s.io/client-go/informers/core/v1"
    	clientset "k8s.io/client-go/kubernetes"
    	"k8s.io/client-go/kubernetes/scheme"
    	v1core "k8s.io/client-go/kubernetes/typed/core/v1"
    	corelisters "k8s.io/client-go/listers/core/v1"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 16.2K bytes
    - Viewed (0)
  4. pkg/controller/podgc/gc_controller_test.go

    	"k8s.io/utils/pointer"
    )
    
    func alwaysReady() bool { return true }
    
    func NewFromClient(ctx context.Context, kubeClient clientset.Interface, terminatedPodThreshold int) (*PodGCController, coreinformers.PodInformer, coreinformers.NodeInformer) {
    	informerFactory := informers.NewSharedInformerFactory(kubeClient, controller.NoResyncPeriodFunc())
    	podInformer := informerFactory.Core().V1().Pods()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 08:16:48 UTC 2024
    - 29K bytes
    - Viewed (0)
  5. pkg/controller/resourcequota/resource_quota_controller.go

    	utilruntime "k8s.io/apimachinery/pkg/util/runtime"
    	"k8s.io/apimachinery/pkg/util/sets"
    	"k8s.io/apimachinery/pkg/util/wait"
    	quota "k8s.io/apiserver/pkg/quota/v1"
    	"k8s.io/client-go/discovery"
    	coreinformers "k8s.io/client-go/informers/core/v1"
    	corev1client "k8s.io/client-go/kubernetes/typed/core/v1"
    	corelisters "k8s.io/client-go/listers/core/v1"
    	"k8s.io/client-go/tools/cache"
    	"k8s.io/client-go/util/workqueue"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 21.3K bytes
    - Viewed (0)
  6. pkg/controller/deployment/deployment_controller.go

    	"k8s.io/apimachinery/pkg/labels"
    	"k8s.io/apimachinery/pkg/types"
    	utilruntime "k8s.io/apimachinery/pkg/util/runtime"
    	"k8s.io/apimachinery/pkg/util/wait"
    	appsinformers "k8s.io/client-go/informers/apps/v1"
    	coreinformers "k8s.io/client-go/informers/core/v1"
    	clientset "k8s.io/client-go/kubernetes"
    	"k8s.io/client-go/kubernetes/scheme"
    	v1core "k8s.io/client-go/kubernetes/typed/core/v1"
    	appslisters "k8s.io/client-go/listers/apps/v1"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 24.2K bytes
    - Viewed (0)
  7. pkg/controller/replicaset/replica_set.go

    	"k8s.io/apimachinery/pkg/runtime/schema"
    	"k8s.io/apimachinery/pkg/types"
    	utilruntime "k8s.io/apimachinery/pkg/util/runtime"
    	"k8s.io/apimachinery/pkg/util/wait"
    	appsinformers "k8s.io/client-go/informers/apps/v1"
    	coreinformers "k8s.io/client-go/informers/core/v1"
    	clientset "k8s.io/client-go/kubernetes"
    	"k8s.io/client-go/kubernetes/scheme"
    	v1core "k8s.io/client-go/kubernetes/typed/core/v1"
    	appslisters "k8s.io/client-go/listers/apps/v1"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 33.2K bytes
    - Viewed (0)
  8. pkg/registry/core/service/ipallocator/controller/repairip.go

    	apierrors "k8s.io/apimachinery/pkg/api/errors"
    	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
    	"k8s.io/apimachinery/pkg/labels"
    	"k8s.io/apimachinery/pkg/util/runtime"
    	"k8s.io/apimachinery/pkg/util/wait"
    	coreinformers "k8s.io/client-go/informers/core/v1"
    	networkinginformers "k8s.io/client-go/informers/networking/v1alpha1"
    	"k8s.io/client-go/kubernetes"
    	corelisters "k8s.io/client-go/listers/core/v1"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 24.7K bytes
    - Viewed (0)
  9. pkg/controller/daemon/daemon_controller.go

    func NewDaemonSetsController(
    	ctx context.Context,
    	daemonSetInformer appsinformers.DaemonSetInformer,
    	historyInformer appsinformers.ControllerRevisionInformer,
    	podInformer coreinformers.PodInformer,
    	nodeInformer coreinformers.NodeInformer,
    	kubeClient clientset.Interface,
    	failedPodsBackoff *flowcontrol.Backoff,
    ) (*DaemonSetsController, error) {
    	eventBroadcaster := record.NewBroadcaster(record.WithContext(ctx))
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 51.3K bytes
    - Viewed (0)
  10. pkg/controller/nodelifecycle/node_lifecycle_controller.go

    }
    
    // NewNodeLifecycleController returns a new taint controller.
    func NewNodeLifecycleController(
    	ctx context.Context,
    	leaseInformer coordinformers.LeaseInformer,
    	podInformer coreinformers.PodInformer,
    	nodeInformer coreinformers.NodeInformer,
    	daemonSetInformer appsv1informers.DaemonSetInformer,
    	kubeClient clientset.Interface,
    	nodeMonitorPeriod time.Duration,
    	nodeStartupGracePeriod time.Duration,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 51.6K bytes
    - Viewed (0)
Back to top