Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for makeStore (0.26 sec)

  1. pilot/pkg/config/aggregate/config_test.go

    	schema2 := collections.GatewayClass
    	store1 := memory.Make(collection.SchemasFor(schema1))
    	store2 := memory.Make(collection.SchemasFor(schema2))
    
    	stores := []model.ConfigStore{store1, store2}
    
    	store, err := makeStore(stores, nil)
    	g.Expect(err).NotTo(HaveOccurred())
    
    	schemas := store.Schemas()
    	g.Expect(cmp.Diff(schemas, collection.SchemasFor(schema1, schema2))).To(BeEmpty())
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Feb 02 17:36:47 UTC 2024
    - 6.7K bytes
    - Viewed (0)
  2. pilot/pkg/config/aggregate/config.go

    	"istio.io/istio/pkg/slices"
    	"istio.io/istio/pkg/util/sets"
    )
    
    var errorUnsupported = errors.New("unsupported operation: the config aggregator is read-only")
    
    // makeStore creates an aggregate config store from several config stores and
    // unifies their descriptors
    func makeStore(stores []model.ConfigStore, writer model.ConfigStore) (model.ConfigStore, error) {
    	union := collection.NewSchemasBuilder()
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Dec 26 01:14:27 UTC 2023
    - 5.4K bytes
    - Viewed (0)
  3. pilot/pkg/model/fake_store.go

    	"istio.io/istio/pkg/maps"
    )
    
    type FakeStore struct {
    	store map[config.GroupVersionKind]map[string]map[string]config.Config
    }
    
    func NewFakeStore() *FakeStore {
    	f := FakeStore{
    		store: make(map[config.GroupVersionKind]map[string]map[string]config.Config),
    	}
    	return &f
    }
    
    var _ ConfigStore = (*FakeStore)(nil)
    
    func (s *FakeStore) Schemas() collection.Schemas {
    	return collections.Pilot
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Jul 18 06:50:06 UTC 2023
    - 3K bytes
    - Viewed (0)
  4. pilot/pkg/model/push_context_test.go

    			ClusterLocalHosts{}),
    		// These are not feasible/worth comparing
    		cmpopts.IgnoreTypes(sync.RWMutex{}, localServiceDiscovery{}, FakeStore{}, atomic.Bool{}, sync.Mutex{}),
    		cmpopts.IgnoreUnexported(IstioEndpoint{}),
    		cmpopts.IgnoreInterfaces(struct{ mesh.Holder }{}),
    		protocmp.Transform(),
    	)
    	if diff != "" {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sun Apr 21 17:42:54 UTC 2024
    - 95.3K bytes
    - Viewed (0)
Back to top