event

Documentation

Index

• type BaseEvent
  • func NewBaseEvent(aggregateID string) BaseEvent
  • func (receiver BaseEvent) AggregateID() string
  • func (receiver BaseEvent) ID() string
  • func (receiver BaseEvent) OccurredOn() time.Time
• type Bus
• type Event
• type Handler
• type Type

Types

type BaseEvent

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

func NewBaseEvent

func NewBaseEvent(aggregateID string) BaseEvent

func (BaseEvent) AggregateID

func (receiver BaseEvent) AggregateID() string

func (BaseEvent) ID

func (receiver BaseEvent) ID() string

func (BaseEvent) OccurredOn

func (receiver BaseEvent) OccurredOn() time.Time

type Bus

type Bus interface {
	Publish([]Event) error
	Subscribe(Type, Handler)
}

type Event

type Event interface {
	ID() string
	AggregateID() string
	OccurredOn() time.Time
	Type() Type
}

type Handler

type Handler interface {
	Handle(Event) error
}

type Type

type Type string