models

type Aggregate struct {
	Id        string
	Type      string
	Version   int64
	Data      interface{}
	Events    []IEvent
	CreatedAt time.Time
	UpdatedAt time.Time
	// contains filtered or unexported fields
}

type AppConfig struct {
	EventSourcing *EventSourcingConfig `json:"event-sourcing"`
}

type Event struct {
	Id        ulid.ULID
	Name      string
	Data      interface{}
	CreatedAt time.Time
}

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

type EventSourcingConfig struct {
	Db        manager.DBConfig         `json:"db"`
	Migration services.MigrationConfig `json:"migration"`
	Log       struct {
		Level string `json:"level"`
	} `json:"log"`
}

type EventSourcingOption func(es *EventSourcing)

type EventsType map[string]func(*Aggregate, IEvent) error

type IEvent interface {
	GetId() ulid.ULID
	GetName() string
	GetData() interface{}
	GetCreatedAt() time.Time
}

type IStorage interface {
	GetAggregate(id, typ string, obj interface{}) (aggregate *Aggregate, err error)
	StoreAggregate(aggregate *Aggregate) (err error)
}

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