ttlmap

README

TtlMap

Redis-like Map with expiry times and maximum capacity

import "github.com/mailgun/ttlmap"

mh, _ := ttlmap.NewMap(20)
mh.Set("key1", "value", 20)
valI, exists := mh.Get("key2")
if exists {
   val := valI.(string)
}

Documentation

Index

• type Callback
• type TtlMap
  • func NewMap(capacity int, opts ...TtlMapOption) (*TtlMap, error)
  • func NewMapWithProvider(capacity int, timeProvider timetools.TimeProvider) (*TtlMap, error)
  • func (m *TtlMap) Get(key string) (interface{}, bool)
  • func (m *TtlMap) GetInt(key string) (int, bool, error)
  • func (m *TtlMap) Increment(key string, value int, ttlSeconds int) (int, error)
  • func (m *TtlMap) Len() int
  • func (m *TtlMap) Set(key string, value interface{}, ttlSeconds int) error
• type TtlMapOption
  • func CallOnExpire(cb Callback) TtlMapOption
  • func Clock(c timetools.TimeProvider) TtlMapOption

Types

type Callback

type Callback func(key string, el interface{})

type TtlMap

type TtlMap struct {
	TimeProvider timetools.TimeProvider
	// contains filtered or unexported fields
}

func NewMap

func NewMap(capacity int, opts ...TtlMapOption) (*TtlMap, error)

func NewMapWithProvider

func NewMapWithProvider(capacity int, timeProvider timetools.TimeProvider) (*TtlMap, error)

func (*TtlMap) Get

func (m *TtlMap) Get(key string) (interface{}, bool)

func (*TtlMap) GetInt

func (m *TtlMap) GetInt(key string) (int, bool, error)

func (*TtlMap) Increment

func (m *TtlMap) Increment(key string, value int, ttlSeconds int) (int, error)

func (*TtlMap) Len

func (m *TtlMap) Len() int

func (*TtlMap) Set

func (m *TtlMap) Set(key string, value interface{}, ttlSeconds int) error

type TtlMapOption

type TtlMapOption func(m *TtlMap) error

func CallOnExpire

func CallOnExpire(cb Callback) TtlMapOption

CallOnExpire will call this callback on expiration of elements

func Clock

func Clock(c timetools.TimeProvider) TtlMapOption

Clock sets the time provider clock, handy for testing