bus

package
v3.0.0-beta6+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 29, 2016 License: Apache-2.0 Imports: 2 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AddEventListener

func AddEventListener(handler HandlerFunc)

Package level functions

func AddHandler

func AddHandler(implName string, handler HandlerFunc)

Package level functions

func AddWildcardListener

func AddWildcardListener(handler HandlerFunc)

func ClearBusHandlers

func ClearBusHandlers()

func Dispatch

func Dispatch(msg Msg) error

func Publish

func Publish(msg Msg) error

Types

type Bus

type Bus interface {
	Dispatch(msg Msg) error
	Publish(msg Msg) error

	AddHandler(handler HandlerFunc)
	AddEventListener(handler HandlerFunc)
	AddWildcardListener(handler HandlerFunc)
}

func New

func New() Bus

type HandlerFunc

type HandlerFunc interface{}

type InProcBus

type InProcBus struct {
	// contains filtered or unexported fields
}

func (*InProcBus) AddEventListener

func (b *InProcBus) AddEventListener(handler HandlerFunc)

func (*InProcBus) AddHandler

func (b *InProcBus) AddHandler(handler HandlerFunc)

func (*InProcBus) AddWildcardListener

func (b *InProcBus) AddWildcardListener(handler HandlerFunc)

func (*InProcBus) Dispatch

func (b *InProcBus) Dispatch(msg Msg) error

func (*InProcBus) Publish

func (b *InProcBus) Publish(msg Msg) error

type Msg

type Msg interface{}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL