- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 27 for serviceInstance (0.24 sec)
-
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/service/DefaultServiceRegistry.java
assertMutable(); ownServices.add(new FixedInstanceService(this, serviceType, serviceInstance)); return this; } /** * Adds a service instance to this registry. The given object is closed when this registry is closed. */ public DefaultServiceRegistry add(Object serviceInstance) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 29 06:47:40 UTC 2024 - 53.3K bytes - Viewed (0) -
pilot/pkg/xds/eds_test.go
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{ Address: "1.2.3.4", ServiceAccount: "spiffe://td1/ns/def/sa/def", HealthStatus: model.UnHealthy, },
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/networking/core/listener_builder_test.go
buildServiceWithPort("test2.com", 81, protocol.Unsupported, tnow), buildServiceWithPort("test3.com", 82, protocol.TCP, tnow), } instances := make([]*model.ServiceInstance, 0, len(services)) for _, s := range services { instances = append(instances, &model.ServiceInstance{ Service: s, Endpoint: &model.IstioEndpoint{ EndpointPort: uint32(s.Ports[0].Port), Address: "1.1.1.1", },
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 24.7K bytes - Viewed (0) -
pilot/pkg/networking/core/listener_test.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 93.6K bytes - Viewed (0) -
pilot/pkg/model/validation.go
fmt.Errorf("invalid service port value %d for %q: %v", port.Port, port.Name, err)) } } return errs } // Validate ensures that the service instance is well-defined func (instance *ServiceInstance) Validate() error { var errs error if instance.Service == nil { errs = multierror.Append(errs, fmt.Errorf("missing service in the instance")) } else if err := instance.Service.Validate(); err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 20:06:41 UTC 2024 - 3.5K bytes - Viewed (0) -
pilot/pkg/config/kube/gateway/conversion_test.go
// Setup a few preconfigured services instances := []*model.ServiceInstance{} for _, svc := range services { instances = append(instances, &model.ServiceInstance{ Service: svc, ServicePort: ports[0], Endpoint: &model.IstioEndpoint{EndpointPort: 8080}, }, &model.ServiceInstance{ Service: svc, ServicePort: ports[1], Endpoint: &model.IstioEndpoint{},
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 08 20:24:52 UTC 2024 - 34.9K bytes - Viewed (0) -
pilot/pkg/networking/core/sidecar_simulation_test.go
) func flattenInstances(il ...[]*model.ServiceInstance) []*model.ServiceInstance { ret := []*model.ServiceInstance{} for _, i := range il { ret = append(ret, i...) } return ret } func makeInstances(proxy *model.Proxy, svc *model.Service, servicePort int, targetPort int) []*model.ServiceInstance { ret := []*model.ServiceInstance{} for _, p := range svc.Ports { if p.Port != servicePort {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 84.7K bytes - Viewed (0) -
pilot/pkg/model/push_context_test.go
instancePlainText := &ServiceInstance{ Endpoint: &IstioEndpoint{ Address: "192.168.1.2", EndpointPort: 1000000, TLSMode: DisabledTLSModeLabel, }, } cases := []struct { name string serviceNamespace string servicePort int serviceResolution Resolution serviceInstances []*ServiceInstance wanted MutualTLSMode }{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Apr 21 17:42:54 UTC 2024 - 95.3K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/controller.go
return "" } return region + "/" + zone + "/" + subzone // Format: "%s/%s/%s" } func (c *Controller) serviceInstancesFromWorkloadInstances(svc *model.Service, reqSvcPort int) []*model.ServiceInstance { // Run through all the workload instances, select ones that match the service labels // only if this is a kubernetes internal service and of ClientSideLB (eds) type
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 41.2K bytes - Viewed (0) -
pilot/pkg/networking/core/cluster_builder_test.go
cases := []struct { name string mesh *meshconfig.MeshConfig labels labels.Instance instances []*model.ServiceInstance expected []*endpoint.LocalityLbEndpoints }{ { name: "basics", mesh: testMesh(), instances: []*model.ServiceInstance{ { Service: service, ServicePort: servicePort, Endpoint: &model.IstioEndpoint{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 110.4K bytes - Viewed (0)