plcache

Documentation

Overview

Package plcache implements cache in pipeline

Index

• Variables
• type Cache
  • func NewCache(interval time.Duration, numSlots int) (*Cache, error)
  • func NewCacheWithTicker(interval time.Duration, numSlots int, ticker *time.Ticker) (*Cache, error)
  • func (c *Cache) Get(key string) (any, bool, error)
  • func (c *Cache) Set(key string, value any, expiration time.Duration) error
  • func (c *Cache) Stop()

Variables

var (
	ErrClosed = errors.New("cache is closed")
	ErrArg    = errors.New("illegal arguments")
)

Types

type Cache

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

func NewCache

func NewCache(interval time.Duration, numSlots int) (*Cache, error)

NewCache returns a Cache

func NewCacheWithTicker

func NewCacheWithTicker(interval time.Duration, numSlots int, ticker *time.Ticker) (*Cache, error)

NewCacheWithTicker returns a Cache with the given ticker.

func (*Cache) Get

func (c *Cache) Get(key string) (any, bool, error)

func (*Cache) Set

func (c *Cache) Set(key string, value any, expiration time.Duration) error

func (*Cache) Stop

func (c *Cache) Stop()