eventbus

Documentation

Index

• type BaseEvent
  • func NewBaseEvent(aggregateID string) BaseEvent
  • func (e *BaseEvent) IsNotValid() bool
• type Body
• type Bus
• type Event
• type Handler
• type Type

Types

type BaseEvent

type BaseEvent struct {
	EventID     string
	AggregateID string
	OccurredOn  time.Time
}

func NewBaseEvent

func NewBaseEvent(aggregateID string) BaseEvent

func (*BaseEvent) IsNotValid

func (e *BaseEvent) IsNotValid() bool

type Body

type Body []byte

Type represents a domain event type.

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(context.Context, Type, Handler)
}

Bus defines the expected behaviour from an event bus.

type Event

type Event interface {
	Type() Type
}

Event represents a domain command.

type Handler

type Handler interface {
	Handle([]byte) bool
}

type Type

type Type string

Type represents a domain event type.