Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for NewStore (0.18 sec)

  1. pilot/pkg/autoregistration/internal/state/store.go

    type StoreCallbacks interface {
    	// IsControllerOf returns true if a given WorkloadEntry is connected
    	// to this istiod instance.
    	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
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 23 17:08:31 UTC 2023
    - 3.3K bytes
    - Viewed (0)
  2. pilot/pkg/config/memory/store.go

    // 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 {
    	return newStore(schemas, true)
    }
    
    func newStore(schemas collection.Schemas, skipValidation bool) model.ConfigStore {
    	out := store{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Dec 26 01:14:27 UTC 2023
    - 6.3K bytes
    - Viewed (0)
  3. pkg/controller/job/tracking_utils.go

    // NewUIDTrackingControllerExpectations returns a wrapper around
    // ControllerExpectations that is aware of deleteKeys.
    func newUIDTrackingExpectations() *uidTrackingExpectations {
    	return &uidTrackingExpectations{store: cache.NewStore(uidSetKeyFunc)}
    }
    
    func hasJobTrackingFinalizer(pod *v1.Pod) bool {
    	for _, fin := range pod.Finalizers {
    		if fin == batch.JobTrackingFinalizer {
    			return true
    		}
    	}
    	return false
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 14 05:40:02 UTC 2023
    - 4.3K bytes
    - Viewed (0)
  4. pkg/controller/job/backoff_utils.go

    	}
    
    	if ok {
    		err = s.store.Delete(b)
    		if err != nil {
    			return err
    		}
    	}
    
    	return nil
    
    }
    
    func newBackoffStore() *backoffStore {
    	return &backoffStore{
    		store: cache.NewStore(backoffRecordKeyFunc),
    	}
    }
    
    var backoffRecordKeyFunc = func(obj interface{}) (string, error) {
    	if u, ok := obj.(*backoffRecord); ok {
    		return u.key, nil
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 06 07:46:41 UTC 2024
    - 8.3K bytes
    - Viewed (0)
Back to top