package
0.0.0-20241209135706-2140920b6e7f
Repository: https://github.com/ajackti/go-kafka.git
Documentation: pkg.go.dev
# Packages
No description provided by the author
# Functions
No description provided by the author
No description provided by the author
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.
No description provided by the author
NewKafkaEventsBus kafkaEventsBus constructor.
# Structs
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.
No description provided by the author
KafkaEventsBusConfig kafka eventbus config.
# Interfaces
No description provided by the author
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.
No description provided by the author
# Type aliases
AggregateType type of the Aggregate.
EventType is the type of any event, used as its unique identifier.