- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 173 for discoveryv1 (0.18 sec)
-
pkg/controller/endpointslicemirroring/endpointslicemirroring_controller.go
"golang.org/x/time/rate" v1 "k8s.io/api/core/v1" discovery "k8s.io/api/discovery/v1" apierrors "k8s.io/apimachinery/pkg/api/errors" "k8s.io/apimachinery/pkg/labels" utilruntime "k8s.io/apimachinery/pkg/util/runtime" "k8s.io/apimachinery/pkg/util/wait" coreinformers "k8s.io/client-go/informers/core/v1" discoveryinformers "k8s.io/client-go/informers/discovery/v1" clientset "k8s.io/client-go/kubernetes"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 06 23:18:31 UTC 2024 - 20.1K bytes - Viewed (0) -
pkg/xds/server.go
// stop can be used to end the connection manually via debug endpoints. Only to be used for testing. stop chan struct{} // reqChan is used to receive discovery requests for this connection. reqChan chan *discovery.DiscoveryRequest // errorChan is used to process error during discovery request processing. errorChan chan error } func NewConnection(peerAddr string, stream DiscoveryStream) Connection { return Connection{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 13 20:55:20 UTC 2024 - 16.3K bytes - Viewed (0) -
cmd/kubeadm/app/apis/kubeadm/v1beta3/zz_generated.conversion.go
return err } if err := s.AddGeneratedConversionFunc((*Discovery)(nil), (*kubeadm.Discovery)(nil), func(a, b interface{}, scope conversion.Scope) error { return Convert_v1beta3_Discovery_To_kubeadm_Discovery(a.(*Discovery), b.(*kubeadm.Discovery), scope) }); err != nil { return err } if err := s.AddGeneratedConversionFunc((*kubeadm.Discovery)(nil), (*Discovery)(nil), func(a, b interface{}, scope conversion.Scope) error {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 01 16:01:49 UTC 2024 - 36.4K bytes - Viewed (0) -
pkg/adsc/adsc.go
return string(out) } func ConfigInitialRequests() []*discovery.DiscoveryRequest { out := make([]*discovery.DiscoveryRequest, 0, len(collections.Pilot.All())+1) out = append(out, &discovery.DiscoveryRequest{ TypeUrl: gvk.MeshConfig.String(), }) for _, sch := range collections.Pilot.All() { out = append(out, &discovery.DiscoveryRequest{ TypeUrl: sch.GroupVersionKind().String(), }) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Feb 05 22:18:49 UTC 2024 - 35K bytes - Viewed (0) -
pkg/controller/garbagecollector/garbagecollector.go
metrics.GarbageCollectorResourcesSyncError.Inc() return } if groupLookupFailures, isLookupFailure := discovery.GroupDiscoveryFailedErrorGroups(err); isLookupFailure { // In partial discovery cases, preserve existing synced informers for resources in the failed groups, so resyncMonitors will only add informers for newly seen resources for k, v := range oldResources {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 32.9K bytes - Viewed (0) -
pkg/proxy/endpointslicecache.go
func endpointSliceCacheKeys(endpointSlice *discovery.EndpointSlice) (types.NamespacedName, string, error) { var err error serviceName, ok := endpointSlice.Labels[discovery.LabelServiceName] if !ok || serviceName == "" { err = fmt.Errorf("no %s label set on endpoint slice: %s", discovery.LabelServiceName, endpointSlice.Name) } else if endpointSlice.Namespace == "" || endpointSlice.Name == "" {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 21:07:21 UTC 2024 - 11.7K bytes - Viewed (1) -
pkg/adsc/delta.go
// lastReceived message, by type lastReceived map[string]*discovery.DeltaDiscoveryResponse deltaXDSUpdates chan *discovery.DeltaDiscoveryResponse // errChan is used to signal errors from the delta stream errChan chan error // closed is set to true when the client is closed closed bool } func (c *Client) trigger(ctx *handlerContext, typeURL string, r *discovery.Resource, event Event) error { var res *Resource
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 02 09:32:41 UTC 2024 - 20.4K bytes - Viewed (0) -
pkg/controller/resourcequota/resource_quota_controller.go
} } } else { // short circuit in non-discovery error cases or if discovery returned zero resources return } } logger := klog.FromContext(ctx) // Decide whether discovery has reported a change. if reflect.DeepEqual(oldResources, newResources) { logger.V(4).Info("no resource updates from discovery, skipping resource quota sync") return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 21.3K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/customresource_discovery_controller.go
utilruntime "k8s.io/apimachinery/pkg/util/runtime" "k8s.io/apimachinery/pkg/util/wait" "k8s.io/apimachinery/pkg/version" "k8s.io/apiserver/pkg/endpoints/discovery" discoveryendpoint "k8s.io/apiserver/pkg/endpoints/discovery/aggregated" "k8s.io/client-go/tools/cache" "k8s.io/client-go/util/workqueue" apiextensionshelpers "k8s.io/apiextensions-apiserver/pkg/apihelpers"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Apr 21 11:40:03 UTC 2024 - 12.8K bytes - Viewed (0) -
pilot/pkg/xds/ads.go
type DeltaDiscoveryStream = discovery.AggregatedDiscoveryService_DeltaAggregatedResourcesServer // DiscoveryClient is a client interface for XDS. type DiscoveryClient = discovery.AggregatedDiscoveryService_StreamAggregatedResourcesClient // DeltaDiscoveryClient is a client interface for Delta XDS. type DeltaDiscoveryClient = discovery.AggregatedDiscoveryService_DeltaAggregatedResourcesClient
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 03 08:29:05 UTC 2024 - 23.4K bytes - Viewed (0)