crawl

Documentation

Index

• Variables
• func GrpcClientSend(arrMql5 []*Mql5)
• func SpInit()
• func WriteUDP(m *Mql5, tt *time.Time)
• type Config
• type Mql5

Variables

var (
	TimeLocLondon     *time.Location //用于伦敦夏令时
	GrpcErrCount      *uint64        //grpc出错数
	SymbolUpdateCount *uint64        // 交易对更新次数

	ChanPageReload = make(chan bool, 1000) //用于统计 完成采集有效次数（每页）
	Re             *regexp.Regexp          //匹配mql5
	Conf           Config
)

var SyncMap *sync.Map //缓存最新 mql5结构的数据

Functions

func GrpcClientSend

func GrpcClientSend(arrMql5 []*Mql5)

func SpInit

func SpInit()

func WriteUDP

func WriteUDP(m *Mql5, tt *time.Time)

Types

type Config

type Config struct {
	Config struct {
		Datahost      string        `yaml:"datahost"`
		GrpgServerArr []string      `yaml:"grpgServerArr"`
		Database      string        `yaml:"database"`
		PageRefresh   time.Duration `yaml:"pageRefresh"`
	}
}

type Mql5

type Mql5 struct {
	Type     string
	Symbol   string
	Title    string
	Bid      float64
	Ask      float64
	UnixNano int64
	TimeStr  string
}