rabbit

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

type RawVersionedEvent struct {
	ID         string          `bson:"aggregate_id,omitempty"`
	Version    int             `bson:"version"`
	Type       string          `bson:"type"`
	Payload    json.RawMessage `bson:"payload"`
	RecordedOn time.Time       `bson:"recorded_on"`
}