util

type Expire ¶

type Expire struct {
	// contains filtered or unexported fields
}

Expire implements a simple last-seen-time-based expiry logic for watching for disappearing entities (for triggering events or just cache housekeeping). User classes define an expiry delay, then call Update every time they encounter a given entity. ComputeExpires() returns the entity names that have not been seen for longer than the configured delay.

func NewExpire(duration time.Duration) *Expire

func (e *Expire) ComputeExpires() []workloadmeta.EntityID

func (e *Expire) Update(id workloadmeta.EntityID, ts time.Time) bool