event_publisher

Documentation

Index

• type EventPublisher
  • func New() *EventPublisher
  • func StartUp() (*EventPublisher, error)
  • func (ep *EventPublisher) Publish(event string, payload []byte)
  • func (ep *EventPublisher) Subscribe(event string, cb func([]byte)) func()

Types

type EventPublisher

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

func New

func New() *EventPublisher

func StartUp

func StartUp() (*EventPublisher, error)

func (*EventPublisher) Publish

func (ep *EventPublisher) Publish(event string, payload []byte)

func (*EventPublisher) Subscribe

func (ep *EventPublisher) Subscribe(event string, cb func([]byte)) func()