Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for BuildStatefulSessionFilter (0.23 sec)

  1. 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)
  2. 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)
Back to top