client

Documentation

Index

• type WebsocketClient
  • func NewClient(endpoint string) (*WebsocketClient, error)
  • func (c *WebsocketClient) Consume() chan interface{}
  • func (c *WebsocketClient) WriteToDisk(filepath string) error

Types

type WebsocketClient

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

WebsocketClient is the base client to consume the websockets

func NewClient

func NewClient(endpoint string) (*WebsocketClient, error)

NewClient creates a new websocket client

func (*WebsocketClient) Consume

func (c *WebsocketClient) Consume() chan interface{}

Consume creates a channel that returns messages

func (*WebsocketClient) WriteToDisk

func (c *WebsocketClient) WriteToDisk(filepath string) error

WriteToDisk writes new messages to disk