Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for NewFakeStore (0.22 sec)

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