coinbasepro

Documentation

Index

• type Channel
• type CoinbasePro
  • func (c *CoinbasePro) Defaults()
• type Message
• type WebsocketSubscription
  • func (w *WebsocketSubscription) SubscribeMatches(exchange *CoinbasePro, products []string, message chan order.Order) (quit func(), err error)

Types

type Channel

type Channel struct {
	Name       string   `json:"name"`
	ProductIDs []string `json:"product_ids,omitempty"`
}

Channel holds subscription channel information

type CoinbasePro

type CoinbasePro struct {
	ExchangeName string
	WSSAddress   string
	// contains filtered or unexported fields
}

CoinbasePro exchange struct

func (*CoinbasePro) Defaults

func (c *CoinbasePro) Defaults()

Defaults sets default values for exchange struct

type Message

type Message struct {
	Type       string    `json:"type"`
	ProductIDs []string  `json:"product_ids,omitempty"`
	Channels   []Channel `json:"channels,omitempty"`
}

Message holds base message information

type WebsocketSubscription

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

WebsocketSubscription holds information related to the subscription service

func (*WebsocketSubscription) SubscribeMatches

func (w *WebsocketSubscription) SubscribeMatches(exchange *CoinbasePro, products []string, message chan order.Order) (quit func(), err error)

SubscribeMatches subscribes to the matches and sends the results as orders