websocketclient

Documentation

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
}