- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 1,561 for store1 (0.1 sec)
-
pilot/pkg/config/aggregate/config_test.go
func TestAggregateStoreWrite(t *testing.T) { g := NewWithT(t) store1 := memory.Make(collection.SchemasFor(collections.HTTPRoute)) store2 := memory.Make(collection.SchemasFor(collections.HTTPRoute)) stores := []model.ConfigStore{store1, store2} store, err := makeStore(stores, store1) g.Expect(err).NotTo(HaveOccurred()) if _, err := store.Create(config.Config{ Meta: config.Meta{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 02 17:36:47 UTC 2024 - 6.7K bytes - Viewed (0) -
platforms/software/dependency-management/src/test/groovy/org/gradle/api/internal/artifacts/ivyservice/resolveengine/store/CachedStoreFactoryTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 16 15:49:50 UTC 2024 - 1.3K bytes - Viewed (0) -
platforms/software/dependency-management/src/test/groovy/org/gradle/api/internal/artifacts/ivyservice/resolveengine/store/ResolutionResultsStoreFactoryTest.groovy
def store2 = stores1.nextBinaryStore() // rolled def store3 = f.createStoreSet().nextBinaryStore() then: store.file != store2.file //rolled [store.file, store2.file, store3.file].each { it.exists() } when: new CompositeStoppable().add(store, store2, store3) then: [store.file, store2.file, store3.file].each { !it.exists() } }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 16 15:49:50 UTC 2024 - 3.4K bytes - Viewed (0) -
src/cmd/compile/internal/ssa/deadstore_test.go
Valu("store1", OpStore, types.TypeMem, 0, c.config.Types.Int64, "addr1", "v", "start"), // store 8 bytes Valu("store2", OpStore, types.TypeMem, 0, c.config.Types.Bool, "addr1", "v", "store1"), // store 1 byte Goto("exit")), Bloc("exit", Exit("store2"))) CheckFunc(fun.f) cse(fun.f) dse(fun.f) CheckFunc(fun.f) v := fun.values["store1"] if v.Op == OpCopy {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Apr 25 20:07:26 UTC 2024 - 5.6K bytes - Viewed (0) -
pilot/pkg/serviceregistry/serviceentry/store.go
package serviceentry import ( "k8s.io/apimachinery/pkg/types" "istio.io/istio/pilot/pkg/model" "istio.io/istio/pkg/util/sets" ) type hostPort struct { host instancesKey port int } // stores all the service instances from SE, WLE and pods type serviceInstancesStore struct { ip2instance map[string][]*model.ServiceInstance // service instances by hostname -> config
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 15:31:09 UTC 2024 - 6.1K bytes - Viewed (0) -
internal/store/store.go
DelList(key []string) error Open() error Delete() error Extension() string } // Key denotes the key present in the store. type Key struct { Name string IsLast bool } // replayItems - Reads the items from the store and replays. func replayItems[I any](store Store[I], doneCh <-chan struct{}, log logger, id string) <-chan Key { keyCh := make(chan Key) go func() { defer xioutil.SafeClose(keyCh)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Mar 25 16:44:20 UTC 2024 - 3.5K bytes - Viewed (0) -
pilot/pkg/autoregistration/internal/state/store.go
IsControllerOf(wle *config.Config) bool } // NewStore returns a new Store instance. func NewStore(store model.ConfigStoreController, cb StoreCallbacks) *Store { return &Store{ store: store, cb: cb, } } // UpdateHealth updates the associated WorkloadEntries health status // based on the corresponding health check performed by istio-agent.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 3.3K bytes - Viewed (0) -
pilot/pkg/config/memory/store.go
) const ResourceVersion string = "ResourceVersion" // Make creates an in-memory config store from a config schemas // It is with validation func Make(schemas collection.Schemas) model.ConfigStore { return newStore(schemas, false) } // MakeSkipValidation creates an in-memory config store from a config schemas // It is without validation func MakeSkipValidation(schemas collection.Schemas) model.ConfigStore {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Dec 26 01:14:27 UTC 2023 - 6.3K bytes - Viewed (0) -
pkg/kubelet/util/store/store.go
keyRegex = regexp.MustCompile("^" + qualifiedKeyFmt + "$") // ErrKeyNotFound is the error returned if key is not found in Store. ErrKeyNotFound = fmt.Errorf("key is not found") ) // Store provides the interface for storing keyed data. // Store must be thread-safe type Store interface { // key must contain one or more characters in [A-Za-z0-9] // Write writes data with key. Write(key string, data []byte) error
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Oct 19 22:18:30 UTC 2017 - 1.9K bytes - Viewed (0) -
internal/config/dns/store.go
// ErrBucketConflict for buckets that already exist type ErrBucketConflict Error func (e ErrBucketConflict) Error() string { return e.Bucket + " bucket conflict error: " + e.Err.Error() } // Store dns record store type Store interface { Put(bucket string) error Get(bucket string) ([]SrvRecord, error) Delete(bucket string) error List() (map[string][]SrvRecord, error) DeleteRecord(record SrvRecord) error Close() error
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Jun 01 21:59:40 UTC 2021 - 1.6K bytes - Viewed (0)