vstore

Documentation

Index

• Variables
• type ValueRecord
  • func NewValueRecord(key []byte, value []byte, addedAt int64, ttl int64, ttlUnit time.Duration) *ValueRecord
  • func (vr *ValueRecord) HasExpired() bool
• type ValueStore
  • func NewValueStore(ttl int64, ttlUnit time.Duration) *ValueStore
  • func (vs *ValueStore) Get(key []byte) ([]byte, error)
  • func (vs *ValueStore) PruneOld()
  • func (vs *ValueStore) PruneWorker()
  • func (vs *ValueStore) Put(key []byte, value []byte) error

Variables

var (
	ErrNotFound = errors.New("key: not found")
)

Types

type ValueRecord

type ValueRecord struct {
	AddedAt int64         // When was the record added
	TTL     int64         // The time to live of the record
	TTLUnit time.Duration // Duration multiplier
	// contains filtered or unexported fields
}

func NewValueRecord

func NewValueRecord(key []byte, value []byte, addedAt int64, ttl int64, ttlUnit time.Duration) *ValueRecord

func (*ValueRecord) HasExpired

func (vr *ValueRecord) HasExpired() bool

type ValueStore

type ValueStore struct {
	KVStore map[string]*ValueRecord // The backing datastore
	// contains filtered or unexported fields
}

func NewValueStore

func NewValueStore(ttl int64, ttlUnit time.Duration) *ValueStore

func (*ValueStore) Get

func (vs *ValueStore) Get(key []byte) ([]byte, error)

func (*ValueStore) PruneOld

func (vs *ValueStore) PruneOld()

func (*ValueStore) PruneWorker

func (vs *ValueStore) PruneWorker()

func (*ValueStore) Put

func (vs *ValueStore) Put(key []byte, value []byte) error