Working with Aggregates

Now that we have our aggregate store, we can begin working with User aggregates in our application.

Create a new aggregate with New():

userID := uuid.Must(uuid.NewV4())

newUser := aggregateStore.New(userID, 0)

We’ll also append an event to change the User’s name to “Juliette”

_ = newUser.Append(UserNameChanged{NewName: "Juliette"})

Saving Aggregates

To save an aggregate, use Save():

_ = aggregateStore.Save(ctx, newUser, nil)

To load an aggregate, use Load():

loadedUser, _ := aggregateStore.Load(ctx, userID, nil)

The aggregate’s root entity can be accessed using .Entity():

user := loadedUser.Entity()

We can also see what version the aggregate is at (i.e. how many events have been applied to it):

fmt.Printf("user %s is at version %d", user.Name, loadedUser.Version())