event

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

type Event struct {
	Topic       string
	Type        string
	Action      string
	EntityType  string
	EntityKeys  []string
	ResourceUrl string

	// This is only important event info, not the entire event payload
	// The entire event payload can be fetched from "ResourceUrl"
	Data any // TODO: maybe a struct array with EntityKey and data
}

type IPipeline interface {
	OnEvent(events []Event) //next func() []Event
}