event

Mar 19, 2021

Changes in this version

+ const ID

+ const RoutingKey

+ const Source

+ const Timestamp

+ const Type

+ type DefaultDomainEvent struct

+ AggregateID string

+ EventID string

+ Type string

+ When *time.Time

+ func (d *DefaultDomainEvent) GetAggregateID() string

+ func (d *DefaultDomainEvent) GetEventID() string

+ func (d *DefaultDomainEvent) GetType() string

+ func (d *DefaultDomainEvent) GetWhen() *time.Time

+ type DomainEvent interface

+ GetAggregateID func() string

+ GetEventID func() string

+ GetType func() string

+ GetWhen func() *time.Time

+ type Options struct

+ Exchange string

+ Source string

+ func NewOptions(v *viper.Viper) (*Options, error)

+ type Publisher interface

+ Publish func(interface{}) error

+ func NewEventPublisher(log logger.LogInfoFormat, c xrabbit.Client, options *Options) Publisher

+ type RabbitEventPublisher struct

+ func (r *RabbitEventPublisher) Publish(event interface{}) error