- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 23 for Sort (0.06 sec)
-
pilot/pkg/networking/core/listener_inbound.go
} for _, i := range lb.node.SidecarScope.Sidecar.Ingress { port := model.ServiceInstancePort{ ServicePort: &model.Port{ Name: i.Port.Name, Port: int(i.Port.Number), Protocol: protocol.Parse(i.Port.Protocol), }, TargetPort: i.Port.Number, // No targetPort support in the API } bindtoPort := getBindToPort(i.CaptureMode, lb.node)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 35.1K bytes - Viewed (0) -
pilot/pkg/model/endpointshards.go
defer es.RUnlock() res := map[int][]*IstioEndpoint{} for _, v := range es.Shards { for _, ep := range v { // use the port name as the key, unless LegacyClusterPortKey is set and takes precedence // In EDS we match on port *name*. But for historical reasons, we match on port number for CDS. var portNum int if ep.LegacyClusterPortKey != 0 { if !ports.Contains(ep.LegacyClusterPortKey) { continue }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 15.6K bytes - Viewed (0) -
pilot/pkg/networking/util/util.go
var portTrafficPolicy *networking.TrafficPolicy_PortTrafficPolicy // Check if port level overrides exist, if yes override with them. for _, p := range policy.PortLevelSettings { if p.Port != nil && uint32(port.Port) == p.Port.Number { // per the docs, port level policies do not inherit and instead to defaults if not provided portTrafficPolicy = p break } } if portTrafficPolicy == nil { return policy, false }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 28.5K bytes - Viewed (0) -
pilot/pkg/model/telemetry_logging.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:30 UTC 2024 - 23K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/workloads.go
pl := &workloadapi.PortList{ Ports: make([]*workloadapi.Port, 0, len(svc.Ports)), } res[n] = pl for _, port := range svc.Ports { targetPort := port.TargetPort // The svc.Ports represents the workloadapi.Service, which drops the port name info and just has numeric target Port. // TargetPort can be 0 which indicates its a named port. Check if its a named port and replace with the real targetPort if so.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 16:51:29 UTC 2024 - 20.9K bytes - Viewed (0) -
cmd/object-multipart-handlers.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "bufio" "context" "io" "net/http" "net/url" "sort" "strconv" "strings" "time" "github.com/google/uuid" "github.com/minio/minio-go/v7" "github.com/minio/minio-go/v7/pkg/encrypt" "github.com/minio/minio-go/v7/pkg/tags"
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 14 13:28:35 UTC 2024 - 38.8K bytes - Viewed (0) -
pilot/pkg/networking/core/cluster_builder.go
if direction == model.TrafficDirectionInbound { // For inbound cluster, add all services on the cluster port have := sets.New[host.Name]() for _, svc := range inboundServices { if svc.Port.Port != port.Port { // If the service port is different from the port of the cluster that is being built, // skip adding telemetry metadata for the service to the cluster. continue }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 31.6K bytes - Viewed (0) -
cmd/erasure-multipart.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "context" "encoding/base64" "errors" "fmt" "io" "os" "path" "sort" "strconv" "strings" "sync" "time" "github.com/klauspost/readahead" "github.com/minio/minio-go/v7/pkg/set" "github.com/minio/minio/internal/config/storageclass" "github.com/minio/minio/internal/crypto"
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 06:56:12 UTC 2024 - 44.8K bytes - Viewed (0) -
pilot/pkg/networking/core/peer_authentication_simulation_test.go
- address: 1.1.1.1 location: MESH_INTERNAL resolution: STATIC ports: - name: http number: 8000 protocol: HTTP ---` mkCall := func(port int, tls simulation.TLSMode) simulation.Call { r := simulation.Call{Protocol: simulation.HTTP, Port: port, CallMode: simulation.CallModeInbound, TLS: tls} if tls == simulation.MTLS { r.Alpn = "istio" } return r } cases := []struct { name string
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 16.2K bytes - Viewed (0) -
pilot/pkg/model/gateway.go
// and validation ensures that all port names within a single gateway config are unique. if _, exists := serversByRouteName[routeName]; exists { log.Infof("skipping server on gateway %s port %s.%d.%s: non unique port name for HTTPS port", gatewayConfig.Name, s.Port.Name, resolvedPort, s.Port.Protocol) RecordRejectedConfig(gatewayName) continue }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 26K bytes - Viewed (0)