connector

Documentation

Index

• type REST
  • func GetREST() (*REST, error)
  • func InitREST(cfg *config.REST) *REST
  • func (r *REST) Do(req *http.Request) (*http.Response, error)
  • func (r *REST) Request(appCtx context.Context, method, url string) (*http.Request, error)
• type Websocket
  • func NewWebsocket(appCtx context.Context, cfg *config.WS, url string) (Websocket, error)
  • func (w *Websocket) Read() ([]byte, error)
  • func (w *Websocket) ReadTextOrFlateBinary() ([]byte, error)
  • func (w *Websocket) ReadTextOrGzipBinary() ([]byte, error)
  • func (w *Websocket) ReadTextOrZlibBinary() ([]byte, error)
  • func (w *Websocket) Write(data []byte) error

Types

type REST

type REST struct {
	HTTPClient *http.Client
}

REST is for REST connection.

func GetREST

func GetREST() (*REST, error)

GetREST returns already initialized http client.

func InitREST

func InitREST(cfg *config.REST) *REST

InitREST initializes http client with configured values.

func (*REST) Do

func (r *REST) Do(req *http.Request) (*http.Response, error)

Do makes GET http call to exchange.

func (*REST) Request

func (r *REST) Request(appCtx context.Context, method, url string) (*http.Request, error)

Request creates a new request object for http operation.

type Websocket

type Websocket struct {
	Conn net.Conn
	Cfg  *config.WS
}

Websocket is for websocket connection.

func NewWebsocket

func NewWebsocket(appCtx context.Context, cfg *config.WS, url string) (Websocket, error)

NewWebsocket creates a new websocket connection for the exchange.

func (*Websocket) Read

func (w *Websocket) Read() ([]byte, error)

Read reads data frame from websocket connection.

func (*Websocket) ReadTextOrFlateBinary

func (w *Websocket) ReadTextOrFlateBinary() ([]byte, error)

ReadTextOrFlateBinary reads data frame from websocket connection. It also handles flate compressed binary data frame.

func (*Websocket) ReadTextOrGzipBinary

func (w *Websocket) ReadTextOrGzipBinary() ([]byte, error)

ReadTextOrGzipBinary reads data frame from websocket connection. It also handles gzip compressed binary data frame.

func (*Websocket) ReadTextOrZlibBinary

func (w *Websocket) ReadTextOrZlibBinary() ([]byte, error)

ReadTextOrZlibBinary reads data frame from websocket connection. It also handles zlib compressed binary data frame.

func (*Websocket) Write

func (w *Websocket) Write(data []byte) error

Write writes data frame on websocket connection.