workpool

Documentation

Index

• Variables
• type Entry
• type ExpirableMap
  • func NewExpirableMap(l int, expire func(time.Time, *Entry) bool) (m *ExpirableMap)
  • func (m *ExpirableMap) Get(k string) (v interface{}, ok bool)
  • func (m *ExpirableMap) Len() int
  • func (m *ExpirableMap) Put(k string, v interface{})
• type WorkPool
  • func GetWorkerPool() *WorkPool
  • func (wp *WorkPool) Get(k string) (any, error)
  • func (wp *WorkPool) Put(k string, v any)

Variables

var (
	ErrBlockNotExists = errors.New("no such block in the work pool")
)

Types

type Entry

type Entry struct {
	Timestamp int64
	Value     interface{}
}

type ExpirableMap

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

func NewExpirableMap

func NewExpirableMap(l int, expire func(time.Time, *Entry) bool) (m *ExpirableMap)

func (*ExpirableMap) Get

func (m *ExpirableMap) Get(k string) (v interface{}, ok bool)

func (*ExpirableMap) Len

func (m *ExpirableMap) Len() int

func (*ExpirableMap) Put

func (m *ExpirableMap) Put(k string, v interface{})

type WorkPool

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

func GetWorkerPool

func GetWorkerPool() *WorkPool

func (*WorkPool) Get

func (wp *WorkPool) Get(k string) (any, error)

func (*WorkPool) Put

func (wp *WorkPool) Put(k string, v any)