Versions in this module Expand all Collapse all v1 v1.1.1 Jul 10, 2025 v1.1.0 Jul 10, 2025 Changes in this version + const ModuleName + var ErrInvalidStreamingRequest = errorsmod.Register(ModuleName, 2, "Invalid full node streaming request") + var ErrInvalidSubaccountFilteringRequest = errorsmod.Register(ModuleName, 3, "Invalid subaccount ID filtering request") + var ErrNotImplemented = errorsmod.Register(ModuleName, 1, "Not implemented") + type FullNodeStreamingManager interface + Enabled func() bool + GetPriceSnapshotsForInitStreams func(getPriceSnapshot func(marketId uint32) *pricestypes.StreamPriceUpdate) map[uint32]*pricestypes.StreamPriceUpdate + GetStagedFinalizeBlockEvents func(ctx sdk.Context) []clobtypes.StagedFinalizeBlockEvent + GetSubaccountSnapshotsForInitStreams func(...) map[satypes.SubaccountId]*satypes.StreamSubaccountUpdate + InitializeNewStreams func(...) + SendOrderbookFillUpdate func(orderbookFill clobtypes.StreamOrderbookFill, ctx sdk.Context, ...) + SendOrderbookUpdates func(offchainUpdates *clobtypes.OffchainUpdates, ctx sdk.Context) + SendPriceUpdate func(ctx sdk.Context, priceUpdate pricestypes.StreamPriceUpdate) + SendSubaccountUpdate func(ctx sdk.Context, subaccountUpdate satypes.StreamSubaccountUpdate) + SendTakerOrderStatus func(takerOrder clobtypes.StreamTakerOrder, ctx sdk.Context) + Stop func() + StreamBatchUpdatesAfterFinalizeBlock func(ctx sdk.Context, ...) + Subscribe func(clobPairIds []uint32, subaccountIds []*satypes.SubaccountId, ...) (err error) + TracksMarketId func(marketId uint32) bool + TracksSubaccountId func(id satypes.SubaccountId) bool + type OutgoingMessageSender interface + Send func(*clobtypes.StreamOrderbookUpdatesResponse) error
Go to main page