Binance Spot Go Connector

This is a lightweight library that works as a connector to Binance public API

Supported API Endpoints:

• Account/Trade: account.go
• Wallet: wallet.go
• Margin Account/Trade: margin.go
• Market Data: market.go
• Sub-Accounts: subaccount.go
• Staking: staking.go
• Websocket Market/User Data Stream: websocket.go
• Websocket User Data Stream: user_stream.go

Installation

go get github.com/binance/binance-connector-go

To reference the package in your code, use the following import statement:

import (
    "github.com/binance/binance-connector-go"
)

Authentication

// The Client can be initiated with apiKey, secretKey and baseURL.
// The baseURL is optional. If not specified, it will default to "https://api.binance.com".
client := binance_connector.NewClient("yourApiKey", "yourSecretKey")

Extra Options

client := binance_connector.NewClient("yourApiKey", "yourSecretKey", "https://api.binance.com")

// Debug Mode
client.Debug = true

// TimeOffset (in milliseconds) - used to adjust the request timestamp by subtracting/adding the current time with it:
client.TimeOffset = -1000 // implies adding: request timestamp = current time - (-1000)

REST API

Create an order example

package main

import (
    "context"
    "fmt"

    binance_connector "github.com/binance/binance-connector-go"
)

func main() {
    apiKey := "yourApiKey"
    secretKey := "yourSecretKey"
    baseURL := "https://testnet.binance.vision"

    // Initialise the client
    client := binance_connector.NewClient(apiKey, secretKey, baseURL)

    // Create new order
    newOrder, err := client.NewCreateOrderService().Symbol("BTCUSDT").
        Side("BUY").Type("MARKET").Quantity(0.001).
        Do(context.Background())
    if err != nil {
        fmt.Println(err)
        return
    }
    fmt.Println(binance_connector.PrettyPrint(newOrder))
}

Please find more examples for each supported endpoint in the examples folder.

Websocket Stream

Initialising Websocket Client - Websocket Client can be initialized with 2 parameters, NewWebsocketStreamClient(isCombined, baseURL): - isCombined is a MANDATORY boolean value that specifies whether you are calling a combined stream or not. - If isCombined is set to true, "/stream?streams=" will be appended to the baseURL to allow for Combining streams. - Otherwise, if set to false, "/ws/" will be appended to the baseURL. - baseURL is an OPTIONAL string value that determines the base URL to use for the websocket connection. - If baseURL is not set, it will default to the Live Exchange URL: "wss://stream.binance.com:9443".

// Initialise Websocket Client with Production baseURL and false for "isCombined" parameter

websocketStreamClient := binance_connector.NewWebsocketStreamClient(false, "wss://stream.testnet.binance.vision")

// Initialise Websocket Client with Production baseURL and true for "isCombined" parameter

websocketStreamClient := binance_connector.NewWebsocketStreamClient(true)

Diff. Depth Stream Example

package main

import (
    "fmt"
    "time"

    binance_connector "github.com/binance/binance-connector-go"
)

func main() {
    // Initialise Websocket Client with Testnet BaseURL and false for "isCombined" parameter
    websocketStreamClient := binance_connector.NewWebsocketStreamClient(false, "wss://stream.testnet.binance.vision")

    wsDepthHandler := func(event *binance_connector.WsDepthEvent) {
        fmt.Println(binance_connector.PrettyPrint(event))
    }

    errHandler := func(err error) {
        fmt.Println(err)
    }

    // Depth stream subscription
    doneCh, stopCh, err := websocketStreamClient.WsDepthServe("BNBUSDT", wsDepthHandler, errHandler)
    if err != nil {
        fmt.Println(err)
        return
    }

    go func() {
        time.Sleep(30 * time.Second)
        stopCh <- struct{}{} // use stopCh to stop streaming
    }()

    <-doneCh
}

Combined Diff. Depth Stream Example

package main

import (
    "fmt"
    "time"

    binance_connector "github.com/binance/binance-connector-go"
)

func main() {
    // Set isCombined parameter to true as we are using Combined Depth Stream
    websocketStreamClient := binance_connector.NewWebsocketStreamClient(true)

    wsCombinedDepthHandler := func(event *binance_connector.WsDepthEvent) {
        fmt.Println(binance_connector.PrettyPrint(event))
    }
    errHandler := func(err error) {
        fmt.Println(err)
    }
    // Use WsCombinedDepthServe to subscribe to multiple streams
    doneCh, stopCh, err := websocketStreamClient.WsCombinedDepthServe([]string{"LTCBTC", "BTCUSDT", "MATICUSDT"}, wsCombinedDepthHandler, errHandler)
    if err != nil {
        fmt.Println(err)
        return
    }
    go func() {
        time.Sleep(5 * time.Second)
        stopCh <- struct{}{}
    }()
    <-doneCh
}

