event

Documentation

Index

• Constants
• type DefaultDomainEvent
  • func (d *DefaultDomainEvent) GetAggregateID() string
  • func (d *DefaultDomainEvent) GetEventID() string
  • func (d *DefaultDomainEvent) GetType() string
  • func (d *DefaultDomainEvent) GetWhen() *time.Time
• type DomainEvent
• type Options
  • func NewOptions(v *viper.Viper) (*Options, error)
• type Publisher
  • func NewEventPublisher(log logger.LogInfoFormat, c xrabbit.Client, options *Options) Publisher
• type RabbitEventPublisher
  • func (r *RabbitEventPublisher) Publish(event interface{}) error

Constants

const (
	ID        = "x-fcyp-id"
	Timestamp = "x-fcyp-timestamp"
	Type      = "x-fcyp-type"
	Source    = "x-fcyp-source"

	RoutingKey = "#"
)

Types

type DefaultDomainEvent

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

func (*DefaultDomainEvent) GetAggregateID

func (d *DefaultDomainEvent) GetAggregateID() string

func (*DefaultDomainEvent) GetEventID

func (d *DefaultDomainEvent) GetEventID() string

func (*DefaultDomainEvent) GetType

func (d *DefaultDomainEvent) GetType() string

func (*DefaultDomainEvent) GetWhen

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

type DomainEvent

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

type Options

type Options struct {
	Source   string
	Exchange string
}

func NewOptions

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

type Publisher

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

func NewEventPublisher

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

type RabbitEventPublisher

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

func (*RabbitEventPublisher) Publish

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