msgqueue

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

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
}

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

type StaticEventMapper struct{}