Versions in this module Expand all Collapse all v0 v0.0.1 Oct 25, 2020 Changes in this version + const DefaultPriority + func NewPriorityGoringQueue() *priorityQueue + func NewPriorityMpscQueue() *priorityQueue + func NewPriorityQueue(queueProducer func() queue) *priorityQueue + func SetLogLevel(level log.Level) + type Dispatcher interface + Schedule func(fn func()) + Throughput func() int + func NewDefaultDispatcher(throughput int) Dispatcher + func NewSynchronizedDispatcher(throughput int) Dispatcher + type Mailbox interface + PostSystemMessage func(message interface{}) + PostUserMessage func(message interface{}) + RegisterHandlers func(invoker MessageInvoker, dispatcher Dispatcher) + Start func() + type MessageInvoker interface + EscalateFailure func(reason interface{}, message interface{}) + InvokeSystemMessage func(interface{}) + InvokeUserMessage func(interface{}) + type PriorityMessage interface + GetPriority func() int8 + type Producer func() Mailbox + func Bounded(size int, mailboxStats ...Statistics) Producer + func BoundedDropping(size int, mailboxStats ...Statistics) Producer + func Unbounded(mailboxStats ...Statistics) Producer + func UnboundedLockfree(mailboxStats ...Statistics) Producer + func UnboundedPriority(mailboxStats ...Statistics) Producer + func UnboundedPriorityMpsc(mailboxStats ...Statistics) Producer + type ResumeMailbox struct + type Statistics interface + MailboxEmpty func() + MailboxStarted func() + MessagePosted func(message interface{}) + MessageReceived func(message interface{}) + type SuspendMailbox struct