Documentation
¶
Index ¶
- Variables
- type AppContext
- type CoinFlow
- func (f *CoinFlow) AbnormalWallets(k string, n int)
- func (f *CoinFlow) GetFlow(k string) *AppContext
- func (f *CoinFlow) Grid(k string, n int)
- func (f *CoinFlow) In(k string, diff decimal.Decimal, name string, info *utils.AppInfo)
- func (f *CoinFlow) Out(k string, diff decimal.Decimal, burn decimal.Decimal, name string, ...)
- func (f *CoinFlow) Wallets(k string, n int)
- type Engine
- type StaticTable
- type TaskType
Constants ¶
This section is empty.
Variables ¶
View Source
var ( Timeout = 2 * 60 Interval = 1 Tries = 1 ChSize = 1024 Works = 8 )
View Source
var ( Flow = CoinFlow{ // contains filtered or unexported fields } )
Functions ¶
This section is empty.
Types ¶
type AppContext ¶
type CoinFlow ¶
type CoinFlow struct {
// contains filtered or unexported fields
}
func (*CoinFlow) AbnormalWallets ¶
func (*CoinFlow) GetFlow ¶
func (f *CoinFlow) GetFlow(k string) *AppContext
type Engine ¶
type Engine struct { // St means static table St StaticTable Wallets wallets.TRCWallets Provider provider.Providerer W utils.Writer RW utils.ReadWriter L *log.Logger Certs cert.Cert // seconds Timeout int // seconds Interval int Tries int Ch chan TaskType ExcepCount int64 // count and closed togather to occupy one cache line Count int64 Closed int64 // contains filtered or unexported fields }
type StaticTable ¶
Click to show internal directories.
Click to hide internal directories.