- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 16 for apiservice (0.21 sec)
-
pkg/controlplane/apiserver/aggregator.go
apiServices := []*v1.APIService{} for _, curr := range delegateAPIServer.ListedPaths() { if curr == "/api/v1" { apiService := makeAPIService(schema.GroupVersion{Group: "", Version: "v1"}, apiVersionPriorities) registration.AddAPIServiceToSyncOnStart(apiService) apiServices = append(apiServices, apiService) continue }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 01 18:08:20 UTC 2024 - 15.3K bytes - Viewed (0) -
pkg/proxy/serviceport.go
} func newBaseServiceInfo(service *v1.Service, ipFamily v1.IPFamily, port *v1.ServicePort) *BaseServicePortInfo { externalPolicyLocal := apiservice.ExternalPolicyLocal(service) internalPolicyLocal := apiservice.InternalPolicyLocal(service) var stickyMaxAgeSeconds int if service.Spec.SessionAffinity == v1.ServiceAffinityClientIP {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jan 09 08:17:56 UTC 2024 - 10.7K bytes - Viewed (0) -
pkg/registry/core/service/storage/alloc.go
oldService, service := before.Service, after.Service neededHealthCheckNodePort := apiservice.NeedsHealthCheck(oldService) oldHealthCheckNodePort := oldService.Spec.HealthCheckNodePort needsHealthCheckNodePort := apiservice.NeedsHealthCheck(service) switch { // Case 1: Transition from don't need HealthCheckNodePort to needs HealthCheckNodePort.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 31 21:05:05 UTC 2023 - 37.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/discovery/aggregated/handler.go
iName := groups[i].Name jName := groups[j].Name // Default to 0 priority by default iPriority := priorities[iName] jPriority := priorities[jName] // Sort discovery based on apiservice priority. // Duplicated from staging/src/k8s.io/kube-aggregator/pkg/apis/apiregistration/v1/helpers.go if iPriority == jPriority { // Equal priority uses name to break ties return iName < jName }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 02 00:29:39 UTC 2024 - 16.1K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/ambientindex_workloadentry_test.go
s.assertEvent(t, s.wleXdsName("name3")) // Non-existent IP should have no response s.assertWorkloads(t, s.addrXdsName("10.0.0.1"), workloadapi.WorkloadStatus_HEALTHY) s.clearEvents() s.addService(t, "svc1", map[string]string{}, // labels map[string]string{}, // annotations []int32{80}, map[string]string{"app": "a"}, // selector "10.0.0.1", ) // Service shouldn't change workload list
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 08 01:04:50 UTC 2024 - 15.6K bytes - Viewed (0) -
pilot/pkg/serviceregistry/aggregate/controller_test.go
registries[0].DiscoveryController.(*memory.ServiceDiscovery).AddService(mock.HelloService) registries[1].DiscoveryController.(*memory.ServiceDiscovery).AddService(mock.HelloService) ctrl.DeleteRegistry(registries[1].Cluster(), registries[1].Provider()) ctrl.UnRegisterHandlersForCluster(registries[1].Cluster()) registries[0].DiscoveryController.(*memory.ServiceDiscovery).AddService(mock.HelloService) if registry1Counter.Load() != 3 {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 06:28:11 UTC 2024 - 14.5K bytes - Viewed (0) -
pilot/pkg/xds/eds_test.go
{ Name: "http", Port: 80, Protocol: protocol.HTTP, }, } svc := &model.Service{ Ports: ports, Hostname: host.Name("test1"), } s.MemRegistry.AddService(svc) if _, err := ads.Wait(time.Second*10, watchAll...); err != nil { t.Fatal(err) } i := &model.ServiceInstance{ Service: svc, ServicePort: svc.Ports[0], Endpoint: &model.IstioEndpoint{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 02 20:58:47 UTC 2024 - 39.6K bytes - Viewed (0) -
pilot/pkg/serviceregistry/memory/discovery.go
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/xds/ads_test.go
hostname := host.Name(name) configsUpdated.Insert(model.ConfigKey{ Kind: kind.ServiceEntry, Name: string(hostname), Namespace: ns, }) s.MemRegistry.AddService(&model.Service{ Hostname: hostname, DefaultAddress: "10.11.0.1", Ports: []*model.Port{ { Name: "http-main", Port: 2080, Protocol: protocol.HTTP, },
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jan 30 17:25:17 UTC 2024 - 30.3K bytes - Viewed (0) -
pilot/pkg/networking/grpcgen/grpcgen_test.go
if err != nil { t.Fatal(err) } _ = s.Send(&discovery.DiscoveryRequest{}) }) } }) } func addIstiod(sd *memory.ServiceDiscovery, xdsPort int) { sd.AddService(&model.Service{ Attributes: model.ServiceAttributes{ Name: "istiod", Namespace: "istio-system", }, Hostname: host.Name(testSvcHost), DefaultAddress: "127.0.1.12",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 09:04:02 UTC 2024 - 16.9K bytes - Viewed (0)