kline

Documentation

Index

• type Data
• type Kline
  • func New(c *client.Client) (Kline, error)
• type Response

Types

type Data

type Data struct {
	Start     int64  `json:"start"`
	End       int64  `json:"end"`
	Interval  string `json:"interval"`
	Open      string `json:"open"`
	Close     string `json:"close"`
	High      string `json:"high"`
	Low       string `json:"low"`
	Volume    string `json:"volume"`
	Turnover  string `json:"turnover"`
	Confirm   bool   `json:"confirm"`
	Timestamp int64  `json:"timestamp"`
}

Data struct represents individual kline data points.

type Kline

type Kline interface {
	// SetClient sets the client for the kline functionality.
	SetClient(client *client.Client) error

	// Subscribe subscribes to kline data for the specified symbols and interval.
	// It also stores the callback for each topic.
	Subscribe(symbols []string, interval string, callback func(response Data)) error

	// Unsubscribe unsubscribes from the specified topics.
	Unsubscribe(topics ...string) error

	// Listen reads the next message from the kline channel.
	Listen() (int, []byte, error)

	// Close closes the connection to the kline channel.
	Close()

	// GetMessagesChan returns a channel that receives messages from the kline channel.
	GetMessagesChan() <-chan []byte

	// Stop stops the kline functionality.
	Stop()
}

Kline represents the interface for the kline functionality.

func New

func New(c *client.Client) (Kline, error)

New creates a new instance of KlineImpl.

type Response

type Response struct {
	Topic string `json:"topic"`
	Type  string `json:"type"`
	Data  []Data `json:"data"`
	Ts    int64  `json:"ts"`
}

Response struct represents the kline response from the server.