bus

Documentation

Overview

Package bus provides Readeck's message bus and task executor.

Index

• func Events() superbus.EventManager
• func Load() error
• func LoadCustom(p string, em superbus.EventManager, s superbus.Store)
• func OnReady(f func())
• func Protocol() string
• func Store() superbus.Store
• func Tasks() *superbus.TaskManager

Functions

func Events

func Events() superbus.EventManager

Events returns the default event manager.

func Load

func Load() error

Load loads the configuration and prepares the worker queue.

func LoadCustom

func LoadCustom(p string, em superbus.EventManager, s superbus.Store)

LoadCustom loads a custom EventManager and Store. Used for tests.

func OnReady

func OnReady(f func())

OnReady lets you add functions that are called when the bus is loaded.

func Protocol

func Protocol() string

Protocol returns the superbus protocol in use.

func Store

func Store() superbus.Store

Store returns the default store.

func Tasks

func Tasks() *superbus.TaskManager

Tasks returns the default task manager.