event

Documentation

Index

• type AssetRegistered
  • func (a AssetRegistered) AggregateID() string
  • func (AssetRegistered) Name() string
• type Bus
• type DomainEvent
• type IntegrationEvent
  • func (i *IntegrationEvent) FromDomainEvent(e DomainEvent)

Types

type AssetRegistered

type AssetRegistered struct {
	TickerSymbol string  `json:"ticker_symbol"`
	SpreadPrice  float64 `json:"spread_price"`
}

func (AssetRegistered) AggregateID

func (a AssetRegistered) AggregateID() string

func (AssetRegistered) Name

func (AssetRegistered) Name() string

type Bus

type Bus interface {
	Publish(context.Context, ...DomainEvent) error
}

type DomainEvent

type DomainEvent interface {
	AggregateID() string
	Name() string
}

type IntegrationEvent

type IntegrationEvent struct {
	Id          string `json:"id"`
	Source      string `json:"source"`
	SpecVersion string `json:"specversion"`
	Type        string `json:"type"`

	// Optional region
	DataContentType string      `json:"datacontenttype,omitempty"`
	DataSchema      string      `json:"dataschema,omitempty"`
	Subject         string      `json:"subject,omitempty"`
	Time            time.Time   `json:"time,omitempty"`
	Data            interface{} `json:"data,omitempty"`
}

IntegrationEvent is a kind of event based on the CNCF CloudEvent specification used to propagate domain events to different modules and systems

func (*IntegrationEvent) FromDomainEvent

func (i *IntegrationEvent) FromDomainEvent(e DomainEvent)