analyservice

Documentation

Index

• func NewMysqlORM(url string) *backend.ORM
• type DataAnalysis
  • func NewDataAnalysis() *DataAnalysis
  • func (d *DataAnalysis) BlockHeight() int64
  • func (d *DataAnalysis) DataType() types.StreamDataKind
  • func (d *DataAnalysis) Empty() bool
  • func (d *DataAnalysis) SetData(ctx sdk.Context, orderKeeper types.OrderKeeper, tokenKeeper types.TokenKeeper, ...)

Functions

func NewMysqlORM

func NewMysqlORM(url string) *backend.ORM

Types

type DataAnalysis

type DataAnalysis struct {
	Height        int64                   `json:"height"`
	Deals         []*backend.Deal         `json:"deals"`
	FeeDetails    []*token.FeeDetail      `json:"fee_details"`
	NewOrders     []*backend.Order        `json:"new_orders"`
	UpdatedOrders []*backend.Order        `json:"updated_orders"`
	Trans         []*backend.Transaction  `json:"trans"`
	MatchResults  []*backend.MatchResult  `json:"match_results"`
	DepthBook     keeper.BookRes          `json:"depth_book"`
	AccStates     []token.AccountResponse `json:"account_states"`
	SwapInfos     []*backend.SwapInfo     `json:"swap_infos"`
	ClaimInfos    []*backend.ClaimInfo    `json:"swap_infos"`
}

the data enqueue to mysql

func NewDataAnalysis

func NewDataAnalysis() *DataAnalysis

func (*DataAnalysis) BlockHeight

func (d *DataAnalysis) BlockHeight() int64

func (*DataAnalysis) DataType

func (d *DataAnalysis) DataType() types.StreamDataKind

func (*DataAnalysis) Empty

func (d *DataAnalysis) Empty() bool

func (*DataAnalysis) SetData

func (d *DataAnalysis) SetData(ctx sdk.Context, orderKeeper types.OrderKeeper,
	tokenKeeper types.TokenKeeper, cache *common.Cache)

nolint