Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for ConvertConsolidatedDestRule (0.54 sec)

  1. pilot/pkg/model/destination_rule.go

    			destRules[resolvedHost] = append(destRules[resolvedHost], ConvertConsolidatedDestRule(&destRuleConfig))
    		}
    		return
    	}
    	// DestinationRule does not exist for the resolved host so add it
    	destRules[resolvedHost] = append(destRules[resolvedHost], ConvertConsolidatedDestRule(&destRuleConfig))
    	p.exportTo[resolvedHost] = exportToSet
    }
    
    func ConvertConsolidatedDestRule(cfg *config.Config) *ConsolidatedDestRule {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 07:22:29 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  2. pilot/pkg/xds/xds_cache_test.go

    		}
    	})
    
    	t.Run("multiple destinationRules", func(t *testing.T) {
    		c := model.NewXdsCache()
    
    		ep1 := makeEp("1", model.ConvertConsolidatedDestRule(&config.Config{Meta: config.Meta{Name: "a", Namespace: "b"}}))
    		ep2 := makeEp("2", model.ConvertConsolidatedDestRule(&config.Config{Meta: config.Meta{Name: "b", Namespace: "b"}}))
    
    		start := time.Now()
    		c.Add(ep1, &model.PushRequest{Start: start}, any1)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Aug 31 20:43:08 UTC 2023
    - 7.8K bytes
    - Viewed (0)
  3. pilot/pkg/xds/endpoints/endpoint_builder_test.go

    						"app": "foo",
    						"a":   "a",
    						"b":   "b",
    					},
    				},
    				push: &model.PushContext{
    					Mesh: tt.mesh,
    				},
    			}
    			if tt.dr != nil {
    				b.destinationRule = model.ConvertConsolidatedDestRule(tt.dr)
    			}
    			b.populateFailoverPriorityLabels()
    			if !reflect.DeepEqual(b.failoverPriorityLabels, tt.expectedLabels) {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sun Apr 21 17:42:54 UTC 2024
    - 5.9K bytes
    - Viewed (0)
  4. pilot/pkg/xds/bench_test.go

    		services = append(services, &model.Service{
    			Hostname:   host.Name(ns + "some" + index + ".example.com"),
    			Attributes: model.ServiceAttributes{Namespace: "test" + index},
    		})
    		drs = append(drs, model.ConvertConsolidatedDestRule(&config.Config{Meta: config.Meta{Name: index, Namespace: index}}))
    	}
    
    	key := &route.Cache{
    		RouteName:        "something",
    		ClusterID:        "my-cluster",
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Apr 22 18:13:40 UTC 2024
    - 19.7K bytes
    - Viewed (0)
  5. pilot/pkg/networking/core/cluster_builder_test.go

    					t.Fatalf("Expected (-) != actual (+):\n%s", v)
    				}
    			})
    		}
    	}
    }
    
    func drWithLabels(lbls labels.Instance) *model.ConsolidatedDestRule {
    	return model.ConvertConsolidatedDestRule(&config.Config{
    		Meta: config.Meta{},
    		Spec: &networking.DestinationRule{
    			Subsets: []*networking.Subset{{
    				Name:   "v1",
    				Labels: lbls,
    			}},
    		},
    	})
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 110.4K bytes
    - Viewed (0)
Back to top