websocketclient

Documentation

Overview

Package websocketclient is deprecated.

Deprecated: use github.com/rosenlo/toolkits/wsclient instead. The wsclient package supersedes this one with reconnect-friendly fields (Name, msgCount, connectedAt), a longer 5-minute readTimeout, PingPong, and richer error logs. This package is retained for backwards compatibility and may be removed in a future major release.

Index

• Constants
• Variables
• type Client
  • func New(addr string) (*Client, error)
  • func (c *Client) Recv(ctx context.Context, messageCh chan<- Message)
  • func (c *Client) Stop()
• type Message

Constants

const (
	MetricMessageChan = "wsp_message_channel_size"
)

Variables

var MessageChanLabel = []string{"url"}

Types

type Client

type Client struct {
	URL *url.URL
	// contains filtered or unexported fields
}

func New

func New(addr string) (*Client, error)

func (*Client) Recv

func (c *Client) Recv(ctx context.Context, messageCh chan<- Message)

func (*Client) Stop

func (c *Client) Stop()

type Message

type Message struct {
	Type        int
	Body        []byte
	ReceiveTime time.Time
}