Versions in this module Expand all Collapse all v0 v0.11.1 Mar 16, 2021 v0.10.1 Mar 16, 2021 Changes in this version + const ModuleName + const QuerierRoute + const RouterKey + type AccountKeeper interface + SetObserverKeeper func(observer auth.ObserverI) + type DexKeeper interface + GetTokenPairs func(ctx sdk.Context) []*dex.TokenPair + SetObserverKeeper func(keeper dex.StreamKeeper) + type EngineEnqueue func(data IStreamData) bool + type FarmKeeper interface + SetObserverKeeper func(k farmtypes.BackendKeeper) + type IDistributeStateService interface + FetchDistLock func(lockKey string, locker string, expiredInMS int) (bool, error) + GetDistState func(stateKey string) (string, error) + GetLockerID func() string + ReleaseDistLock func(lockKey string, locker string) (bool, error) + SetDistState func(stateKey string, stateValue string) error + UnlockDistLockWithState func(lockKey string, locker string, stateKey string, stateValue string) (bool, error) + type IStreamData interface + BlockHeight func() int64 + DataType func() StreamDataKind + type IStreamDatas []IStreamData + func (datas IStreamDatas) Len() int + func (datas IStreamDatas) Less(i, j int) bool + func (datas IStreamDatas) Sort() IStreamDatas + func (datas IStreamDatas) Swap(i, j int) + type IStreamEngine interface + URL func() string + Write func(data IStreamData, success *bool) + type OrderKeeper interface + GetBestBidAndAsk func(ctx sdk.Context, product string) (sdk.Dec, sdk.Dec) + GetBlockMatchResult func() *order.BlockMatchResult + GetBlockOrderNum func(ctx sdk.Context, blockHeight int64) int64 + GetDepthBookCopy func(product string) *order.DepthBook + GetLastPrice func(ctx sdk.Context, product string) sdk.Dec + GetOrder func(ctx sdk.Context, orderID string) *order.Order + GetProductPriceOrderIDs func(key string) []string + GetTxHandlerMsgResult func() []bitset.BitSet + GetUpdatedDepthbookKeys func() []string + GetUpdatedOrderIDs func() []string + type StreamDataKind byte + const StreamDataAnalysisKind + const StreamDataKlineKind + const StreamDataNilKind + const StreamDataNotifyKind + const StreamDataWebSocketKind + type SwapKeeper interface + GetSwapTokenPairs func(ctx sdk.Context) []ammswap.SwapTokenPair + SetObserverKeeper func(k ammswaptypes.BackendKeeper) + type TokenKeeper interface + GetCoinsInfo func(ctx sdk.Context, addr sdk.AccAddress) token.CoinsInfo + GetFeeDetailList func() []*token.FeeDetail
Go to main page