domain

Documentation

Index

• type DomainEvent
  • func NewDomainEvent(topic, processID, eventID, account string) *DomainEvent
  • func (e *DomainEvent) GetAccount() string
  • func (e *DomainEvent) GetEventID() string
  • func (e *DomainEvent) GetProcessID() string
  • func (e *DomainEvent) GetTopic() string
• type EventAG
  • func (eag *EventAG) ClearDomainEvents()
  • func (eag *EventAG) PullDomainEvents() []*DomainEvent
  • func (eag *EventAG) RecordDomainEvent(event *DomainEvent)
• type EventBus
• type IDomainEvent
• type Subscriber

Types

type DomainEvent

type DomainEvent struct {
	Topic     string `json:"topic"`
	ProcessID string `json:"processID"`
	EventID   string `json:"eventID"`
	Account   string `json:"account"`
}

nolint:revive // I want this to be called DomainEvent because it's a Domain Driven Design concept.

func NewDomainEvent

func NewDomainEvent(topic, processID, eventID, account string) *DomainEvent

func (*DomainEvent) GetAccount

func (e *DomainEvent) GetAccount() string

func (*DomainEvent) GetEventID

func (e *DomainEvent) GetEventID() string

func (*DomainEvent) GetProcessID

func (e *DomainEvent) GetProcessID() string

func (*DomainEvent) GetTopic

func (e *DomainEvent) GetTopic() string

type EventAG

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

func (*EventAG) ClearDomainEvents

func (eag *EventAG) ClearDomainEvents()

func (*EventAG) PullDomainEvents

func (eag *EventAG) PullDomainEvents() []*DomainEvent

func (*EventAG) RecordDomainEvent

func (eag *EventAG) RecordDomainEvent(event *DomainEvent)

type EventBus

type EventBus interface {
	Publish(...DomainEvent) error
}

type IDomainEvent

type IDomainEvent interface {
	GetTopic() string
	GetProcessID() string
	GetEventID() string
	GetAccount() string
}

type Subscriber

type Subscriber interface {
	Consume(event []byte)
}