mongo

type AggregateDB struct {
	ID      string    `bson:"_id"`
	Version int       `bson:"version"`
	Events  []EventDB `bson:"events"`
}

type Client struct {
	// contains filtered or unexported fields
}

type EventDB struct {
	Type        string   `bson:"event_type"`
	AggregateID string   `bson:"_id"`
	RawData     bson.Raw `bson:"data,omitempty"`

	Timestamp     time.Time `bson:"timestamp"`
	AggregateType string    `bson:"aggregate_type"`
	Version       int       `bson:"version"`
	// contains filtered or unexported fields
}