ttlstore

type DeleteHook ¶

type DeleteHook func(key interface{})

type Deleter ¶

type Deleter struct {
	DeleteFunc DeleteHook
	Interval   time.Duration
	Name       string
	Now        func() time.Time
	// contains filtered or unexported fields
}

Deleter implements a clean up mechanism. Deleter keeps at least `keep` items. The items must be younger then `maxAge`. One should call Set method for keys one wants to keep for a specific time. The deletion process is triggered by a timer set to `Interval` value. It removes items from the oldest to the newest until we have less than `keep` items.

func NewDeleter(name string, del DeleteHook, maxAge, runInterval time.Duration,
	bufSize, keep int, logger logrus.FieldLogger) *Deleter

func (d *Deleter) Deleting()

func (d *Deleter) Process()

func (d *Deleter) Set(key interface{}, insert time.Time)

func (d *Deleter) Start()

func (d *Deleter) Stop()

type DeleterProvider ¶

type DeleterProvider func(name string, hook DeleteHook) *Deleter

func NewDeleterProvider(maxAge, interval time.Duration, bufSize, keep int) DeleterProvider

type SetCallback ¶

type SetCallback func(key interface{}, insert time.Time)

type TtlStore ¶

type TtlStore struct {
	Now func() time.Time
	// contains filtered or unexported fields
}

TtlStore is a map store with callback on Set. It wraps around the sync.Map. It adds `Delete` method used by Deleter.

func New(c SetCallback) *TtlStore

func (t *TtlStore) Delete(key interface{})

func (t *TtlStore) Get(key interface{}) interface{}

func (t *TtlStore) GetHas(key interface{}) (interface{}, bool)

func (t *TtlStore) Has(key interface{}) bool

func (t *TtlStore) Set(key, value interface{})