- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for kubeinformers (0.28 sec)
-
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) -
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) -
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) -
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)