ordermanagement

Nov 22, 2023

Changes in this version

type OrderCache

+ func NewOwnerOrderCache(ctx context.Context, ownerId string, store orderStore) (*OrderCache, error)

+ type OrderStream interface

+ Chan func() <-chan *model.Order

+ Close func()

Oct 13, 2020

Changes in this version

+ func GetChildOrders(id string, kafkaReaderConfig kafka.ReaderConfig, bufferSize int) (<-chan ChildOrder, error)

+ func NewChildOrderUpdatesDistributor(updates <-chan ChildOrder) *childOrderUpdatesDistributor

+ type ChildOrder struct

+ Child *model.Order

+ ParentOrderId string

+ type ChildOrderStream interface

+ Close func()

+ GetStream func() <-chan *model.Order

+ type OrderCache struct

+ func NewOrderCache(store orderstore.OrderStore, ownerId string) (*OrderCache, error)

+ func (oc *OrderCache) Close()

+ func (oc *OrderCache) GetOrder(orderId string) (*model.Order, bool, error)

+ func (oc *OrderCache) Store(order *model.Order) error

+ type ParentOrder struct

+ ChildOrders map[string]*model.Order

+ func NewParentOrder(order model.Order) *ParentOrder

+ func (po *ParentOrder) OnChildOrderUpdate(childOrder *model.Order) (bool, error)