notify

Documentation

Index

• Constants
• func Post(event interface{}, data interface{}) error
• func PostTimeout(event interface{}, data interface{}, timeout time.Duration) error
• func Start(event interface{}) chan interface{}
• func Stop(event interface{}, outputChan chan interface{}) error
• func StopAll(event string)

Constants

const EventNotFound = "Event not found"

Functions

func Post

func Post(event interface{}, data interface{}) error

Post a notification (arbitrary data) to the specified event

func PostTimeout

func PostTimeout(event interface{}, data interface{}, timeout time.Duration) error

Post a notification to the specified event using the provided timeout for any output channels that are blocking

func Start

func Start(event interface{}) chan interface{}

func Stop

func Stop(event interface{}, outputChan chan interface{}) error

Stop observing the specified event on the provided output channel

func StopAll

func StopAll(event string)

Stop observing the specified event on all channels