- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for BuildStatefulSessionFilter (0.23 sec)
-
pilot/pkg/networking/grpcgen/lds.go
for _, p := range sv.Ports { sPort := strconv.Itoa(p.Port) if !match.includesPort(sPort) { continue } filters := supportedFilters if sessionFilter := util.BuildStatefulSessionFilter(sv); sessionFilter != nil { filters = append([]*hcm.HttpFilter{sessionFilter}, filters...) } ll := &listener.Listener{ Name: net.JoinHostPort(matchedHost, sPort), Address: &core.Address{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 22:20:44 UTC 2024 - 14.6K bytes - Viewed (0) -
pilot/pkg/networking/util/util.go
// logical destination behind the tunnel, on which policy and telemetry will be applied "local": net.JoinHostPort(address, strconv.Itoa(port)), } st, _ := structpb.NewStruct(m) return st } func BuildStatefulSessionFilter(svc *model.Service) *hcm.HttpFilter { filterConfig := MaybeBuildStatefulSessionFilterConfig(svc) if filterConfig == nil { return nil } return &hcm.HttpFilter{ Name: StatefulSessionFilter,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 28.5K bytes - Viewed (0)