domain

Documentation

Index

• type Aggregate
  • func ExistingAggregate(id rid.Id, version int32, createdAt time.Time, updatedAt time.Time, ...) *Aggregate
  • func NewAggregate(id rid.Id) *Aggregate
  • func (a *Aggregate) AddEvent(e Event)
  • func (a *Aggregate) CreatedAt() time.Time
  • func (a *Aggregate) DeletedAt() *time.Time
  • func (a *Aggregate) Events() []Event
  • func (a *Aggregate) ID() string
  • func (a *Aggregate) IsDeleted() bool
  • func (a *Aggregate) PullEvents() []Event
  • func (a *Aggregate) SoftDelete()
  • func (a *Aggregate) Touch()
  • func (a *Aggregate) UpdatedAt() time.Time
  • func (a *Aggregate) Version() int32
• type Bus
• type Command
• type Domain
• type Event
• type Query
• type Repository
• type ValueObject

Types

type Aggregate

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

func ExistingAggregate

func ExistingAggregate(id rid.Id, version int32, createdAt time.Time, updatedAt time.Time, deletedAt *time.Time, events []Event) *Aggregate

func NewAggregate

func NewAggregate(id rid.Id) *Aggregate

func (*Aggregate) AddEvent

func (a *Aggregate) AddEvent(e Event)

func (*Aggregate) CreatedAt

func (a *Aggregate) CreatedAt() time.Time

func (*Aggregate) DeletedAt

func (a *Aggregate) DeletedAt() *time.Time

func (*Aggregate) Events

func (a *Aggregate) Events() []Event

func (*Aggregate) ID

func (a *Aggregate) ID() string

func (*Aggregate) IsDeleted

func (a *Aggregate) IsDeleted() bool

func (*Aggregate) PullEvents

func (a *Aggregate) PullEvents() []Event

func (*Aggregate) SoftDelete

func (a *Aggregate) SoftDelete()

func (*Aggregate) Touch

func (a *Aggregate) Touch()

func (*Aggregate) UpdatedAt

func (a *Aggregate) UpdatedAt() time.Time

func (*Aggregate) Version

func (a *Aggregate) Version() int32

type Bus

type Bus interface {
	Publish(subject string, data any) error
	Subscribe(subject, durable, queue string, handler func(ctx context.Context, data any) error) error
	EnsureStream(name string, subjects ...string) error
	Close() error
}

type Command

type Command interface {
	CommandName() string
	Validate() error
}

type Domain

type Domain[T any, P any] interface {
	New(param P) (*T, error)
	Existing(param P) (*T, error)
}

type Event

type Event interface {
	EventName() string
	OccurredAt() time.Time
}

type Query

type Query interface {
	QueryName() string
}

type Repository

type Repository[T any] interface {
	Save(entity T) error
	GetByID(id string) (T, error)
	Delete(id string) error
	List() ([]T, error)
}

type ValueObject

type ValueObject interface {
	Equals(other ValueObject) bool
}

ValueObject is a marker interface for DDD value objects