- Sort Score
- Result 10 results
- Languages All
Results 21 - 29 of 29 for discoveryclient (0.24 sec)
-
pkg/istio-agent/xds_proxy.go
) type ( DiscoveryStream = discovery.AggregatedDiscoveryService_StreamAggregatedResourcesServer DeltaDiscoveryStream = discovery.AggregatedDiscoveryService_DeltaAggregatedResourcesServer DiscoveryClient = discovery.AggregatedDiscoveryService_StreamAggregatedResourcesClient DeltaDiscoveryClient = discovery.AggregatedDiscoveryService_DeltaAggregatedResourcesClient ) var connectionNumber = atomic.NewUint32(0)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 16 22:12:28 UTC 2024 - 27.9K bytes - Viewed (0) -
pkg/controller/resourcequota/resource_quota_controller_test.go
} assertMonitors(t, qc, "pods", "deployments") // Simulate the discovery client returning an error fakeDiscoveryClient.setPreferredResources(nil, fmt.Errorf("error calling discoveryClient.ServerPreferredResources()")) // Wait until sync discovers the change time.Sleep(1 * time.Second) // No monitors removed assertMonitors(t, qc, "pods", "deployments")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 12 16:29:33 UTC 2023 - 42.6K bytes - Viewed (0) -
cmd/kube-controller-manager/app/core.go
if !controllerContext.ComponentConfig.GarbageCollectorController.EnableGarbageCollector { return nil, false, nil } gcClientset := controllerContext.ClientBuilder.ClientOrDie("generic-garbage-collector") discoveryClient := controllerContext.ClientBuilder.DiscoveryClientOrDie("generic-garbage-collector") config := controllerContext.ClientBuilder.ConfigOrDie("generic-garbage-collector")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 08:42:31 UTC 2024 - 39K bytes - Viewed (0) -
cmd/kube-controller-manager/app/controllermanager.go
} // Use a discovery client capable of being refreshed. discoveryClient := rootClientBuilder.DiscoveryClientOrDie("controller-discovery") cachedClient := cacheddiscovery.NewMemCacheClient(discoveryClient) restMapper := restmapper.NewDeferredDiscoveryRESTMapper(cachedClient) go wait.Until(func() { restMapper.Reset() }, 30*time.Second, ctx.Done())
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 01 13:03:53 UTC 2024 - 37.5K bytes - Viewed (0) -
staging/src/k8s.io/cli-runtime/pkg/resource/builder.go
} func NewBuilder(restClientGetter RESTClientGetter) *Builder { categoryExpanderFn := func() (restmapper.CategoryExpander, error) { discoveryClient, err := restClientGetter.ToDiscoveryClient() if err != nil { return nil, err } return restmapper.NewDiscoveryCategoryExpander(discoveryClient), err } return newBuilder( restClientGetter.ToRESTConfig, restClientGetter.ToRESTMapper,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jul 03 10:17:56 UTC 2023 - 37.2K bytes - Viewed (0) -
pkg/controller/disruption/disruption_test.go
pdbStore cache.Store rcStore cache.Store rsStore cache.Store dStore cache.Store ssStore cache.Store coreClient *fake.Clientset scaleClient *scalefake.FakeScaleClient discoveryClient *discoveryfake.FakeDiscovery informerFactory informers.SharedInformerFactory } var customGVK = schema.GroupVersionKind{ Group: "custom.k8s.io", Version: "v1", Kind: "customresource", }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 50K bytes - Viewed (0) -
pkg/controller/garbagecollector/garbagecollector_test.go
} assertMonitors(t, gc, "pods", "deployments") // Simulate the discovery client returning an error fakeDiscoveryClient.setPreferredResources(nil, fmt.Errorf("error calling discoveryClient.ServerPreferredResources()")) // Wait until sync discovers the change time.Sleep(1 * time.Second) // No monitor changes assertMonitors(t, gc, "pods", "deployments")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 111.6K bytes - Viewed (0) -
staging/src/k8s.io/cli-runtime/pkg/resource/interfaces.go
"k8s.io/apimachinery/pkg/types" "k8s.io/client-go/discovery" "k8s.io/client-go/rest" "k8s.io/client-go/restmapper" ) type RESTClientGetter interface { ToRESTConfig() (*rest.Config, error) ToDiscoveryClient() (discovery.CachedDiscoveryInterface, error) ToRESTMapper() (meta.RESTMapper, error) } type ClientConfigFunc func() (*rest.Config, error) type RESTMapperFunc func() (meta.RESTMapper, error)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 23:00:24 UTC 2019 - 3.1K bytes - Viewed (0) -
CHANGELOG/CHANGELOG-1.24.md
- Adds `OpenAPIV3SchemaInterface` to `DiscoveryClient` and its variants for fetching OpenAPI v3 schema documents. ([#108992](https://github.com/kubernetes/kubernetes/pull/108992), [@alexzielenski](https://github.com/alexzielenski))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 24 00:02:43 UTC 2023 - 473.4K bytes - Viewed (0)