shared

Documentation

Index

• func NewEventMessage(aggregateID string, event interface{}, version *int, orderingKey string) ycq.EventMessage
• func NewPubsubEventBus(projectID, topic string) ycq.EventBus
• type AggregateDefinition
• type BaseGenericUnitOfWork
  • 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
• type Filter
• type GenericReadDB
• type GenericUnitOfWork
• type ItemFactory
• type Lease
• type LeasingService
• type Repository

Functions

func NewEventMessage

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

func NewPubsubEventBus

func NewPubsubEventBus(projectID, topic string) ycq.EventBus

Types

type AggregateDefinition

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

type BaseGenericUnitOfWork

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

func NewBaseGenericUnitOfWork

func NewBaseGenericUnitOfWork() *BaseGenericUnitOfWork

func (*BaseGenericUnitOfWork) AcceptAllChanges

func (uow *BaseGenericUnitOfWork) AcceptAllChanges()

func (*BaseGenericUnitOfWork) CommitAllChanges

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

func (*BaseGenericUnitOfWork) GetAggregateRepo

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

func (*BaseGenericUnitOfWork) Load

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

func (*BaseGenericUnitOfWork) Save

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

type EventMessage

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

type Filter

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

type GenericReadDB

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

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

type ItemFactory func() interface{}

type Lease

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

type LeasingService

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

type Repository

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