uws

Documentation

Index

• func MessageTypeString(i int) string
• type Client
  • func NewClient(url string) *Client
  • func (o *Client) Cancel()
  • func (o *Client) Close()
  • func (o *Client) Connected() bool
  • func (o *Client) Log() *ulog.Log
  • func (o *Client) Run()
  • func (o *Client) Running() bool
  • func (o *Client) Send(messageType int, data []byte) error
  • func (o *Client) SendBinary(data []byte) error
  • func (o *Client) SendJson(v any) (err error)
  • func (o *Client) SendText(data string) error
  • func (o *Client) WithAppendPath(path string) *Client
  • func (o *Client) WithBase(base string) *Client
  • func (o *Client) WithLog(log *ulog.Log) *Client
  • func (o *Client) WithOnBinaryMessage(f func([]byte))
  • func (o *Client) WithOnCloseError(f func(error))
  • func (o *Client) WithOnConnected(f func())
  • func (o *Client) WithOnDial(f func(string))
  • func (o *Client) WithOnDialDelay(f func() time.Duration)
  • func (o *Client) WithOnDialError(f func(error) bool)
  • func (o *Client) WithOnDisconnected(f func())
  • func (o *Client) WithOnMessage(f func(int, []byte))
  • func (o *Client) WithOnPing(f func())
  • func (o *Client) WithOnPreDial(f func(string) string)
  • func (o *Client) WithOnTextMessage(f func(string))
  • func (o *Client) WithPath(path string) *Client
  • func (o *Client) WithProxy(proxy string) *Client
  • func (o *Client) WithProxyUrl(url *url.URL) *Client
• type Events
  • func (o *Events) SetOnBinaryMessage(f func([]byte))
  • func (o *Events) SetOnTextMessage(f func(string))
• type LogMessage
• type Options
  • func (o *Options) AppendPath(path string)
  • func (o *Options) EmptyUrl() bool
  • func (o *Options) SetDefaultTimeouts()
  • func (o *Options) SetProxy(proxy string)
  • func (o *Options) Url() string

Functions

func MessageTypeString

func MessageTypeString(i int) string

Types

type Client

type Client struct {
	Options Options
	Events  Events
	// contains filtered or unexported fields
}

func NewClient

func NewClient(url string) *Client

func (*Client) Cancel

func (o *Client) Cancel()

func (*Client) Close

func (o *Client) Close()

func (*Client) Connected

func (o *Client) Connected() bool

func (*Client) Log

func (o *Client) Log() *ulog.Log

func (*Client) Run

func (o *Client) Run()

func (*Client) Running

func (o *Client) Running() bool

func (*Client) Send

func (o *Client) Send(messageType int, data []byte) error

func (*Client) SendBinary

func (o *Client) SendBinary(data []byte) error

func (*Client) SendJson

func (o *Client) SendJson(v any) (err error)

func (*Client) SendText

func (o *Client) SendText(data string) error

func (*Client) WithAppendPath

func (o *Client) WithAppendPath(path string) *Client

func (*Client) WithBase

func (o *Client) WithBase(base string) *Client

func (*Client) WithLog

func (o *Client) WithLog(log *ulog.Log) *Client

func (*Client) WithOnBinaryMessage

func (o *Client) WithOnBinaryMessage(f func([]byte))

func (*Client) WithOnCloseError

func (o *Client) WithOnCloseError(f func(error))

func (*Client) WithOnConnected

func (o *Client) WithOnConnected(f func())

func (*Client) WithOnDial

func (o *Client) WithOnDial(f func(string))

func (*Client) WithOnDialDelay

func (o *Client) WithOnDialDelay(f func() time.Duration)

func (*Client) WithOnDialError

func (o *Client) WithOnDialError(f func(error) bool)

func (*Client) WithOnDisconnected

func (o *Client) WithOnDisconnected(f func())

func (*Client) WithOnMessage

func (o *Client) WithOnMessage(f func(int, []byte))

func (*Client) WithOnPing

func (o *Client) WithOnPing(f func())

func (*Client) WithOnPreDial

func (o *Client) WithOnPreDial(f func(string) string)

func (*Client) WithOnTextMessage

func (o *Client) WithOnTextMessage(f func(string))

func (*Client) WithPath

func (o *Client) WithPath(path string) *Client

func (*Client) WithProxy

func (o *Client) WithProxy(proxy string) *Client

func (*Client) WithProxyUrl

func (o *Client) WithProxyUrl(url *url.URL) *Client

type Events

type Events struct {
	OnPing         func()
	OnMessage      func(int, []byte)
	OnPreDial      func(string) string
	OnDial         func(string)
	OnDialDelay    func() time.Duration
	OnDialError    func(error) bool
	OnConnected    func()
	OnDisconnected func()
	OnCloseError   func(error)
}

func (*Events) SetOnBinaryMessage

func (o *Events) SetOnBinaryMessage(f func([]byte))

func (*Events) SetOnTextMessage

func (o *Events) SetOnTextMessage(f func(string))

type LogMessage

type LogMessage struct {
	Type bool
	Size bool
	Data bool
}

type Options

type Options struct {
	Base               string
	Path               string
	Proxy              *url.URL
	InsecureSkipVerify bool
	PingInterval       time.Duration
	ReDialInterval     time.Duration
	ReDialDelay        time.Duration
	HandshakeTimeout   time.Duration
	ReadTimeout        time.Duration
	SendTimeout        time.Duration
	LogSent            LogMessage
	LogRecv            LogMessage
}

func (*Options) AppendPath

func (o *Options) AppendPath(path string)

func (*Options) EmptyUrl

func (o *Options) EmptyUrl() bool

func (*Options) SetDefaultTimeouts

func (o *Options) SetDefaultTimeouts()

func (*Options) SetProxy

func (o *Options) SetProxy(proxy string)

func (*Options) Url

func (o *Options) Url() string