market

package
v1.5.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 21, 2018 License: Apache-2.0 Imports: 27 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	OneHour  = "1Hr"
	TwoHour  = "2Hr"
	FourHour = "4Hr"
	OneDay   = "1Day"
	OneWeek  = "1Week"
)
View Source 
const GMCLock = "globalMarketZkLock"
View Source 
const GlobalMarketTickerKey = "GMTKPK"
View Source 
const GlobalTickerKey = "GTKPK"
View Source 
const GlobalTrendKey = "GTDPK"

Variables

This section is empty.

Functions

This section is empty.

Types

type BinanceTicker 

type BinanceTicker struct {
	Symbol    string `json:"symbol"`
	Change    string `json:"priceChangePercent"`
	Close     string `json:"prevClosePrice"`
	Open      string `json:"openPrice"`
	High      string `json:"highPrice"`
	Low       string `json:"lowPrice"`
	LastPrice string `json:"lastPrice"`
	Amount    string `json:"volume"`
	Vol       string `json:"quoteVolume"`
	Ask       string `json:"askPrice"`
	Bid       string `json:"bidPrice"`
}

type Cache 

type Cache struct {
	Trends []Trend
	Fills  []dao.FillEvent
}

type Collector 

type Collector interface {
	Start()
	// contains filtered or unexported methods
}

type CollectorImpl 

type CollectorImpl struct {
	// contains filtered or unexported fields
}

func NewCollector 

func NewCollector() *CollectorImpl

func (*CollectorImpl) GetTickers 

func (c *CollectorImpl) GetTickers(market string) ([]Ticker, error)

func (*CollectorImpl) Start 

func (c *CollectorImpl) Start()

type Exchange 

type Exchange interface {
	// contains filtered or unexported methods
}

type ExchangeImpl 

type ExchangeImpl struct {
	// contains filtered or unexported fields
}

func NewExchange 

func NewExchange(name, tickerUrl string) ExchangeImpl

type ExchangeType 

type ExchangeType string

type GlobalMarket 

type GlobalMarket struct {
	// contains filtered or unexported fields
}
var GM *GlobalMarket

func NewGlobalMarket 

func NewGlobalMarket(config MyTokenConfig) GlobalMarket

func (*GlobalMarket) GetGlobalMarketTicker 

func (g *GlobalMarket) GetGlobalMarketTicker(symbol string) (trend []GlobalMarketTicker, err error)

func (*GlobalMarket) GetGlobalMarketTickerCache 

func (g *GlobalMarket) GetGlobalMarketTickerCache(token string) (tickers map[string][]GlobalMarketTicker, err error)

func (*GlobalMarket) GetGlobalTicker 

func (g *GlobalMarket) GetGlobalTicker(token string) (ticker GlobalTicker, err error)

func (*GlobalMarket) GetGlobalTickerCache 

func (g *GlobalMarket) GetGlobalTickerCache(token string) (tickers map[string]GlobalTicker, err error)

func (*GlobalMarket) GetGlobalTrend 

func (g *GlobalMarket) GetGlobalTrend(token string) (trend []GlobalTrend, err error)

func (*GlobalMarket) GetGlobalTrendCache 

func (g *GlobalMarket) GetGlobalTrendCache(token string) (trends map[string][]GlobalTrend, err error)

func (*GlobalMarket) Sign 

func (g *GlobalMarket) Sign(param interface{}) (urlParam string, err error)

func (*GlobalMarket) Start 

func (g *GlobalMarket) Start()

type GlobalMarketTicker 

type GlobalMarketTicker struct {
	MarketName        string `json:"market_name"`
	Symbol            string `json:"symbol"`
	Anchor            string `json:"anchor"`
	Pair              string `json:"pair"`
	Price             string `json:"price"`
	PriceUsd          string `json:"price_usd"`
	PriceCny          string `json:"price_cny"`
	Volume24hUsd      string `json:"volume_24h_usd"`
	Volume24h         string `json:"volume_24h"`
	Volume24hFrom     string `json:"volume_24h_from"`
	PercentChangeUtc0 string `json:"percent_change_utc0"`
	Alias             string `json:"alias"`
}

type GlobalMarketTickerReq 

type GlobalMarketTickerReq struct {
	Anchor    string `json:"anchor"`
	NameId    string `json:"name_id"`
	Symbol    string `json:"symbol"`
	SortType  string `json:"sort_type"`
	SortField string `json:"sort_field"`
}

type GlobalMarketTickerResp 

type GlobalMarketTickerResp struct {
	MyTokenResp
	Data map[string][]GlobalMarketTicker `json:"data"`
}

type GlobalTicker 

type GlobalTicker struct {
	Symbol            string `json:"symbol"`
	Price             string `json:"price"`
	PriceUsd          string `json:"price_usd"`
	PriceCnyUtc0      string `json:"price_cny_utc0"`
	PriceCny          string `json:"price_cny"`
	Volume24hUsd      string `json:"volume_24h_usd"`
	Volume24h         string `json:"volume_24h"`
	Volume24hFrom     string `json:"volume_24h_from"`
	PercentChangeUtc0 string `json:"percent_change_utc0"`
	Alias             string `json:"alias"`
	PriceUpdatedAt    string `json:"price_updated_at"`
}

type GlobalTickerReq 

type GlobalTickerReq struct {
	NameId string `json:"name_id"`
}

type GlobalTickerResp 

