- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 249 for disovery (0.19 sec)
-
pilot/pkg/xds/discovery.go
// limitations under the License. package xds import ( "context" "fmt" "sort" "strconv" "sync" "time" discovery "github.com/envoyproxy/go-control-plane/envoy/service/discovery/v3" "github.com/google/uuid" "go.uber.org/atomic" "golang.org/x/time/rate" "google.golang.org/grpc" "istio.io/istio/pilot/pkg/autoregistration"
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 20:21:09 UTC 2024 - 19K bytes - Viewed (0) -
pilot/pkg/serviceregistry/memory/discovery.go
"istio.io/istio/pkg/log" "istio.io/istio/pkg/maps" "istio.io/istio/pkg/slices" "istio.io/istio/pkg/util/sets" "istio.io/istio/pkg/workloadapi" ) // ServiceDiscovery is a mock discovery interface type ServiceDiscovery struct { services map[host.Name]*model.Service handlers model.ControllerHandlers networkGateways []model.NetworkGateway model.NetworkGatewaysHandler
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 23:10:01 UTC 2024 - 12.4K bytes - Viewed (0) -
pilot/pkg/serviceregistry/aggregate/controller_test.go
ClusterID: "cluster-1", DiscoveryController: discovery1, } registry2 := serviceregistry.Simple{ ProviderID: provider.Kubernetes, ClusterID: "cluster-2", DiscoveryController: discovery2, } ctls := NewController(Options{}) ctls.AddRegistry(registry1) ctls.AddRegistry(registry2) return ctls, discovery1, discovery2 } func TestServicesForMultiCluster(t *testing.T) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 06:28:11 UTC 2024 - 14.5K 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) -
platforms/ide/tooling-api/src/testFixtures/groovy/org/gradle/integtests/tooling/fixture/CrossVersionTestEngine.java
import org.junit.platform.engine.TestDescriptor; import org.junit.platform.engine.TestEngine; import org.junit.platform.engine.UniqueId; import org.junit.platform.engine.discovery.ClassSelector; import org.junit.platform.engine.discovery.DiscoverySelectors; import org.junit.platform.engine.discovery.UniqueIdSelector; import org.junit.platform.engine.support.descriptor.EngineDescriptor; import org.junit.platform.engine.support.hierarchical.HierarchicalTestEngine;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Sep 26 14:49:20 UTC 2023 - 13.4K 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) -
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) -
pkg/registry/discovery/endpointslice/strategy_test.go
Hints: &discovery.EndpointHints{ ForZones: []discovery.ForZone{{Name: "zone-a-old"}}, }, }, { Hints: &discovery.EndpointHints{ ForZones: []discovery.ForZone{{Name: "zone-b-old"}}, }, }, }, }, newEPS: &discovery.EndpointSlice{ Endpoints: []discovery.Endpoint{ { Hints: &discovery.EndpointHints{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 27.3K bytes - Viewed (0) -
pkg/controlplane/instance_test.go
c := &restclient.Config{ Host: server.URL, APIPath: "/api", ContentConfig: restclient.ContentConfig{NegotiatedSerializer: legacyscheme.Codecs}, } discover := discovery.NewDiscoveryClientForConfigOrDie(c).WithLegacy() _, all, err := discover.ServerGroupsAndResources() if err != nil { t.Error(err) } var count int apiResources := sets.NewString() for _, g := range all {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 03 11:50:04 UTC 2024 - 21.5K bytes - Viewed (0) -
pkg/proxy/endpointslicecache_test.go
initialSlice: &discovery.EndpointSlice{ ObjectMeta: objMeta, Ports: []discovery.EndpointPort{port443}, Endpoints: []discovery.Endpoint{endpoint1, endpoint2}, }, updatedSlice: &discovery.EndpointSlice{ ObjectMeta: objMeta, Ports: []discovery.EndpointPort{port443}, Endpoints: []discovery.Endpoint{endpoint1, endpoint2}, }, expectChanged: false,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 21:07:21 UTC 2024 - 24.9K bytes - Viewed (0)