- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for instanceId (0.48 sec)
-
pilot/pkg/model/gateway.go
hosts.InsertAll(s.Hosts...) } } } } return hosts } func udpSupportedPort(number uint32, instances []ServiceTarget) bool { for _, w := range instances { if int(number) == w.Port.Port && w.Port.Protocol == protocol.UDP { return true } } return false }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 26K bytes - Viewed (0) -
pilot/pkg/model/endpointshards.go
Cluster() cluster.ID Provider() provider.ID } // ShardKeyFromRegistry computes the shard key based on provider type and cluster id. func ShardKeyFromRegistry(instance shardRegistry) ShardKey { return ShardKey{Cluster: instance.Cluster(), Provider: instance.Provider()} } // ShardKey is the key for EndpointShards made of a key with the format "provider/cluster" type ShardKey struct { Cluster cluster.ID Provider provider.ID
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/model/telemetry_logging.go
}, } // State logged by the metadata exchange filter about the upstream and downstream service instances // We need to propagate these as part of access log service stream // Logging them by default on the console may be an issue as the base64 encoded string is bound to be a big one.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:30 UTC 2024 - 23K bytes - Viewed (0) -
cmd/object-multipart-handlers.go
dstRecords, err = globalDNSConfig.Get(dstBucket) if err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } // Send PutObject request to appropriate instance (in federated deployment) core, rerr := getRemoteInstanceClient(r, getHostFromSrv(dstRecords)) if rerr != nil { writeErrorResponse(ctx, w, toAPIError(ctx, rerr), r.URL) return }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 14 13:28:35 UTC 2024 - 38.8K bytes - Viewed (0)