cache

Jun 29, 2023

Changes in this version

+ type Cache interface

+ Add func(task.Task)

+ Get func(id string) TaskJob

+ type DurationStats struct

+ Max time.Duration

+ Min time.Duration

+ func (s *DurationStats) Add(d time.Duration)

+ func (s *DurationStats) Average() time.Duration

+ func (s *DurationStats) String() string

+ type Memory struct

+ func NewMemory(ttl_minutes int) *Memory

+ func (c *Memory) Add(t task.Task)

+ func (c *Memory) Get(id string) TaskJob

+ func (c *Memory) Recap() map[string]*Stats

+ func (c *Memory) Recycle() Stat

+ type Stat struct

+ Count int

+ ProcessTime time.Duration

+ Removed int

+ Unfinished []task.Task

+ type Stats struct

+ CompletedCount int

+ CompletedTimes []time.Time

+ ErrorCount int

+ ErrorTimes []time.Time

+ ExecTimes *DurationStats

+ func (s *Stats) MarshalJSON() ([]byte, error)

+ func (s Stats) String() string

+ func (stats *Stats) Add(tsk task.Task)

+ type TaskJob struct

+ Completed bool

+ Events []task.Task

+ LastUpdate time.Time