- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for NewFakeStore (0.18 sec)
-
pilot/pkg/model/proxy_config_test.go
Name: name, Namespace: ns, }, Spec: spec, } } func newProxyConfigStore(t *testing.T, configs []config.Config) ConfigStore { t.Helper() store := NewFakeStore() for _, cfg := range configs { store.Create(cfg) } return store } func setCreationTimestamp(c config.Config, t time.Time) config.Config { c.Meta.CreationTimestamp = t return c }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Mar 21 01:23:19 UTC 2023 - 11.8K bytes - Viewed (0) -
pilot/pkg/config/kube/gateway/deploymentcontroller_test.go
Name: "custom", }, Spec: k8s.GatewayClassSpec{ ControllerName: k8s.GatewayController(features.ManagedGatewayController), }, } defaultObjects := []runtime.Object{defaultNamespace} store := model.NewFakeStore() if _, err := store.Create(config.Config{ Meta: config.Meta{ GroupVersionKind: gvk.ProxyConfig, Name: "test", Namespace: "default", },
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 13 21:43:20 UTC 2024 - 16.5K bytes - Viewed (0) -
pilot/pkg/model/authentication_test.go
} }) } } func getTestAuthenticationPolicies(configs []*config.Config, t *testing.T) *AuthenticationPolicies { configStore := NewFakeStore() for _, cfg := range configs { log.Infof("add config %s", cfg.Name) if _, err := configStore.Create(*cfg); err != nil { t.Fatalf("getTestAuthenticationPolicies %v", err) } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 22:20:44 UTC 2024 - 45.1K bytes - Viewed (0) -
pkg/kube/inject/webhook_test.go
t.Fatalf("WriteFile(%v) failed: %v", valuesFile, err) } // mesh config m := mesh.DefaultMeshConfig() store := model.NewFakeStore() for i := 0; i < pcResources; i++ { store.Create(newProxyConfig(fmt.Sprintf("pc-%d", i), "istio-system", &v1beta12.ProxyConfig{ Concurrency: &wrapperspb.Int32Value{Value: int32(i % 5)},
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jul 17 20:25:52 UTC 2023 - 39K bytes - Viewed (1)