ws

Documentation

Index

• Constants
• type Args
• type Auth
• type Cmd
• type Configuration
• type FTXWS
  • func New(config *Configuration) *FTXWS
  • func (b *FTXWS) Auth()
  • func (b *FTXWS) Emit(event interface{}, arguments ...interface{}) *emission.Emitter
  • func (b *FTXWS) GetPair(args ...string) string
  • func (b *FTXWS) Off(event interface{}, listener interface{}) *emission.Emitter
  • func (b *FTXWS) On(event interface{}, listener interface{}) *emission.Emitter
  • func (b *FTXWS) Send(msg string) (err error)
  • func (b *FTXWS) SendCmd(cmd Cmd)
  • func (b *FTXWS) Start() error
  • func (b *FTXWS) Subscribe(channel string, coins []string)
  • func (b *FTXWS) Subscribe2(channel string, coin string)
• type Ticker

Constants

const (
	ChannelTicker = "ticker"
)

const (
	HostMainnetPublicTopics = "wss://ftx.com/ws/"
)

Types

type Args

type Args struct {
	Key  string `json:"key"`
	Sign string `json:"sign"`
	Time int64  `json:"time"`
}

type Auth

type Auth struct {
	Op   string `json:"op"`
	Args Args   `json:"args"`
}

type Cmd

type Cmd struct {
	Op      string `json:"op"`
	Channel string `json:"channel"`
	Market  string `json:"market"`
}

Необходим для удобного создания подписок

type Configuration

type Configuration struct {
	Addr      string `json:"addr"`
	ApiKey    string `json:"api_key"`
	SecretKey string `json:"secret_key"`
	DebugMode bool   `json:"debug_mode"`
}

type FTXWS

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

func New

func New(config *Configuration) *FTXWS

func (*FTXWS) Auth

func (b *FTXWS) Auth()

Необходим для приватных каналов

func (*FTXWS) Emit

func (b *FTXWS) Emit(event interface{}, arguments ...interface{}) *emission.Emitter

Emit emits an event

func (*FTXWS) GetPair

func (b *FTXWS) GetPair(args ...string) string

func (*FTXWS) Off

func (b *FTXWS) Off(event interface{}, listener interface{}) *emission.Emitter

Off removes a listener for an event

func (*FTXWS) On

func (b *FTXWS) On(event interface{}, listener interface{}) *emission.Emitter

On adds a listener to a specific event

func (*FTXWS) Send

func (b *FTXWS) Send(msg string) (err error)

func (*FTXWS) SendCmd

func (b *FTXWS) SendCmd(cmd Cmd)

отправка команды на сервер в отдельной функции для того, чтобы при переподключении быстро подписаться на все предыдущие каналы

func (*FTXWS) Start

func (b *FTXWS) Start() error

подключение к серверу и постоянное чтение приходящих ответов

func (*FTXWS) Subscribe

func (b *FTXWS) Subscribe(channel string, coins []string)

func (*FTXWS) Subscribe2

func (b *FTXWS) Subscribe2(channel string, coin string)

type Ticker

type Ticker struct {
	Channel string     `json:"channel"`
	Market  string     `json:"market"`
	Type    string     `json:"type"`
	Data    dataTicker `json:"data"`
}