Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for kubeinformers (0.22 sec)

  1. staging/src/k8s.io/apiserver/pkg/util/peerproxy/peerproxy.go

    limitations under the License.
    */
    
    package peerproxy
    
    import (
    	"net/http"
    	"sync"
    
    	"k8s.io/apimachinery/pkg/runtime"
    	"k8s.io/apiserver/pkg/reconcilers"
    	"k8s.io/apiserver/pkg/storageversion"
    	kubeinformers "k8s.io/client-go/informers"
    	"k8s.io/client-go/tools/cache"
    )
    
    // Interface defines how the Unknown Version Proxy filter interacts with the underlying system.
    type Interface interface {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jul 19 00:36:22 UTC 2023
    - 2K bytes
    - Viewed (0)
  2. pkg/controlplane/apiserver/apiextensions.go

    	"k8s.io/apiserver/pkg/util/webhook"
    	"k8s.io/client-go/informers"
    
    	"k8s.io/kubernetes/pkg/controlplane/apiserver/options"
    )
    
    func CreateAPIExtensionsConfig(
    	kubeAPIServerConfig server.Config,
    	kubeInformers informers.SharedInformerFactory,
    	pluginInitializers []admission.PluginInitializer,
    	commandOptions options.CompletedOptions,
    	masterCount int,
    	serviceResolver webhook.ServiceResolver,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 01 18:08:20 UTC 2024
    - 3.8K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/util/flowcontrol/apf_filter.go

    	fqs "k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/queueset"
    	"k8s.io/apiserver/pkg/util/flowcontrol/metrics"
    	fcrequest "k8s.io/apiserver/pkg/util/flowcontrol/request"
    	kubeinformers "k8s.io/client-go/informers"
    	"k8s.io/klog/v2"
    	"k8s.io/utils/clock"
    
    	flowcontrol "k8s.io/api/flowcontrol/v1"
    	flowcontrolclient "k8s.io/client-go/kubernetes/typed/flowcontrol/v1"
    )
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 30 12:18:35 UTC 2023
    - 8K bytes
    - Viewed (0)
  4. pkg/kubelet/kubelet.go

    	if kubeDeps.KubeClient != nil {
    		kubeInformers := informers.NewSharedInformerFactoryWithOptions(kubeDeps.KubeClient, 0, informers.WithTweakListOptions(func(options *metav1.ListOptions) {
    			options.FieldSelector = fields.Set{metav1.ObjectNameField: string(nodeName)}.String()
    		}))
    		nodeLister = kubeInformers.Core().V1().Nodes().Lister()
    		nodeHasSynced = func() bool {
    			return kubeInformers.Core().V1().Nodes().Informer().HasSynced()
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 126.1K bytes
    - Viewed (0)
Back to top