shared

type AggregateDefinition struct {
	Constructor func(id string) ycq.AggregateRoot
	Type        reflect.Type
}

type BaseGenericUnitOfWork struct {
	Repos map[string]Repository
	sync.Mutex
}

type EventMessage interface {
	ycq.EventMessage
	OrderingKey() string
}

type Filter struct {
	Path  string
	Op    string
	Value interface{}
}

type GenericReadDB interface {
	SaveItem(transaction interface{}, id string, item interface{}) error
	LoadAllItems() ([]interface{}, error)
	LoadItem(id string) (interface{}, error)
	DeleteItem(transaction interface{}, id string) error
	UpdateItem(transaction interface{}, id string, updates interface{}) error
	ListItems(filter []Filter, limit int) ([]interface{}, error)
}

type GenericUnitOfWork interface {
	GetAggregateRepo(aggregateType reflect.Type) Repository
	Load(typ reflect.Type, aggregateID string) (ycq.AggregateRoot, error)
	Save(aggregate ycq.AggregateRoot, expectedVersion *int) error
	CommitAllChanges(ctx context.Context, transaction interface{}) error
	AcceptAllChanges()
}

type ItemFactory func() interface{}

type Lease interface {
	Lock() (bool, error)
	Release() (bool, error)
}

type LeasingService interface {
	GetLease(resourceID string, duration time.Duration) (Lease, error)
}

type Repository interface {
	Load(id string) (ycq.AggregateRoot, error)
	Save(aggregate ycq.AggregateRoot, expectedVersion *int) error
	CommitChanges(ctx context.Context, transaction interface{}) error
	AcceptChanges()
}