event

Documentation

Index

• type BaseEvent
  • func NewBaseEvent(aggregateID string) BaseEvent
  • func (b BaseEvent) AggregateId() string
  • func (b BaseEvent) Id() string
  • func (b 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 (b BaseEvent) AggregateId() string

func (BaseEvent) Id

func (b BaseEvent) Id() string

func (BaseEvent) OccurredOn

func (b BaseEvent) OccurredOn() time.Time

type Bus

type Bus interface {
	Publish(context.Context, []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(context.Context, Event) error
}

type Type

type Type string