events

Documentation

Index

• type EventHandler
• type EventManager
  • func NewEventManager() *EventManager
  • func (e *EventManager) Publish(emsg EventMessage)
  • func (e *EventManager) StartListening(ctx context.Context, handler EventHandler, serviceName string, ...)
  • func (e *EventManager) Subscribe(name string) (uuid.UUID, <-chan EventMessage)
  • func (e *EventManager) Unsubscribe(id uuid.UUID, name string)
• type EventMessage

Types

type EventHandler

type EventHandler interface {
	HandleEvent(context.Context, EventMessage)
}

type EventManager

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

func NewEventManager

func NewEventManager() *EventManager

func (*EventManager) Publish

func (e *EventManager) Publish(emsg EventMessage)

func (*EventManager) StartListening

func (e *EventManager) StartListening(ctx context.Context, handler EventHandler, serviceName string, onSubscribe func())

func (*EventManager) Subscribe

func (e *EventManager) Subscribe(name string) (uuid.UUID, <-chan EventMessage)

func (*EventManager) Unsubscribe

func (e *EventManager) Unsubscribe(id uuid.UUID, name string)

type EventMessage

type EventMessage struct {
	Type    string
	Payload interface{}
}