shared

Feb 3, 2021

Changes in this version

+ type ItemFactory func() reflect.Type

+ type SliceFactory func() []reflect.Type

Feb 2, 2021

Changes in this version

+ func NewEventMessage(aggregateID string, event interface{}, version *int, orderingKey string) ycq.EventMessage

+ func NewPubsubEventBus(projectID, topic string) ycq.EventBus

+ type AggregateDefinition struct

+ Constructor func(id string) ycq.AggregateRoot

+ Type reflect.Type

+ type BaseGenericUnitOfWork struct

+ Repos map[string]Repository

+ func NewBaseGenericUnitOfWork() *BaseGenericUnitOfWork

+ func (uow *BaseGenericUnitOfWork) AcceptAllChanges()

+ func (uow *BaseGenericUnitOfWork) CommitAllChanges(ctx context.Context, transaction interface{}) error

+ func (uow *BaseGenericUnitOfWork) GetAggregateRepo(aggregateType reflect.Type) Repository

+ func (uow *BaseGenericUnitOfWork) Load(typ reflect.Type, aggregateID string) (ycq.AggregateRoot, error)

+ func (uow *BaseGenericUnitOfWork) Save(aggregate ycq.AggregateRoot, expectedVersion *int) error

+ type EventMessage interface

+ OrderingKey func() string

+ type Filter struct

+ Op string

+ Path string

+ Value interface{}

+ type GenericReadDB interface

+ DeleteItem func(transaction interface{}, id string) error

+ ListItems func(filter []Filter, limit int) (interface{}, error)

+ LoadAllItems func() (interface{}, error)

+ LoadItem func(id string) (interface{}, error)

+ SaveItem func(transaction interface{}, id string, item interface{}) error

+ UpdateItem func(transaction interface{}, id string, updates interface{}) error

+ type GenericUnitOfWork interface

+ AcceptAllChanges func()

+ CommitAllChanges func(ctx context.Context, transaction interface{}) error

+ GetAggregateRepo func(aggregateType reflect.Type) Repository

+ Load func(typ reflect.Type, aggregateID string) (ycq.AggregateRoot, error)

+ Save func(aggregate ycq.AggregateRoot, expectedVersion *int) error

+ type Lease interface

+ Lock func() (bool, error)

+ Release func() (bool, error)

+ type LeasingService interface

+ GetLease func(resourceID string, duration time.Duration) (Lease, error)

+ type Repository interface

+ AcceptChanges func()

+ CommitChanges func(ctx context.Context, transaction interface{}) error

+ Load func(id string) (ycq.AggregateRoot, error)

+ Save func(aggregate ycq.AggregateRoot, expectedVersion *int) error