types

Documentation

Index

• Constants
• type AccountKeeper
• type DexKeeper
• type EngineEnqueue
• type FarmKeeper
• type IDistributeStateService
• type IStreamData
• type IStreamDatas
  • 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
• type OrderKeeper
• type StreamDataKind
• type SwapKeeper
• type TokenKeeper

Constants

const (
	ModuleName   = "stream"
	QuerierRoute = ModuleName
	// RouterKey is the msg router key for the backend module
	RouterKey = ""
)

Types

type AccountKeeper

type AccountKeeper interface {
	SetObserverKeeper(observer auth.ObserverI)
}

type DexKeeper

type DexKeeper interface {
	GetTokenPairs(ctx sdk.Context) []*dex.TokenPair
	SetObserverKeeper(keeper dex.StreamKeeper)
}

type EngineEnqueue

type EngineEnqueue func(data IStreamData) bool

type FarmKeeper

type FarmKeeper interface {
	SetObserverKeeper(k farmtypes.BackendKeeper)
}

FarmKeeper expected farm keeper

type IDistributeStateService

type IDistributeStateService interface {
	GetLockerID() string
	GetDistState(stateKey string) (string, error)
	SetDistState(stateKey string, stateValue string) error
	FetchDistLock(lockKey string, locker string, expiredInMS int) (bool, error)
	ReleaseDistLock(lockKey string, locker string) (bool, error)
	UnlockDistLockWithState(lockKey string, locker string, stateKey string, stateValue string) (bool, error)
}

Distributed State Service Interface

type IStreamData

type IStreamData interface {
	BlockHeight() int64
	DataType() StreamDataKind
}

***********************************

type IStreamDatas

type IStreamDatas []IStreamData

func (IStreamDatas) Len

func (datas IStreamDatas) Len() int

nolint

func (IStreamDatas) Less

func (datas IStreamDatas) Less(i, j int) bool

func (IStreamDatas) Sort

func (datas IStreamDatas) Sort() IStreamDatas

Sort is a helper function to sort the set of IStreamDatas in-place.

func (IStreamDatas) Swap

func (datas IStreamDatas) Swap(i, j int)

type IStreamEngine

type IStreamEngine interface {
	URL() string
	Write(data IStreamData, success *bool)
}

***********************************

type OrderKeeper

type OrderKeeper interface {
	GetOrder(ctx sdk.Context, orderID string) *order.Order
	GetUpdatedOrderIDs() []string
	GetBlockOrderNum(ctx sdk.Context, blockHeight int64) int64
	GetBlockMatchResult() *order.BlockMatchResult
	GetLastPrice(ctx sdk.Context, product string) sdk.Dec
	GetBestBidAndAsk(ctx sdk.Context, product string) (sdk.Dec, sdk.Dec)
	GetUpdatedDepthbookKeys() []string
	GetDepthBookCopy(product string) *order.DepthBook
	GetProductPriceOrderIDs(key string) []string
	GetTxHandlerMsgResult() []bitset.BitSet
}

type StreamDataKind

type StreamDataKind byte

const (
	StreamDataNilKind       StreamDataKind = 0x00
	StreamDataAnalysisKind  StreamDataKind = 0x01
	StreamDataNotifyKind    StreamDataKind = 0x02
	StreamDataKlineKind     StreamDataKind = 0x03
	StreamDataWebSocketKind StreamDataKind = 0x04
)

type SwapKeeper

type SwapKeeper interface {
	SetObserverKeeper(k ammswaptypes.BackendKeeper)
	GetSwapTokenPairs(ctx sdk.Context) []ammswap.SwapTokenPair
}

SwapKeeper expected swap keeper

type TokenKeeper

type TokenKeeper interface {
	GetFeeDetailList() []*token.FeeDetail
	GetCoinsInfo(ctx sdk.Context, addr sdk.AccAddress) token.CoinsInfo
}