domain

Documentation

Index

• type Aggregate
• type BaseAggregate
  • func (agg *BaseAggregate) GetID() uuid.UUID
  • func (agg *BaseAggregate) IncrementVersion()
  • func (agg *BaseAggregate) UpdateUpdatedAt(t time.Time)
• type EventBus

Types

type Aggregate

type Aggregate interface {
	GetID() uuid.UUID
	IncrementVersion()
	UpdateUpdatedAt(time.Time)
	AggregateType() string
}

type BaseAggregate

type BaseAggregate struct {
	ID        uuid.UUID      `json:"id"`
	CreatedAt time.Time      `json:"created_at"`
	UpdatedAt time.Time      `json:"updated_at"`
	DeletedAt *time.Time     `json:"deleted_at"`
	Version   uint64         `json:"version"`
	Events    []events.Event `json:"events"`
}

func (*BaseAggregate) GetID

func (agg *BaseAggregate) GetID() uuid.UUID

func (*BaseAggregate) IncrementVersion

func (agg *BaseAggregate) IncrementVersion()

func (*BaseAggregate) UpdateUpdatedAt

func (agg *BaseAggregate) UpdateUpdatedAt(t time.Time)

type EventBus

type EventBus interface {
	Publish(event dao.Event) error
}