goproc

Jun 25, 2021

Changes in this version

+ type Controller struct

+ func NewController(ctx context.Context, name string) *Controller

+ func (c *Controller) Die() bool

+ func (c *Controller) Go(g Goroutine) *Controller

+ func (c *Controller) GoWithRecover(g Goroutine, rf Recover) *Controller

+ func (c *Controller) Shutdown()

+ func (c *Controller) Wait()

+ func (c *Controller) WithDeadline(deadline time.Time) *Controller

+ func (c *Controller) WithTimeout(timeout time.Duration) *Controller

+ func (c *Controller) WithValue(key interface{}, value interface{}) *Controller

+ type Goroutine func(ctx context.Context)

+ type Recover func(r interface{})

Jan 17, 2020

Changes in this version

type TimeoutChan

+ func (c *TimeoutChan) Stats() TimeoutChanStats

Jan 8, 2020

Changes in this version

+ type BackgroundController struct

+ func NewBackgroundController(ctx context.Context, name string) *BackgroundController

+ func (c *BackgroundController) Die() bool

+ func (c *BackgroundController) GoBackground(f BackgroundFunc)

+ func (c *BackgroundController) GoRecoverableBackground(f BackgroundFunc, h RecoverHandleFunc)

+ func (c *BackgroundController) Shutdown()

+ func (c *BackgroundController) WaitExit()

+ func (c *BackgroundController) WithDeadline(deadline time.Time) *BackgroundController

+ func (c *BackgroundController) WithTimeout(timeout time.Duration) *BackgroundController

+ func (c *BackgroundController) WithValue(key interface{}, value interface{}) *BackgroundController

+ type BackgroundFunc func(ctx context.Context)

+ type Deadliner interface

+ Deadline func() time.Time

+ type Prioritier interface

+ Priority func() int64

+ type PriorityQueue struct

+ func NewPriorityQueue(desc bool, size int) *PriorityQueue

+ func (q *PriorityQueue) Clear() int

+ func (q *PriorityQueue) Peek() interface{}

+ func (q *PriorityQueue) Pop() interface{}

+ func (q *PriorityQueue) Push(x interface{})

+ func (q PriorityQueue) Len() int

+ func (q PriorityQueue) Less(i, j int) bool

+ func (q PriorityQueue) Swap(i, j int)

+ type RecoverHandleFunc func(r interface{})

+ type TimeoutChan struct

+ In chan<- Deadliner

+ Out <-chan Deadliner

+ func NewTimeoutChan(ctx context.Context, resolution time.Duration, limit int) *TimeoutChan

+ func (c *TimeoutChan) Clear() int

+ func (c *TimeoutChan) Close()

+ func (c *TimeoutChan) Push(in Deadliner)

+ func (c *TimeoutChan) Shutdown()

+ func (c *TimeoutChan) Stat() TimeoutChanStats

+ type TimeoutChanStats struct

+ Cleared int

+ Popped int

+ Pushed int

+ func (s TimeoutChanStats) String() string