client

package
v2.3.8+incompatible Latest Latest
Warning

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

Go to latest
Published: Aug 2, 2018 License: Apache-2.0 Imports: 14 Imported by: 6

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ColumnSeriesFromResult

func ColumnSeriesFromResult(shapes []io.DataShape, columns map[string]interface{}) (cs *io.ColumnSeries, err error)

Types

type Client

type Client struct {
	BaseURL string
}

func NewClient

func NewClient(baseurl string) (cl *Client, err error)

NewClient intializes a new MarketStore RPC client

func (*Client) DoRPC

func (cl *Client) DoRPC(functionName string, args interface{}) (response interface{}, err error)

DoRPC makes an RPC request to MarketStore's API

func (*Client) Subscribe

func (cl *Client) Subscribe(
	handler func(pl stream.Payload) error,
	cancel <-chan struct{},
	streams ...string) (done <-chan struct{}, err error)

Subscribe to the marketstore websocket interface with a message handler, a set of streams and cancel channel.

Jump to

Keyboard shortcuts

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