Versions in this module Expand all Collapse all v0 v0.7.0 Jul 23, 2026 Changes in this version + const ServiceName + const TopicOrderCreated + var ItemPriceEndPnt = "/v1/inventory/item/price" + var ItemPurchaseEndPnt = "/v1/inventory/items/purchase" + var ItemsEndPnt = "/v1/inventory/items" + var ItemsPriceEndPnt = "/v1/inventory/items/price" + var KeyParam = "/:key" + var OrdersEndPnt = "/v1/orders" + type Option func(*OutboxRelayer) + func WithBatchSize(n int) Option + func WithPollInterval(d time.Duration) Option + type OutboxRelayer struct + func NewOutboxRelayer(store database.OutboxStore, publisher messaging.Publisher, opts ...Option) *OutboxRelayer + func (o *OutboxRelayer) Ping(ctx context.Context) error + func (o *OutboxRelayer) Start(startCtx context.Context) error + func (o *OutboxRelayer) Stop() error + type Relayer interface + Ping func(ctx context.Context) error + Start func(ctx context.Context) error + Stop func() error + type Service struct + func NewService(db store, relayer Relayer, authn auth.Authenticator) *Service + func (h *Service) AddItems() httprouter.Handle + func (h *Service) ItemPrice() httprouter.Handle + func (h *Service) ItemsPrice() httprouter.Handle + func (h *Service) ListItems() httprouter.Handle + func (h *Service) Orders() httprouter.Handle + func (h *Service) PurchaseItems() httprouter.Handle + func (h *Service) RegisterHandlers() *httprouter.Router + func (h *Service) Start(ctx context.Context) error + func (h *Service) Stop() error
Go to main page