websocket

Documentation

Index

• Constants
• type ChanStreamOrderDepth
• type ChanStreamOrders
• type ChanStreamPositions
• type ChanStreamQuotes
• type ChanStreamTrades
• type Conn
  • func (c *Conn) Close()
  • func (c *Conn) Collect(data chan []byte)
• type WebsocketClient
  • func (w *WebsocketClient) Connect(params string) (*Conn, error)
  • func (w *WebsocketClient) StreamOrderDepth(ctx context.Context, params string) (*Conn, ChanStreamOrderDepth, error)
  • func (w *WebsocketClient) StreamOrders(ctx context.Context, params string) (*Conn, ChanStreamOrders, error)
  • func (w *WebsocketClient) StreamPositions(ctx context.Context, params string) (*Conn, ChanStreamPositions, error)
  • func (w *WebsocketClient) StreamQuotes(ctx context.Context, params string) (*Conn, ChanStreamQuotes, error)
  • func (w *WebsocketClient) StreamTrades(ctx context.Context, params string) (*Conn, ChanStreamTrades, error)

Constants

const (
	DefaultWebsocketUrl        = "wss://www.avanza.se/_push/cometd"
	PingChannel                = "/meta/connect"
	QuotesSubscriptionPath     = "/quotes/%s"
	OrderDepthSubscriptionPath = "/orderdepths/%s"
	PositionsSubscriptionPath  = "/positions/%s"
	OrdersSubscriptionPath     = "/orders/%s"
	TradesSubscriptionPath     = "/trades/%s"
)

Types

type ChanStreamOrderDepth

type ChanStreamOrderDepth chan models.StreamOrderDepth

type ChanStreamOrders

type ChanStreamOrders chan models.StreamOrders

type ChanStreamPositions

type ChanStreamPositions chan models.StreamPositions

type ChanStreamQuotes

type ChanStreamQuotes chan models.StreamQuote

type ChanStreamTrades

type ChanStreamTrades chan models.StreamTrades

type Conn

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

Conn defines a connection to a WebSocket server.

func (*Conn) Close

func (c *Conn) Close()

func (*Conn) Collect

func (c *Conn) Collect(data chan []byte)

type WebsocketClient

type WebsocketClient struct {
	*client.Client
	Dialer *websocket.Dialer
	// contains filtered or unexported fields
}

func (*WebsocketClient) Connect

func (w *WebsocketClient) Connect(params string) (*Conn, error)

func (*WebsocketClient) StreamOrderDepth

func (w *WebsocketClient) StreamOrderDepth(ctx context.Context, params string) (*Conn, ChanStreamOrderDepth, error)

func (*WebsocketClient) StreamOrders

func (w *WebsocketClient) StreamOrders(ctx context.Context, params string) (*Conn, ChanStreamOrders, error)

func (*WebsocketClient) StreamPositions

func (w *WebsocketClient) StreamPositions(ctx context.Context, params string) (*Conn, ChanStreamPositions, error)

func (*WebsocketClient) StreamQuotes

func (w *WebsocketClient) StreamQuotes(ctx context.Context, params string) (*Conn, ChanStreamQuotes, error)

func (*WebsocketClient) StreamTrades

func (w *WebsocketClient) StreamTrades(ctx context.Context, params string) (*Conn, ChanStreamTrades, error)