- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 124 for EndpointPort (0.19 sec)
-
staging/src/k8s.io/cli-runtime/pkg/printers/template_test.go
&v1.PodList{}, &v1.PodList{Items: []v1.Pod{{}}}, &v1.Endpoints{ Subsets: []v1.EndpointSubset{{ Addresses: []v1.EndpointAddress{{IP: "127.0.0.1"}, {IP: "localhost"}}, Ports: []v1.EndpointPort{{Port: 8080}}, }}}, } for _, obj := range objects { b := &bytes.Buffer{} if err := templatePrinter.PrintObj(obj, b); err != nil { t.Errorf("Unexpected template error: %v", err) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 22 23:10:00 UTC 2019 - 7.1K bytes - Viewed (0) -
pkg/controller/endpointslicemirroring/utils_test.go
protocol := v1.ProtocolTCP ports := []discovery.EndpointPort{{Name: &portName, Protocol: &protocol}} addrType := discovery.AddressTypeIPv4 gvk := schema.GroupVersionKind{Version: "v1", Kind: "Endpoints"} endpoints := v1.Endpoints{ ObjectMeta: metav1.ObjectMeta{ Name: "foo", Namespace: "test", }, Subsets: []v1.EndpointSubset{{ Ports: []v1.EndpointPort{{Port: 80}}, }}, }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 23 15:40:23 UTC 2022 - 7.5K bytes - Viewed (0) -
pilot/pkg/networking/apigen/apigen_test.go
sd := ds.MemRegistry sd.AddHTTPService("fortio1.fortio.svc.cluster.local", "10.10.10.1", 8081) sd.SetEndpoints("fortio1.fortio.svc.cluster.local", "", []*model.IstioEndpoint{ { Address: "127.0.0.1", EndpointPort: uint32(14056), ServicePortName: "http-main", }, }) return ds } // Test using resolving DNS over GRPC. This uses XDS protocol, and Listener resources
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jan 12 18:20:36 UTC 2024 - 2.3K bytes - Viewed (0) -
staging/src/k8s.io/api/discovery/v1/types.go
type ForZone struct { // name represents the name of the zone. Name string `json:"name" protobuf:"bytes,1,name=name"` } // EndpointPort represents a Port used by an EndpointSlice // +structType=atomic type EndpointPort struct { // name represents the name of this port. All ports in an EndpointSlice must have a unique name.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 23 17:42:49 UTC 2024 - 9.5K bytes - Viewed (0) -
pilot/pkg/xds/endpoints/mtls_checker.go
if ep.TLSMode != model.IstioMutualTLSModeLabel { return false } return authn. NewMtlsPolicy(c.push, ep.Namespace, ep.Labels, isWaypoint). GetMutualTLSModeForPort(ep.EndpointPort) != model.MTLSDisable } func tlsModeForDestinationRule(drc *config.Config, subset string, port int) *networkingapi.ClientTLSSettings_TLSmode { if drc == nil { return nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Dec 01 07:32:22 UTC 2023 - 3.3K bytes - Viewed (0) -
staging/src/k8s.io/api/discovery/v1beta1/types_swagger_doc_generated.go
} func (EndpointHints) SwaggerDoc() map[string]string { return map_EndpointHints } var map_EndpointPort = map[string]string{ "": "EndpointPort represents a Port used by an EndpointSlice",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Sep 17 09:26:19 UTC 2023 - 7.8K bytes - Viewed (0) -
pilot/pkg/networking/core/cluster_builder_test.go
{ Service: tt.service, ServicePort: tt.port, Endpoint: &model.IstioEndpoint{ ServicePortName: tt.port.Name, Address: "192.168.1.1", EndpointPort: 10001, Locality: model.Locality{ ClusterID: "", Label: "region1/zone1/subzone1", }, Labels: tt.service.Attributes.Labels, TLSMode: model.IstioMutualTLSModeLabel,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 110.4K bytes - Viewed (0) -
pilot/pkg/model/validation.go
} if instance.Endpoint != nil { if err := instance.Endpoint.Labels.Validate(); err != nil { errs = multierror.Append(errs, err) } if err := agent.ValidatePort(int(instance.Endpoint.EndpointPort)); err != nil { errs = multierror.Append(errs, err) } } port := instance.ServicePort if port == nil { errs = multierror.Append(errs, fmt.Errorf("missing service port"))
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/serviceregistry/mock/discovery.go
target := port.Port if target != 80 { target += 1000 } return &model.ServiceInstance{ Endpoint: &model.IstioEndpoint{ Address: MakeIP(service, version), EndpointPort: uint32(target), ServicePortName: port.Name, Labels: map[string]string{"version": fmt.Sprintf("v%d", version)}, Locality: locality, }, Service: service, ServicePort: port, }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Aug 07 18:40:05 UTC 2023 - 3.7K bytes - Viewed (0) -
pilot/pkg/networking/grpcgen/grpcgen_test.go
Protocol: protocol.GRPC, // SetEndpoints hardcodes this }, }, }) sd.SetEndpoints(testSvcHost, "istio-system", []*model.IstioEndpoint{ { Address: "127.0.0.1", EndpointPort: uint32(xdsPort), ServicePortName: "grpc-main", }, }) } // initPersistent creates echo-persistent.test:9999, type GRPC with one drained endpoint func initPersistent(sd *memory.ServiceDiscovery) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 09:04:02 UTC 2024 - 16.9K bytes - Viewed (0)