Go SDK - Financial Data API REST & WebSocket Real-Time Streaming iTick Documentation SDK & Developer Tools Official iTick Go SDK providing REST API queries and WebSocket real-time data subscription for basic, stock, index, futures, fund, forex, and cryptocurrency market data.

package main

import (
    "github.com/itick-org/go-sdk/sdk"
)

func main() {
    token := "your_api_token"
    client := sdk.NewClient(token)
}

// Get forex real-time trade
tick, err := client.GetForexTick("GB", "EURUSD")
if err != nil {
    log.Fatalf("GetForexTick error: %v", err)
}
tickBy, _ := json.Marshal(tick)
fmt.Printf("Forex Tick: %+v\n", string(tickBy))

// Get forex batch real-time trade
ticks, err := client.GetForexTicks("GB", []string{"EURUSD", "GBPUSD"})
if err != nil {
    log.Fatalf("GetForexTicks error: %v", err)
}
ticksBy, _ := json.Marshal(ticks)
fmt.Printf("Forex Ticks: %+v\n", string(ticksBy))

// Get forex real-time Quote
quote, err := client.GetForexQuote("GB", "GBPUSD")
if err != nil {
    log.Fatalf("GetForexQuote error: %v", err)
}
quoteBy, _ := json.Marshal(quote)
fmt.Printf("Forex Quote: %+v\n", string(quoteBy))

// Get forex batch real-time Quote
quotes, err := client.GetForexQuotes("GB", []string{"EURUSD", "GBPUSD"})
if err != nil {
    log.Fatalf("GetForexQuotes error: %v", err)
}
quotesBy, _ := json.Marshal(quotes)
fmt.Printf("Forex Quotes: %+v\n", string(quotesBy))

// Get forex real-time order book
depth, err := client.GetForexDepth("GB", "EURUSD")
if err != nil {
    log.Fatalf("GetForexDepth error: %v", err)
}
depthBy, _ := json.Marshal(depth)
fmt.Printf("Forex Depth: %+v\n", string(depthBy))

// Get forex batch real-time order book
depths, err := client.GetForexDepths("GB", []string{"EURUSD", "GBPUSD"})
if err != nil {
    log.Fatalf("GetForexDepths error: %v", err)
}
depthsBy, _ := json.Marshal(depths)
fmt.Printf("Forex Depths: %+v\n", string(depthsBy))

// Get forex historical K-line
kline, err := client.GetForexKline("GB", "EURUSD", 2, 10, nil)
if err != nil {
    log.Fatalf("GetForexKlines error: %v", err)
}
klineBy, _ := json.Marshal(kline)
fmt.Printf("Forex Klines: %+v\n", string(klineBy))

// Get forex batch historical K-line
klines, err := client.GetForexKlines("GB", []string{"EURUSD", "GBPUSD"}, 2, 10, nil)
if err != nil {
    log.Fatalf("GetForexKlines error: %v", err)
}
klinesBy, _ := json.Marshal(klines)
fmt.Printf("Forex Klines: %+v\n", string(klinesBy))

// Get stock real-time trade
tick, err := client.GetStockTick("US", "AAPL")
if err != nil {
    log.Fatal(err)
}

// Get stock real-time quote
quote, err := client.GetStockQuote("US", "AAPL")
if err != nil {
    log.Fatal(err)
}

// Get stock real-time order book
depth, err := client.GetStockDepth("US", "AAPL")
if err != nil {
    log.Fatal(err)
}

// Get stock historical K-line
kline, err := client.GetStockKline("US", "AAPL", 2, 10, nil)
if err != nil {
    log.Fatal(err)
}

// Get crypto real-time trade
tick, err := client.GetCryptoTick("BA", "BTCUSDT")
if err != nil {
    log.Fatal(err)
}

// Get crypto real-time quote
quote, err := client.GetCryptoQuote("BA", "BTCUSDT")
if err != nil {
    log.Fatal(err)
}

// Get crypto real-time order book
depth, err := client.GetCryptoDepth("BA", "BTCUSDT")
if err != nil {
    log.Fatal(err)
}

// Get crypto historical K-line
kline, err := client.GetCryptoKline("BA", "BTCUSDT", 2, 10, nil)
if err != nil {
    log.Fatal(err)
}

// Set message handler
client.SetMessageHandler(func(message []byte) {
    fmt.Printf("Received WebSocket message: %s\n", message)
})

// Set error handler
client.SetErrorHandler(func(err error) {
    log.Printf("WebSocket error: %v\n", err)
})

// Connect to forex WebSocket
err := client.ConnectForexWebSocket()
if err != nil {
    log.Fatal(err)
}
defer client.CloseWebSocket()

// Send subscription message
subscribeMsg := []byte(`{"ac": "subscribe", "params": "EURUSD$GB","types":"quote"}`)
err = client.SendWebSocketMessage(subscribeMsg)
if err != nil {
    log.Fatal(err)
}

// Wait to receive messages
time.Sleep(10 * time.Second)

// Check connection status
fmt.Printf("WebSocket connected: %v\n", client.IsWebSocketConnected())

// Connect to stock WebSocket
err := client.ConnectStockWebSocket()

// Connect to cryptocurrency WebSocket
err := client.ConnectCryptoWebSocket()

// Check if WebSocket is connected
connected := client.IsWebSocketConnected()

package main

import (
    "fmt"
    "log"
    "time"

    "github.com/itick-org/go-sdk/sdk"
)

func main() {
    // Initialize client
    token := "your_api_token"
    client := sdk.NewClient(token)

    // Set WebSocket message handler
    client.SetMessageHandler(func(message []byte) {
        fmt.Printf("Received WebSocket message: %s\n", message)
    })

    // Set WebSocket error handler
    client.SetErrorHandler(func(err error) {
        log.Printf("WebSocket error: %v\n", err)
    })

    // Test REST API
    tick, err := client.GetForexTick("GB", "EURUSD")
    if err != nil {
        log.Fatal(err)
    }
    fmt.Printf("Forex Tick: %+v\n", tick)

    // Test WebSocket
    err = client.ConnectForexWebSocket()
    if err != nil {
        log.Fatal(err)
    }
    defer client.CloseWebSocket()

    // Send subscription message
    subscribeMsg := []byte(`{"ac": "subscribe", "params": "EURUSD$GB","types":"quote"}`)
    err = client.SendWebSocketMessage(subscribeMsg)
    if err != nil {
        log.Fatal(err)
    }

    // Wait to receive messages
    time.Sleep(10 * time.Second)
}