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 EngineAnalysisKind + const EngineKlineKind + const EngineNilKind + const EngineNotifyKind + const EngineWebSocketKind + const ModuleName + const QuerierRoute + const RouterKey + const StreamKafkaKind + const StreamMysqlKind + const StreamNilKind + const StreamPulsarKind + const StreamRedisKind + const StreamWebSocketKind + var EngineKind2StreamKindMap = map[EngineKind]Kind + var StreamKind2EngineKindMap = map[Kind]EngineKind + var TaskConstDesc = map[TaskConst]string + func BeginBlocker(ctx sdk.Context, keeper Keeper) + func CreateGenAccounts(numAccs int, genCoins sdk.Coins) (addrKeysSlice mock.AddrKeysSlice, genAccs []auth.Account) + func EndBlocker(ctx sdk.Context, k Keeper) + func MockApplyBlock(app *MockApp, blockHeight int64, txs []auth.StdTx) + func NewKafkaEngine(url string, logger log.Logger, cfg *appCfg.StreamConfig) (types.IStreamEngine, error) + func NewMySQLEngine(url string, log log.Logger, cfg *appCfg.StreamConfig) (types.IStreamEngine, error) + func NewPulsarEngine(url string, logger log.Logger, cfg *appCfg.StreamConfig) (types.IStreamEngine, error) + func NewRedisEngine(url string, logger log.Logger, cfg *appCfg.StreamConfig) (types.IStreamEngine, error) + func ParseStreamEngineConfig(logger log.Logger, cfg *appCfg.StreamConfig) (map[EngineKind]types.IStreamEngine, error) + func ProduceOrderTxs(app *MockApp, ctx sdk.Context, numToGenerate int, addrKeys mock.AddrKeys, ...) []auth.StdTx + type AppModule struct + func NewAppModule(k Keeper) AppModule + func (AppModule) Name() string + func (am AppModule) BeginBlock(ctx sdk.Context, _ abci.RequestBeginBlock) + func (am AppModule) EndBlock(ctx sdk.Context, _ abci.RequestEndBlock) []abci.ValidatorUpdate + func (am AppModule) ExportGenesis(ctx sdk.Context) json.RawMessage + func (am AppModule) InitGenesis(ctx sdk.Context, data json.RawMessage) []abci.ValidatorUpdate + func (am AppModule) NewHandler() sdk.Handler + func (am AppModule) NewQuerierHandler() sdk.Querier + func (am AppModule) QuerierRoute() string + func (am AppModule) RegisterInvariants(ir sdk.InvariantRegistry) + func (am AppModule) Route() string + type AppModuleBasic struct + func (AppModuleBasic) DefaultGenesis() json.RawMessage + func (AppModuleBasic) GetQueryCmd(cdc *codec.Codec) *cobra.Command + func (AppModuleBasic) GetTxCmd(cdc *codec.Codec) *cobra.Command + func (AppModuleBasic) Name() string + func (AppModuleBasic) RegisterCodec(cdc *codec.Codec) + func (AppModuleBasic) RegisterRESTRoutes(ctx context.CLIContext, rtr *mux.Router) + func (AppModuleBasic) ValidateGenesis(bz json.RawMessage) error + type AtomTaskResult struct + type AtomTaskRunner struct + type BaseMarketKeeper struct + type CacheQueue struct + func (cq *CacheQueue) Enqueue(sc Context) + func (cq *CacheQueue) Start() + type Context struct + type Coordinator struct + func NewCoordinator(logger log.Logger, taskCh chan *TaskWithData, resultCh chan Task, timeout int, ...) *Coordinator + type DexKeeper = types.DexKeeper + type EngineCreator func(url string, logger log.Logger, cfg *appCfg.StreamConfig) (types.IStreamEngine, error) + func GetEngineCreator(eKind EngineKind, sKind Kind) (EngineCreator, error) + type EngineKind byte + func StringToEngineKind(kind string) EngineKind + type KafkaEngine struct + func (ke *KafkaEngine) URL() string + func (ke *KafkaEngine) Write(data types.IStreamData, success *bool) + type Keeper struct + func NewKeeper(orderKeeper types.OrderKeeper, tokenKeeper types.TokenKeeper, ...) Keeper + func (k Keeper) AnalysisEnable() bool + func (k Keeper) GetMarketKeeper() MarketKeeper + func (k Keeper) OnAccountUpdated(acc auth.Account) + func (k Keeper) OnAddNewTokenPair(ctx sdk.Context, tokenPair *dex.TokenPair) + func (k Keeper) OnFarmClaim(ctx sdk.Context, address sdk.AccAddress, poolName string, ...) + func (k Keeper) OnSwapCreateExchange(ctx sdk.Context, swapTokenPair ammswap.SwapTokenPair) + func (k Keeper) OnSwapToken(ctx sdk.Context, address sdk.AccAddress, swapTokenPair ammswap.SwapTokenPair, ...) + func (k Keeper) OnTokenPairUpdated(ctx sdk.Context) + func (k Keeper) SyncTx(ctx sdk.Context, tx *auth.StdTx, txHash string, timestamp int64) + type Kind byte + func StringToStreamKind(kind string) Kind + type MarketKeeper backend.MarketKeeper + type MockApp struct + BankKeeper bank.Keeper + DexKeeper dex.Keeper + OrderKeeper keeper.Keeper + TokenKeeper token.Keeper + func GetMockApp(t *testing.T, numGenAccs int, cfg *appCfg.Config) (mockApp *MockApp, addrKeysSlice mock.AddrKeysSlice) + type MySQLEngine struct + func (e *MySQLEngine) URL() string + func (e *MySQLEngine) Write(data types.IStreamData, success *bool) + type PulsarEngine struct + func (e *PulsarEngine) URL() string + func (e *PulsarEngine) Write(data types.IStreamData, success *bool) + type RedisEngine struct + func (e *RedisEngine) URL() string + func (e *RedisEngine) Write(data types.IStreamData, success *bool) + type RedisMarketKeeper struct + func NewRedisMarketKeeper(client *conn.Client, logger log.Logger) *RedisMarketKeeper + func (k *RedisMarketKeeper) GetKlineByProductID(productID uint64, granularity, size int) ([][]string, error) + func (k *RedisMarketKeeper) GetTickerByProducts(products []string) ([]map[string]string, error) + type Stream struct + AnalysisEnable bool + Cache *common.Cache + func NewStream(orderKeeper types.OrderKeeper, tokenKeeper types.TokenKeeper, ...) *Stream + type Task struct + DoneMap map[Kind]bool + Height int64 + UpdatedAt int64 + func NewTask(blockHeight int64) *Task + func (t *Task) GetStatus() TaskConst + type TaskConst int + const TaskPhase1NextActionJumpNextBlock + const TaskPhase1NextActionNewTask + const TaskPhase1NextActionRestart + const TaskPhase1NextActionReturnTask + const TaskPhase1NextActionUnknown + const TaskPhase2NextActionJumpNextBlock + const TaskPhase2NextActionRestart + const TaskStatusInvalid + const TaskStatusPartialSuccess + const TaskStatusStatusFail + const TaskStatusSuccess + type TaskWithData struct
Go to main page