Versions in this module Expand all Collapse all v0 v0.2.0 Apr 12, 2022 Changes in this version + const SIZE + var WorkerChannel = make(chan chan Work) + func CreateExampleJobs(amount int) []string + func Example() + func ExampleWork(params Params) error + func RandStringRunes(n int) string + type Any interface + type Cache struct + Hash Hash + Queue Queue + func NewCache() Cache + func (c *Cache) Add(n *Node) + func (c *Cache) Check(str string) + func (c *Cache) Display() + func (c *Cache) Remove(n *Node) *Node + type Collector struct + End chan bool + Work chan Work + func StartDispatcher(workerCount int) Collector + type GetSetter interface + Get func(key Any) (Any, error) + Set func(key Any, value Any) error + type Hash map[string]*Node + type JobSpec interface + Completed func() bool + Deadline func() time.Time + Id func() int + Identifier func() Any + Name func() string + type Node struct + Left *Node + Right *Node + Val string + type Params interface + func NewParams(locked bool, m map[string]Any) Params + type Queue struct + Head *Node + Length int + Tail *Node + func NewQueue() Queue + func (q *Queue) Display() + type Work struct + ID int + JS JobSpec + Job string + type Worker interface + DoWork func(params Params) + Start func() + Stop func()
Go to main page