event

Documentation

Index

• func Publish(event *Event) error
• type Event
• type Subscriber
  • func Subscribe(topic string, handler func(e *Event)) (Subscriber, error)
  • func SubscribeAll(handler func(e *Event)) (Subscriber, error)

Functions

func Publish

func Publish(event *Event) error

Types

type Event

type Event struct {
	Topic   string      `json:"topic"`
	Status  string      `json:"status"`
	Data    interface{} `json:"data,omitempty"`
	Context interface{} `json:"context,omitempty"`
}

type Subscriber

type Subscriber interface {
	Unsubscribe()
}

func Subscribe

func Subscribe(topic string, handler func(e *Event)) (Subscriber, error)

func SubscribeAll

func SubscribeAll(handler func(e *Event)) (Subscriber, error)