ordermanagement

package

v1.4.2 Latest Latest Go to latest Published: Nov 28, 2023 License: GPL-3.0 Imports: 7 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Types and functions to be used by services that manage orders.

This section is empty.

This section is empty.

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

GetChildOrders returns a channel of orders whose originator id matches the given order id and are thus children of the order.

func NewChildOrderUpdatesDistributor(updates <-chan ChildOrder, initialSubscriptionsBufferSize int) *childOrderUpdatesDistributor

type ChildOrder struct {
	ParentOrderId string
	Child         *model.Order
}

type OrderCache struct {
	// contains filtered or unexported fields
}

OrderCache is an in memory cache of the latest order state for a given owner backed by a persistent store.

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

func (oc *OrderCache) Close()

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

GetOrder returns the order and true if found, otherwise a nil value and false

func (oc *OrderCache) Store(ctx context.Context, order *model.Order) error

type OrderStream interface {
	Chan() <-chan *model.Order
	Close()
}

type ParentOrder struct {
	model.Order
	ChildOrders map[string]*model.Order
	// contains filtered or unexported fields
}

ParentOrder has a one-to-many relationship to its child orders. The parent order aggregates and summarises state across its children.

func NewParentOrder(order model.Order) *ParentOrder

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