msgqueue

package

v1.0.1 Latest Latest Go to latest Published: Nov 30, 2020 License: MIT Imports: 5 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func (e *DynamicEventMapper) MapEvent(eventName string, serialized interface{}) (Event, error)

func (e *DynamicEventMapper) RegisterMapping(eventType reflect.Type) error

type Event interface {
	// PartitionKey() string
	EventName() string
}

type EventEmitter interface {
	Emit(event Event) error
}

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

EventListener describes an interface for a class that can listen to events.

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

func NewDynamicEventMapper() EventMapper

func NewEventMapper() EventMapper

type StaticEventMapper struct{}

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