events

Documentation

Index

• func Send(topic string, message *Message)
• func Start()
• func StartFileWatch()
• func Stop()
• func StopFileWatch()
• type Handle
  • func Listen(topic string, listener Listener) *Handle
  • func (handle *Handle) Close()
• type Listener
• type Message

Functions

func Send

func Send(topic string, message *Message)

func Start

func Start()

func StartFileWatch

func StartFileWatch()

only do this once

func Stop

func Stop()

func StopFileWatch

func StopFileWatch()

Types

type Handle

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

func Listen

func Listen(topic string, listener Listener) *Handle

func (*Handle) Close

func (handle *Handle) Close()

type Listener

type Listener func(message *Message)

type Message

type Message map[string]interface{}