- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for Builds (0.27 sec)
-
pilot/pkg/networking/core/listener_inbound.go
func (lb *ListenerBuilder) buildInboundListeners() []*listener.Listener { // All listeners we build var listeners []*listener.Listener // virtualInboundFilterChains builds up all of the filter chains for the virtual inbound listener var virtualInboundFilterChains []*listener.FilterChain // For each chain config we will build required filter chain(s) for _, cc := range lb.buildInboundChainConfigs() {
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/networking/util/util.go
if strings.Contains(host, ":") { return "[" + host + "]" } return host } // DomainName builds the domain name for a given host and port func DomainName(host string, port int) string { return net.JoinHostPort(host, strconv.Itoa(port)) } // BuildInternalEndpoint builds an lb endpoint pointing to the internal listener named dest.
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/networking/core/cluster_builder.go
if cachedCluster == nil { allFound = false } res = append(res, cachedCluster) } return res, allFound } // build does any final build operations needed, like marshaling etc. func (mc *clusterWrapper) build() *cluster.Cluster { if mc == nil { return nil } // Marshall Http Protocol options if they exist. if mc.httpProtocolOptions != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 31.6K bytes - Viewed (0) -
pilot/pkg/networking/core/listener_waypoint.go
post = append(post, xdsfilters.WaypointUpstreamMetadataFilter) post = append(post, lb.push.Telemetry.HTTPFilters(lb.node, cls, svc)...) return } // buildWaypointInboundHTTPFilters builds the network filters that should be inserted before an HCM. // This should only be used with HTTP; see buildInboundNetworkFilters for TCP
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 27.6K bytes - Viewed (0) -
pilot/pkg/networking/core/cluster.go
deletedClusters = append(deletedClusters, subsetClusters[matchedSvc.Hostname.String()].UnsortedList()...) } } return services, deletedClusters } // buildClusters builds clusters for the proxy with the services passed. func (configgen *ConfigGeneratorImpl) buildClusters(proxy *model.Proxy, req *model.PushRequest, services []*model.Service, ) ([]*discovery.Resource, model.XdsLogDetails) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 33K bytes - Viewed (0)