eventmanager

README

Auttaja Events Manager

A super simple wrapper around NATS to enforce the CloudEvents message structure.

Documentation

Index

• type EventHandler
• type EventManager
  • func New(natsAddr string, app string) (*EventManager, error)
  • func (m *EventManager) Listen(subject string, cb EventHandler) error
  • func (m *EventManager) Publish(subject, t string, data interface{}) error

Types

type EventHandler

type EventHandler func(m *cloudevents.Event)

type EventManager

type EventManager struct {
	Broker *nats.Conn
	// contains filtered or unexported fields
}

func New

func New(natsAddr string, app string) (*EventManager, error)

func (*EventManager) Listen

func (m *EventManager) Listen(subject string, cb EventHandler) error

func (*EventManager) Publish

func (m *EventManager) Publish(subject, t string, data interface{}) error