Version: v0.0.0-...-935a062 Latest Latest

This package is not in the latest version of its module.

Go to latest
Published: Oct 7, 2020 License: MIT Imports: 13 Imported by: 0




View Source
const (
	APIEndpoint string = "wss://"

	HeartbeatIntervalSecond time.Duration = 60
	ReadTimeoutSecond       time.Duration = 300
	WriteTimeoutSecond      time.Duration = 5


This section is empty.


This section is empty.


type Channel

type Channel string
var (
	ChannelOrderBook       Channel = "lightning_board_snapshot"
	ChannelOrderBookUpdate Channel = "lightning_board"
	ChannelTicker          Channel = "lightning_ticker"
	ChannelExecution       Channel = "lightning_executions"

type ChannelMessage

type ChannelMessage struct {
	Channel Channel                 `json:"channel"`
	Message jsonencoding.RawMessage `json:"message"`

type Client

type Client struct {
	Endpoint string
	Session  *Session

func NewClient

func NewClient() *Client

func (*Client) APIEndpoint

func (c *Client) APIEndpoint() string

func (*Client) Connect

func (c *Client) Connect() (*Session, error)

type ExecutionHandler

type ExecutionHandler func(executions.Response) error

type Message

type Message struct {
	Version string         `json:"jsonrpc"`
	Method  string         `json:"method"`
	Params  ChannelMessage `json:"params"`

type OrderBookHandler

type OrderBookHandler func(board.Response) error

type OrderBookUpdateHandler

type OrderBookUpdateHandler func(board.Response) error

type RequestParam

type RequestParam struct {
	Channel Channel `json:"channel"`

type Session

type Session struct {
	Conn *websocket.Conn

func (*Session) Close

func (sess *Session) Close() error

type Subscriber

type Subscriber struct {
	// contains filtered or unexported fields

func NewSubscriber

func NewSubscriber() *Subscriber

func NewSubscriberWithOpts

func NewSubscriberWithOpts(opts *SubscriberOpts) *Subscriber

func (*Subscriber) HandleExecution

func (s *Subscriber) HandleExecution(
	pcs []markets.ProductCode,
	handler ExecutionHandler,

func (*Subscriber) HandleOrderBook

func (s *Subscriber) HandleOrderBook(
	pcs []markets.ProductCode,
	handler OrderBookHandler,

func (*Subscriber) HandleOrderBookUpdate

func (s *Subscriber) HandleOrderBookUpdate(
	pcs []markets.ProductCode,
	handler OrderBookUpdateHandler,

func (*Subscriber) HandleTicker

func (s *Subscriber) HandleTicker(
	pcs []markets.ProductCode,
	handler TickerHandler,

func (*Subscriber) ListenAndServe

func (s *Subscriber) ListenAndServe(sess *Session) error

type SubscriberOpts

type SubscriberOpts struct {
	Debug bool

type TickerHandler

type TickerHandler func(ticker.Response) error

Source Files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL