queue

Documentation

Index

• Constants
• type Event
• type EventEmitter
• type EventListener
• type EventMapper
  • func NewEventMapper(mapperType MapperType) (EventMapper, error)
• type MapperType
• type StaticEventMapper
  • func (m *StaticEventMapper) MapEvent(eventName string, serialized interface{}) (Event, error)

Constants

const (
	EventNameHeader = "x-event-name"
)

Types

type Event

type Event interface {
	Name() string
}

type EventEmitter

type EventEmitter interface {
	Emit(Event) error
}

type EventListener

type EventListener interface {
	Listen(...string) (<-chan Event, <-chan error, error)
	EventMapper() EventMapper
}

type EventMapper

type EventMapper interface {
	MapEvent(eventName string, serialized interface{}) (Event, error)
}

func NewEventMapper

func NewEventMapper(mapperType MapperType) (EventMapper, error)

type MapperType

type MapperType int

const (
	StaticMapper MapperType = iota
)

type StaticEventMapper

type StaticEventMapper struct{}

func (*StaticEventMapper) MapEvent

func (m *StaticEventMapper) MapEvent(eventName string, serialized interface{}) (Event, error)