lib

Documentation

Index

• type BoltCache
  • func NewBoltCache(path string) (BoltCache, error)
  • func (c BoltCache) Del(ns, k string)
  • func (c BoltCache) Get(ns, k string) ([]byte, bool)
  • func (c BoltCache) Items(ns string, ks chan<- string)
  • func (c BoltCache) Set(ns, k string, v []byte)
• type Cache
• type Progress
• type RateLimit
  • func (r *RateLimit) DoWithBackoff(f func() (err error, fatal bool)) error
  • func (r *RateLimit) Get()
  • func (r *RateLimit) Start()
  • func (r *RateLimit) Stop()
  • func (r *RateLimit) TryGet() bool

Types

type BoltCache

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

func NewBoltCache

func NewBoltCache(path string) (BoltCache, error)

func (BoltCache) Del

func (c BoltCache) Del(ns, k string)

func (BoltCache) Get

func (c BoltCache) Get(ns, k string) ([]byte, bool)

func (BoltCache) Items

func (c BoltCache) Items(ns string, ks chan<- string)

func (BoltCache) Set

func (c BoltCache) Set(ns, k string, v []byte)

type Cache

type Cache interface {
	Set(ns, k string, v []byte)
	Get(ns, k string) ([]byte, bool)
	Del(ns, k string)
	Items(ns string, ks chan<- string)
	Close()
}

type Progress

type Progress struct {
	Current uint
	Total   uint
}

Progress represents a simple "done xxx out of yyy"-style progress report.

type RateLimit

type RateLimit struct {
	Period       time.Duration
	Rate         uint
	BackoffLimit uint
	BackoffStart time.Duration
	// contains filtered or unexported fields
}

func (*RateLimit) DoWithBackoff

func (r *RateLimit) DoWithBackoff(f func() (err error, fatal bool)) error

func (*RateLimit) Get

func (r *RateLimit) Get()

func (*RateLimit) Start

func (r *RateLimit) Start()

func (*RateLimit) Stop

func (r *RateLimit) Stop()

func (*RateLimit) TryGet

func (r *RateLimit) TryGet() bool