memory

Documentation

Index

• func NewBus(middlewares ...MiddlewareFunc) bus.Bus
• func NewSchedulerAdapter() bus.SchedulerAdapter
• type MiddlewareFunc

Functions

func NewBus

func NewBus(middlewares ...MiddlewareFunc) bus.Bus

Creates a new in memory bus which will call the handlers in process.

func NewSchedulerAdapter

func NewSchedulerAdapter() bus.SchedulerAdapter

Builds a new inmemory scheduler adapter which will store all scheduled jobs in memory. It will not make use of dedupe names and should be used only for testing purposes.

Types

type MiddlewareFunc

type MiddlewareFunc func(bus.NextFunc) bus.NextFunc

Middleware function used to add behavior to the dispatch process.