Websocket API

func OCOHistoryExample() {
    // Initialise Websocket API Client
    client := binance_connector.NewWebsocketAPIClient("api_key", "secret_key")
    // Connect to Websocket API
    err := client.Connect()
    if err != nil {
        log.Printf("Error: %v", err)
        return
    }
    defer client.Close()

    // Send request to Websocket API
    response, err := client.NewAccountOCOHistoryService().Do(context.Background())
    if err != nil {
        log.Printf("Error: %v", err)
        return
    }

    // Print the response
    fmt.Println(binance_connector.PrettyPrint(response))

    client.WaitForCloseSignal()
}

Base URL

• Binance provides alternative Production URLs in case of performance issues:
• https://api1.binance.com
• https://api2.binance.com
• https://api3.binance.com

Testnet Support

• In order to use the Testnet, simply set the baseURL to "https://testnet.binance.vision"
• You can find step-by-step instructions on how to use the get a Testnet API and Secret Key here

Pretty Print vs PrintLn

• The fmt.Println(<response>) function will print the struct in a single line, which is not very readable.
• The fmt.Println(binance_connector.PrettyPrint(<response>)) function will print the struct, including both the key and value, in a multi-line format which is more easily readable.

Regular PrintLn Example Output

&{depthUpdate 1680092520368 LTCBTC 1989614201 1989614210 [{0.00322300 70.96700000} {0.00322200 52.57100000} {0.00322000 248.64000000} {0.00321900 34.98300000}] [{0.00322600 71.52600000} {0.00323400 53.88900000} {0.00323500 27.37000000}]}
&{depthUpdate 1680092521368 LTCBTC 1989614211 1989614212 [{0.00320700 197.10100000} {0.00320100 15.76800000}] []}
&{depthUpdate 1680092522368 LTCBTC 1989614213 1989614224 [{0.00322300 86.15400000} {0.00322200 37.38400000} {0.00322100 252.53900000} {0.00322000 60.01300000}] [{0.00322800 75.48400000} {0.00322900 254.84500000} {0.00323000 8.74700000} {0.00323100 37.42800000}]}
&{depthUpdate 1680092523369 LTCBTC 1989614225 1989614226 [{0.00322300 103.57400000}] [{0.00399500 11.75400000}]}
&{depthUpdate 1680092524369 LTCBTC 1989614227 1989614276 [{0.00322500 0.00000000} {0.00322400 101.32700000} {0.00322300 138.82600000} {0.00322200 58.49100000} {0.00322100 249.65400000} {0.00321900 47.34800000} {0.00317800 16.08500000} {0.00317500 38.36500000}] [{0.00322500 75.14300000} {0.00322600 48.19100000} {0.00322700 44.97900000} {0.00322800 242.74300000} {0.00322900 20.73400000} {0.00532700 0.18900000} {0.00779700 0.05600000}]}

binance_connector.PrettyPrint Example Output

{
    "e": "depthUpdate",
    "E": 1680092041346,
    "s": "LTCBTC",
    "U": 1989606566,
    "u": 1989606596,
    "b": [
        {
            "Price": "0.00322800",
            "Quantity": "83.05100000"
        },
        {
            "Price": "0.00322700",
            "Quantity": "12.50200000"
        },
        {
            "Price": "0.00322500",
            "Quantity": "48.53700000"
        },
        {
            "Price": "0.00322400",
            "Quantity": "244.13500000"
        }
    ],
    "a": [
        {
            "Price": "0.00322900",
            "Quantity": "79.52900000"
        },
        {
            "Price": "0.00323000",
            "Quantity": "42.68400000"
        },
        {
            "Price": "0.00323100",
            "Quantity": "68.75500000"
        }
    ]
}
{
    "e": "depthUpdate",
    "E": 1680092042346,
    "s": "LTCBTC",
    "U": 1989606597,
    "u": 1989606611,
    "b": [
        {
            "Price": "0.00321400",
            "Quantity": "0.24700000"
        },
        {
            "Price": "0.00318000",
            "Quantity": "1.91600000"
        }
    ],
    "a": [
        {
            "Price": "0.00322900",
            "Quantity": "79.27900000"
        }
    ]
}

Limitations

Futures and European Options APIs are not supported: - /fapi/ - /dapi/ - /vapi/* - Associated Websocket Market and User Data Streams

Contributing

Contributions are welcome.

If you've found a bug within this project, please open an issue to discuss what you would like to change.

If it's an issue with the API, please open a topic at Binance Developer Community