store

Documentation

Overview

Implement expiry within the the actual value storage The underlying store will need to use this when Inserting/Retrieving

Index

• func HasBytesExpired(buf []byte, now time.Time) bool
• type StoreEntry
  • func DecodeStoreEntry(key, value []byte) StoreEntry
  • func (e *StoreEntry) Encode() (key, value []byte)
• type StoreExpiry
  • func NewStoreExpiry(compactorFunc func(), compactionInterval time.Duration) (*StoreExpiry, error)
  • func (s *StoreExpiry) NewStoreEntry(key string, value []byte, ttl time.Duration) StoreEntry

Functions

func HasBytesExpired

func HasBytesExpired(buf []byte, now time.Time) bool

Types

type StoreEntry

type StoreEntry struct {
	Value []byte
	expiry.ExpiryRecord
}

StoreEntry retains the efficiency of ExpiryRecord Further encodes the expiry in the the Value

func DecodeStoreEntry

func DecodeStoreEntry(key, value []byte) StoreEntry

Decode the raw bytes into the StoreEntry type

func (*StoreEntry) Encode

func (e *StoreEntry) Encode() (key, value []byte)

type StoreExpiry

type StoreExpiry struct {
	*expiry.Expiry
}

func NewStoreExpiry

func NewStoreExpiry(compactorFunc func(), compactionInterval time.Duration) (*StoreExpiry, error)

func (*StoreExpiry) NewStoreEntry

func (s *StoreExpiry) NewStoreEntry(key string, value []byte, ttl time.Duration) StoreEntry