Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for MaybeBuildStatefulSessionFilterConfig (0.67 sec)

  1. pilot/pkg/networking/util/util.go

    	filterConfig := MaybeBuildStatefulSessionFilterConfig(svc)
    	if filterConfig == nil {
    		return nil
    	}
    
    	return &hcm.HttpFilter{
    		Name: StatefulSessionFilter,
    		ConfigType: &hcm.HttpFilter_TypedConfig{
    			TypedConfig: protoconv.MessageToAny(filterConfig),
    		},
    	}
    }
    
    func MaybeBuildStatefulSessionFilterConfig(svc *model.Service) *statefulsession.StatefulSession {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 28.5K bytes
    - Viewed (0)
  2. pilot/pkg/networking/util/util_test.go

    							Name: "test-cookie",
    						},
    					}),
    				},
    			},
    		},
    	}
    	for _, tt := range cases {
    		t.Run(tt.name, func(t *testing.T) {
    			sessionConfig := MaybeBuildStatefulSessionFilterConfig(tt.service)
    			if !reflect.DeepEqual(tt.expectedconfig, sessionConfig) {
    				t.Errorf("unexpected stateful session filter config, expected: %v, got :%v", tt.expectedconfig, sessionConfig)
    			}
    		})
    	}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 01:17:58 UTC 2024
    - 40K bytes
    - Viewed (0)
  3. pilot/pkg/networking/core/httproute.go

    			push.AddMetric(model.DuplicatedDomains, name, node.ID, msg)
    		}
    		if len(domains) > 0 {
    			pervirtualHostFilters := map[string]*anypb.Any{}
    			if statefulConfig := util.MaybeBuildStatefulSessionFilterConfig(svc); statefulConfig != nil {
    				perRouteStatefulSession := &statefulsession.StatefulSessionPerRoute{
    					Override: &statefulsession.StatefulSessionPerRoute_StatefulSession{
    						StatefulSession: statefulConfig,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Mar 28 17:09:02 UTC 2024
    - 32.7K bytes
    - Viewed (0)
  4. pilot/pkg/networking/core/gateway.go

    					perRouteFilters := map[string]*anypb.Any{}
    					if gatewayService != nil {
    						// Build StatefulSession Filter if gateway service has persistence session label.
    						if statefulConfig := util.MaybeBuildStatefulSessionFilterConfig(gatewayService); statefulConfig != nil {
    							perRouteStatefulSession := &statefulsession.StatefulSessionPerRoute{
    								Override: &statefulsession.StatefulSessionPerRoute_StatefulSession{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon May 06 04:44:06 UTC 2024
    - 46.4K bytes
    - Viewed (0)
  5. pilot/pkg/networking/core/route/route.go

    	}
    	var statefulConfig *statefulsession.StatefulSession
    	for _, hostname := range hostnames {
    		perSvcStatefulConfig := util.MaybeBuildStatefulSessionFilterConfig(serviceRegistry[hostname])
    		// This means we have more than one stateful config for the same route because of weighed destinations.
    		// We should just pick the first and give a warning.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 14 14:12:39 UTC 2024
    - 56.1K bytes
    - Viewed (0)
Back to top