slowset

type ObjectData ¶

type ObjectData struct {
	Timestamp       time.Time
	StorageClassUID string
}

type SlowSet ¶

type SlowSet struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

SlowSet is a set of API objects that should be synced at slower rate. Key is typically the object namespace + name and value is timestamp when the object was added to the set.

func NewSlowSet(retTime time.Duration) *SlowSet

func (s *SlowSet) Add(key string, info ObjectData) bool

func (s *SlowSet) Contains(key string) bool

func (s *SlowSet) Get(key string) (ObjectData, bool)

func (s *SlowSet) Remove(key string)

func (s *SlowSet) Run(stopCh <-chan struct{})

func (s *SlowSet) TimeRemaining(key string) time.Duration