event

type DefaultDomainEvent struct {
	EventID     string     `json:"-"`
	AggregateID string     `json:"aggregateId"`
	When        *time.Time `json:"-"`
	Type        string     `json:"-"`
}

type DomainEvent interface {
	GetEventID() string
	GetAggregateID() string
	GetWhen() *time.Time
	GetType() string
}

type Options struct {
	Source   string
	Exchange string
}

type Publisher interface {
	Publish(interface{}) error
}

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