NewAggregateBase AggregateBase constructor, contains all main fields and methods, main aggregate must realize When interface and pass as argument to constructor Example of recommended aggregate constructor method: func NewOrderAggregate() *OrderAggregate { orderAggregate := &OrderAggregate{ Order: models.NewOrder(), } base := es.NewAggregateBase(orderAggregate.When) base.SetType(OrderAggregateType) orderAggregate.AggregateBase = base return orderAggregate}.

NewBaseEvent new base Event constructor with configured EventID, Aggregate properties and Timestamp.

NewKafkaEventsBus kafkaEventsBus constructor.

AggregateBase base aggregate contains all main necessary fields.

Event is an internal representation of an event, returned when the Aggregate uses NewEvent to create a new event.

KafkaEventsBusConfig kafka eventbus config.

AggregateRoot contains all methods of AggregateBase.

Apply process Aggregate Event.

Load create Aggregate state from Event's.

RaiseEvent process applied Aggregate Event from event store.

AggregateType type of the Aggregate.

EventType is the type of any event, used as its unique identifier.