24hr for all markets

binance/examples/ticker.go

@@ -0,0 +1,58 @@
+package main
+
+import (
+	//"sync"
+	//"strings"
+	"encoding/json"
+	"fmt"
+	"log"
+
+	"github.com/gorilla/websocket"
+)
+
+const (
+	MaxQueue = 100 // Size of message queue
+)
+
+type ChangeStats struct {
+	Symbol             string `json:"s"`
+	PriceChange        string `json:"p"`
+	PriceChangePercent string `json:"P"`
+	WeightedAvgPrice   string `json:"w"`
+	PrevClosePrice     string `json:"x"`
+	BidPrice           string `json:"b"`
+	AskPrice           string `json:"a"`
+	HighPrice          string `json:"h"`
+	Volume             string `json:"v"`
+}
+
+func main() {
+
+	address := fmt.Sprintf("wss://stream.binance.com:9443/ws/!ticker@arr")
+
+	var wsDialer websocket.Dialer
+	wsConn, _, err := wsDialer.Dial(address, nil)
+	if err != nil {
+		panic(err)
+	}
+	defer wsConn.Close()
+	log.Println("Dialed:", address)
+
+	for {
+		_, message, err := wsConn.ReadMessage()
+
+		if err != nil {
+			log.Println("[ERROR] ReadMessage:", err)
+		}
+
+		var msg []ChangeStats
+		fmt.Println("Received message !")
+
+		err = json.Unmarshal(message, &msg)
+		if err != nil {
+			log.Println("[ERROR] Parsing:", err)
+			continue
+		}
+		fmt.Println(msg)
+	}
+}

binance/market.go

@@ -70,6 +70,15 @@ func (b *Binance) Get24Hr(q SymbolQuery) (changeStats ChangeStats, err error) {
 	return
 }
 
+// 24 hour price for all statistics
+func (b *Binance) GetAll24Hr(q SymbolQuery) (changeStats []ChangeStats, err error) {
+
+	reqUrl := fmt.Sprintf("api/v1/ticker/24hr")
+	_, err = b.client.do("GET", reqUrl, "", false, &changeStats)
+
+	return
+}
+
 // Latest price for all symbols.
 func (b *Binance) GetAllPrices() (prices []TickerPrice, err error) {
 

binance/market_response.go

@@ -48,6 +48,7 @@ func (o *Order) UnmarshalJSON(b []byte) error {
 
 // Result from: GET /api/v1/ticker/24hr
 type ChangeStats struct {
+	Symbol 			   string  `json:"symbol, string"`
 	PriceChange        float64 `json:"priceChange,string"`
 	PriceChangePercent float64 `json:"priceChangePercent,string"`
 	WeightedAvgPrice   float64 `json:"weightedAvgPrice,string"`