Versions in this module Expand all Collapse all v0 v0.19.9 Oct 25, 2021 Changes in this version + const DexSpotAccount + const DexSpotAllTicker3s + const DexSpotDepthBook + const DexSpotMatch + const DexSpotOrder + const DexSpotTicker + func GetDepthBookFromCache(product string) (depthBook pushservice.BookRes, ok bool) + func InitialCache(ctx sdk.Context, orderKeeper types.OrderKeeper, dexKeeper types.DexKeeper, ...) + func NewEngine(url string, logger log.Logger, cfg *appCfg.StreamConfig) (types.IStreamEngine, error) + func StartWSServer(logger log.Logger, endpoint string) + func UpdateDepthBookCache(product string, bookRes pushservice.BookRes) + type BaseOp struct + Args []string + Op string + type Conn struct + type Context struct + type Engine struct + func (engine *Engine) NewEvent(channel string, data interface{}) (sdk.Event, error) + func (engine *Engine) URL() string + func (engine *Engine) Write(data types.IStreamData, success *bool) + type ErrorResponse struct + ErrorCode int + Event string + Message string + func (r *ErrorResponse) Valid() bool + type EventResponse struct + Channel string + Event string + Success string + func (r *EventResponse) Valid() bool + type PushData struct + func NewPushData() *PushData + func (data *PushData) SetData(ctx sdk.Context, orderKeeper types.OrderKeeper, tokenKeeper types.TokenKeeper, ...) + func (data PushData) DataType() types.StreamDataKind + type SubscriptionTopic struct + Channel string + Filter string + func FormSubscriptionTopic(str string) *SubscriptionTopic + func (st *SubscriptionTopic) NeedLogin() bool + func (st *SubscriptionTopic) ToString() (topic string, err error) + type TableResponse struct + Action string + Data []interface{} + Table string + func (r *TableResponse) Valid() bool
Go to main page