gowebsocket

type ConnectionOptions struct {
	UseCompression bool
	UseSSL         bool
	Proxy          func(*http.Request) (*url.URL, error)
	SubProtocols   []string
	AutoRetry      bool
	RetryDelay     time.Duration
}

type Logger interface {
	Errorf(format string, args ...interface{})
	Warnf(format string, args ...interface{})
	Infof(format string, args ...interface{})
	Debugf(format string, args ...interface{})
	Tracef(format string, args ...interface{})
}

type NoOpLogger struct {
}

type ReconnectionOptions struct {
	AutoRetry  bool
	RetryDelay time.Duration
}

type Socket struct {
	Conn            *websocket.Conn
	WebsocketDialer *websocket.Dialer
	Url             string
	Connection      ConnectionOptions
	Reconnection    ReconnectionOptions
	RequestHeader   http.Header
	OnConnected     func(socket Socket)
	OnTextMessage   func(message string, socket Socket)
	OnBinaryMessage func(data []byte, socket Socket)
	Log             Logger
	Timeout         time.Duration
	OnConnectError  func(err error, socket Socket)
	OnDisconnected  func(err error, socket Socket)
	OnPingReceived  func(data string, socket Socket)
	OnPongReceived  func(data string, socket Socket)
	// contains filtered or unexported fields
}