dispatcher

Documentation

Index

• type Dispatcher
  • func New[K cmp.Ordered](options *Options) *Dispatcher[K]
  • func (d *Dispatcher[K]) Dispatch(serialID K, functor func()) error
  • func (d *Dispatcher[K]) Stop()
• type Options

Types

type Dispatcher

type Dispatcher[K comparable] struct {
	// contains filtered or unexported fields
}

func New

func New[K cmp.Ordered](options *Options) *Dispatcher[K]

func (*Dispatcher[K]) Dispatch

func (d *Dispatcher[K]) Dispatch(serialID K, functor func()) error

func (*Dispatcher[K]) Stop

func (d *Dispatcher[K]) Stop()

type Options

type Options struct {
	// number of goroutines to be spawned by this dispatcher instance
	GoroutineCount uint16

	// max number of pending events for each goroutine queue
	QueueLength uint16

	// whether to log event lifecycle
	EnableLogging bool
}