eventsource

KO | EN

gitlite — search

#python #react #typescript #go #android #machine-learning #deep-learning #macos #windows #kubernetes #pytorch #security #mcp #openai

(★ 18)

library to simplify tasks around event sourcing with golang

eventsource Latest Version Download

Download Latest Version (.zip)

// repository documentation

Was this content helpful?

★ 0 (0 ratings)

# event source

golang event sourcing library

## Installation

```
go get github.com/savaki/eventsource
```

## Example

```
package main

import (
	"context"
	"fmt"
	"log"
	"time"

"github.com/savaki/eventsource"
)

// UserCreated defines a user creation event
type UserCreated struct {
	eventsource.Model
}

// UserFirstSet defines an event by simple struct embedding
type UserNameSet struct {
	eventsource.Model
	Name string
}

// UserLastSet implements the eventsource.Event interface directly
type UserEmailSet struct {
	ID      string
	Version int
	At      time.Time
	Email   string
}

func (m UserEmailSet) AggregateID() string {
	return m.ID
}

func (m UserEmailSet) EventVersion() int {
	return m.Version
}

func (m UserEmailSet) EventAt() time.Time {
	return m.At
}

type User struct { 
	ID      string
	Version int
	Name    string
	Email   string
}

func (item *User) On(event eventsource.Event) bool {
	switch v := event.(type) {
	case *UserCreated:
		item.Version = v.Model.Version
		item.ID = v.Model.ID

case *UserNameSet:
		item.Version = v.Model.Version
		item.Name = v.Name

case *UserEmailSet:
		item.Version = v.Version
		item.Email = v.Email

default:
		return false
	}

return true
}

func main() {
	userEvents := eventsource.New(&User{})
	err := userEvents.Bind(
		UserCreated{},
		UserNameSet{},
		UserEmailSet{},
	)
	if err != nil {
		log.Fatalln(err)
	}

id := "123"
	setNameEvent := &UserNameSet{
		Model: eventsource.Model{ID: id, Version: 1},
		Name:  "Joe Public",
	}
	setEmailEvent := &UserEmailSet{
		ID:      id,
		Version: 2,
		Email:   "joe.public@example.com",
	}

ctx := context.Background()
	err = userEvents.Save(ctx, setEmailEvent, setNameEvent)
	if err != nil {
		log.Fatalln(err)
	}

v, err := userEvents.Load(ctx, id)
	if err != nil {
		log.Fatalln(err)
	}

user := v.(*User)
	fmt.Printf("Hello %v %v\n", user.Name, user.Email) // prints "Hello Joe Public joe.public@example.com"
}
```

eventsource

eventsource Latest Version Download

Today's picks

Was this content helpful?

Recent Feedback

eventsource

eventsource Latest Version Download

Today's picks

Was this content helpful?

Recent Feedback

Download README