type GlobalTickerResp struct {
	MyTokenResp
	Data GlobalTicker `json:"data"`
}

type GlobalTrend 

type GlobalTrend struct {
	Price      string `json:"price"`
	Time       string `json:"time"`
	VolumeFrom string `json:"volumefrom"`
}

type GlobalTrendReq 

type GlobalTrendReq struct {
	TrendAnchor string `json:"trend_anchor"`
	NameId      string `json:"name_id"`
	Limit       int64  `json:"limit"`
	Period      string `json:"period"`
}

type GlobalTrendResp 

type GlobalTrendResp struct {
	MyTokenResp
	Data map[string][]GlobalTrend `json:"data"`
}

type HuobiInnerTicker 

type HuobiInnerTicker struct {
	Close  float64   `json:"close"`
	Open   float64   `json:"open"`
	High   float64   `json:"high"`
	Low    float64   `json:"low"`
	Amount float64   `json:"amount"`
	Count  int       `json:"count"`
	Vol    float64   `json:"vol"`
	Ask    []float64 `json:"ask"`
	Bid    []float64 `json:"bid"`
}

type HuobiTicker 

type HuobiTicker struct {
	Timestamp int64            `json:"ts"`
	ErrorCode string           `json:"err-code"`
	Status    string           `json:"status"`
	Tick      HuobiInnerTicker `json:"tick"`
}

type MyTokenConfig 

type MyTokenConfig struct {
	AppId     string
	AppSecret string
	BaseUrl   string
}

type MyTokenResp 

type MyTokenResp struct {
	Code      int    `json:"code"`
	Message   string `json:"message"`
	Timestamp int64  `json:"timestamp"`
}

type OkexFullTicker 

type OkexFullTicker struct {
	Code int              `json:"code"`
	Data []OkexTickerElem `json:"data"`
	Msg  string           `json:"msg"`
}

type OkexInnerTicker 

type OkexInnerTicker struct {
	High      string `json:"high"`
	Low       string `json:"low"`
	LastPrice string `json:"last"`
	Vol       string `json:"vol"`
	Ask       string `json:"sell"`
	Bid       string `json:"buy"`
}

type OkexTicker 

type OkexTicker struct {
	Date   string          `json:"date"`
	Ticker OkexInnerTicker `json:"ticker"`
}

type OkexTickerElem 

type OkexTickerElem struct {
	Buy    string `json:"buy"`
	Last   string `json:"last"`
	Vol    string `json:"volume"`
	Symbol string `json:"symbol"`
	High   string `json:"high"`
	Low    string `json:"low"`
	Change string `json:"changePercentage"`
}

type Ticker 

type Ticker struct {
	Market    string  `json:"market"`
	Exchange  string  `json:"exchange"`
	Intervals string  `json:"interval"`
	Amount    float64 `json:"amount"`
	Vol       float64 `json:"vol"`
	Open      float64 `json:"open"`
	Close     float64 `json:"close"`
	High      float64 `json:"high"`
	Low       float64 `json:"low"`
	Last      float64 `json:"last"`
	Buy       float64 `json:"buy"`
	Sell      float64 `json:"sell"`
	Change    string  `json:"change"`
}

func GetAllTickerFromBinance 

func GetAllTickerFromBinance() (tickers []Ticker, err error)

func GetAllTickerFromOkex 

func GetAllTickerFromOkex() (tickers []Ticker, err error)

func GetTickerFromBinance 

func GetTickerFromBinance(market string) (ticker Ticker, err error)

func GetTickerFromHuobi 

func GetTickerFromHuobi(market string) (ticker Ticker, err error)

func GetTickerFromOkex 

func GetTickerFromOkex(market string) (ticker Ticker, err error)

type TickerField 

type TickerField struct {
	// contains filtered or unexported fields
}

type Trend 

type Trend struct {
	Intervals  string  `json:"intervals"`
	Market     string  `json:"market"`
	Vol        float64 `json:"vol"`
	Amount     float64 `json:"amount"`
	CreateTime int64   `json:"createTime"`
	Open       float64 `json:"open"`
	Close      float64 `json:"close"`
	High       float64 `json:"high"`
	Low        float64 `json:"low"`
	Start      int64   `json:"start"`
	End        int64   `json:"end"`
}

func ConvertUp 

func ConvertUp(src dao.Trend) Trend

type TrendManager 

type TrendManager struct {
	// contains filtered or unexported fields
}

func NewTrendManager 

func NewTrendManager(dao *dao.RdsService) TrendManager

func (*TrendManager) GetTicker 

func (t *TrendManager) GetTicker() (tickers []Ticker, err error)

func (*TrendManager) GetTickerByMarket 

func (t *TrendManager) GetTickerByMarket(mkt string) (ticker Ticker, err error)

func (*TrendManager) GetTrends 

func (t *TrendManager) GetTrends(market, interval string) (trends []Trend, err error)

func (*TrendManager) HandleOrderFilled 

func (t *TrendManager) HandleOrderFilled(input eventemitter.EventData) (err error)

func (*TrendManager) LoadCache 

func (t *TrendManager) LoadCache()

func (*TrendManager) ProofRead 

func (t *TrendManager) ProofRead()

func (*TrendManager) ScheduleUpdate 

func (t *TrendManager) ScheduleUpdate()

type TrendUpdateMsg 

type TrendUpdateMsg struct {
	Market   string `json:"market"`
	Interval string `json:"interval"`
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.