goddd

Sep 19, 2023

Changes in this version

+ const REMOVED_EVENT_NAME

type InMemoryRepository

+ func (r *InMemoryRepository[T]) Remove(ctx context.Context, objectID string, object T) error

type MongoRepository

+ func (r *MongoRepository[T]) Remove(ctx context.Context, objectID string, object T) error

type Repository

+ Remove func(ctx context.Context, objectID string, object T) error

Sep 14, 2023

Changes in this version

+ var InvalidUpdateCallback = errors.New("callback should return a non nil object if error is nil")

Aug 30, 2023

Changes in this version

+ var ConcurrencyError = errors.New("concurrency error while saving")

+ func MigrateMongoDB(mongoDB *mongo.Database, dir string) error

type InMemoryRepository

+ func (r *InMemoryRepository[T]) Update(ctx context.Context, objectID string, object T, nbRetries int, ...) (T, error)

type MongoRepository

+ func (r *MongoRepository[T]) Update(ctx context.Context, objectID string, object T, nbRetries int, ...) (T, error)

type Repository

+ Update func(ctx context.Context, objectID string, object T, nbRetries int, ...) (T, error)

Dec 1, 2022

Changes in this version

type EventStream

+ CollectUnsavedEvents func() []Event

type Stream

+ func (s *Stream) CollectUnsavedEvents() []Event

Nov 29, 2022

Changes in this version

type EventStream

+ UnsavedEvents func() []Event

type Stream

+ func (s *Stream) UnsavedEvents() []Event

Oct 21, 2022

Changes in this version

type Event

+ func Deserialize(message []byte) (Event, error)

+ func (event Event) Serialize() ([]byte, error)

type EventPublisher

+ func (p *EventPublisher) OnEvent(event Event)

type EventReceiver

+ func NewRemoteEventPublisher(queue services.QueueService, errChan chan<- error) EventReceiver

+ type RemoteEventListener struct

+ func NewRemoteEventListener(queue services.QueueService, receiver EventReceiver, errChan chan<- error) RemoteEventListener

+ func (r *RemoteEventListener) Listen()

+ type RemoteEventPublisher struct

+ func (r *RemoteEventPublisher) OnEvent(event Event)

Apr 23, 2022

Changes in this version

type DomainObjectMemento

+ SetVersion func(version int)

type EventStream

+ SetStreamVersion func(version int)

type MongoRepository

+ func (r *MongoRepository) ObjectEventsSinceVersion(objectID string, version int) ([]Event, error)

type Stream

+ func (s *Stream) SetStreamVersion(version int)

Apr 23, 2022

Changes in this version

+ type DomainObjectMemento interface

+ ApplyMemento func(payload []byte) error

+ DumpMemento func() (msgp.Marshaler, error)

Apr 11, 2022

Changes in this version

type Event

+ func ReloadEvent(eventID, objectID, eventName string, version int, payload []byte, ...) Event

Apr 11, 2022

Changes in this version

+ func Encode(object DomainObject) ([]byte, error)

type DomainObject

+ func Decode(data []byte) (*DomainObject, error)

type InMemoryRepository

+ func (r *InMemoryRepository) EventsSince(timestamp time.Time, limit int) ([]Event, error)

type MongoRepository

+ func (r *MongoRepository) EventsSince(timestamp time.Time, limit int) ([]Event, error)

type Repository

+ EventsSince func(time time.Time, limit int) ([]Event, error)

Aug 25, 2021

Changes in this version

type EventStream

+ Clear func()

type Stream

+ func (s *Stream) Clear()

Mar 1, 2021

Changes in this version

+ func NewIdentity(objectType string) string

+ type DomainObject interface

+ Apply func(eventName string, eventPayload []byte) error

+ ObjectID func() string

+ type Event struct

+ func NewEvent(objectID string, eventName string, version int, payload []byte) Event

+ func (event Event) Id() string

+ func (event Event) Name() string

+ func (event Event) ObjectId() string

+ func (event Event) Payload() []byte

+ func (event Event) Timestamp() int64

+ func (event Event) Version() int

+ type EventPublisher struct

+ Wait bool

+ func NewEventPublisher() EventPublisher

+ func (p *EventPublisher) Publish(events []Event)

+ func (p *EventPublisher) Register(receiver EventReceiver)

+ type EventReceiver interface

+ OnEvent func(event Event)

+ type EventStream interface

+ AddEvent func(object DomainObject, eventName string, payload proto.Message) error

+ ContainsEventWithId func(eventID string) bool

+ Events func() []Event

+ LastVersion func() int

+ LoadEvent func(object DomainObject, event Event) error

+ type ExentStoreRepository struct

+ func NewExentStoreRepository(endpoint string, publisher *EventPublisher) ExentStoreRepository

+ func (r *ExentStoreRepository) Exists(objectID string) (bool, error)

+ func (r *ExentStoreRepository) Load(objectID string, object DomainObject) error

+ func (r *ExentStoreRepository) Save(object DomainObject) error

+ type InMemoryRepository struct

+ func NewInMemoryRepository(publisher *EventPublisher) InMemoryRepository

+ func (r *InMemoryRepository) Exists(objectId string) (bool, error)

+ func (r *InMemoryRepository) Load(objectID string, object DomainObject) error

+ func (r *InMemoryRepository) Save(object DomainObject) error

+ type MongoRepository struct

+ func NewMongoRepository(database *mongo.Database, publisher *EventPublisher) MongoRepository

+ func (r *MongoRepository) Exists(objectId string) (bool, error)

+ func (r *MongoRepository) Load(objectID string, object DomainObject) error

+ func (r *MongoRepository) Save(object DomainObject) error

+ type Repository interface

+ Exists func(objectID string) (bool, error)

+ Load func(objectID string, object DomainObject) error

+ Save func(object DomainObject) error

+ type Stream struct

+ func NewEventStream() Stream

+ func (s *Stream) AddEvent(object DomainObject, eventName string, payload proto.Message) error

+ func (s *Stream) ContainsEventWithId(eventId string) bool

+ func (s *Stream) Events() []Event

+ func (s *Stream) LastVersion() int

+ func (s *Stream) LoadEvent(object DomainObject, event Event) error