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 {
	MEventID     string
	MAggregateID string
	MOccurredOn  time.Time
}

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 is the method used to publish new events.
	Publish(context.Context, []Event) error
	// Subscribe is the method used to subscribe new event handlers.
	Subscribe(Type, Handler)
	Close() error
}

Bus defines the expected behaviour from an event bus.

type Event

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

Event represents a domain command.

type Handler

type Handler interface {
	Handle(context.Context, Event) error
}

Handler defines the expected behaviour from an event handler.

type Type

type Type string

Type represents a domain event type.