Documentation
¶
Index ¶
- Constants
- Variables
- func CheckMessageIsPrivate(msg []byte, privateMessagePropertyName string) (requestId string, isPrivate bool)
- type GoLogger
- func (logger *GoLogger) DEBUG(message string, err ...error)
- func (logger *GoLogger) Disable()
- func (logger *GoLogger) ERROR(message string, err ...error)
- func (logger *GoLogger) Enable()
- func (logger *GoLogger) IMPORTANT(message string, err ...error)
- func (logger *GoLogger) INFO(message string, err ...error)
- func (logger *GoLogger) SHOULDNT_HAPPEN(message string, err ...error)
- func (logger *GoLogger) WARN(message string, err ...error)
- type ReconnectingRegisteredCallbacksWebsocket
- func AssignReconnectingRegisteredCallbacksWebsocket(conn *ws.Conn, URL string, privateMessagePropertyName string, isServer bool, ...) *ReconnectingRegisteredCallbacksWebsocket
- func CreateReconnectingRegisteredCallbacksWebsocket(URL string, privateMessagePropertyName string, isServer bool, ...) (*ReconnectingRegisteredCallbacksWebsocket, error)
- func (socket *ReconnectingRegisteredCallbacksWebsocket) Close()
- func (socket *ReconnectingRegisteredCallbacksWebsocket) GetParserRegistry() *parser.MessageParsers_Registry
- func (socket *ReconnectingRegisteredCallbacksWebsocket) SendJSON(v interface{}) error
- func (socket *ReconnectingRegisteredCallbacksWebsocket) SendPreparedMessage(preparedMessage *ws.PreparedMessage) error
- func (socket *ReconnectingRegisteredCallbacksWebsocket) SendPrivateMessage(message map[string]interface{}, timeout_sec ...int) (response []byte, hasTimedOut bool, err error)
- func (socket *ReconnectingRegisteredCallbacksWebsocket) SendText(text string) error
- func (socket *ReconnectingRegisteredCallbacksWebsocket) SetHTTPHeader(httpHeader http.Header)
- func (socket *ReconnectingRegisteredCallbacksWebsocket) SetURL(URL string)
- type RegisteredCallbacksWebsocket
- func (socket *RegisteredCallbacksWebsocket) Close()
- func (socket *RegisteredCallbacksWebsocket) GetParserRegistry() *parser.MessageParsers_Registry
- func (socket *RegisteredCallbacksWebsocket) SendJSON(v interface{}) error
- func (socket *RegisteredCallbacksWebsocket) SendPreparedMessage(preparedMessage *ws.PreparedMessage) error
- func (socket *RegisteredCallbacksWebsocket) SendPrivateMessage(message map[string]interface{}, timeout_sec ...int) (response []byte, hasTimedOut bool, err error)
- func (socket *RegisteredCallbacksWebsocket) SendText(text string) error
Constants ¶
View Source
const ( HEARTBEAT_CHECK_INTERVAL_SEC = 5 HEARTBEAT_CLOSE_ON_NO_HEARTBEAT_SEC = 20 )
Variables ¶
View Source
var Logger = GoLogger{}
Functions ¶
Types ¶
type GoLogger ¶
type GoLogger struct {
PrintLogsLevel int
LogLevel int
LogFile string
// contains filtered or unexported fields
}
func (*GoLogger) SHOULDNT_HAPPEN ¶
type ReconnectingRegisteredCallbacksWebsocket ¶
type ReconnectingRegisteredCallbacksWebsocket struct {
OnMessage func(messageType int, msg []byte)
OnError func(err error)
OnDisconnect func(code int, reason string)
OnReconnectError func(err error)
OnReconnect func()
// contains filtered or unexported fields
}
func CreateReconnectingRegisteredCallbacksWebsocket ¶
func CreateReconnectingRegisteredCallbacksWebsocket(URL string, privateMessagePropertyName string, isServer bool, httpHeader http.Header) (*ReconnectingRegisteredCallbacksWebsocket, error)
WARNING: Since this is a reconnecting socket, it will NEVER error out when trying to connect to the server, it will block until a successful connection is established
func (*ReconnectingRegisteredCallbacksWebsocket) Close ¶
func (socket *ReconnectingRegisteredCallbacksWebsocket) Close()
func (*ReconnectingRegisteredCallbacksWebsocket) GetParserRegistry ¶
func (socket *ReconnectingRegisteredCallbacksWebsocket) GetParserRegistry() *parser.MessageParsers_Registry
func (*ReconnectingRegisteredCallbacksWebsocket) SendJSON ¶
func (socket *ReconnectingRegisteredCallbacksWebsocket) SendJSON(v interface{}) error
func (*ReconnectingRegisteredCallbacksWebsocket) SendPreparedMessage ¶
func (socket *ReconnectingRegisteredCallbacksWebsocket) SendPreparedMessage(preparedMessage *ws.PreparedMessage) error
func (*ReconnectingRegisteredCallbacksWebsocket) SendPrivateMessage ¶
func (*ReconnectingRegisteredCallbacksWebsocket) SendText ¶
func (socket *ReconnectingRegisteredCallbacksWebsocket) SendText(text string) error
func (*ReconnectingRegisteredCallbacksWebsocket) SetHTTPHeader ¶
func (socket *ReconnectingRegisteredCallbacksWebsocket) SetHTTPHeader(httpHeader http.Header)
func (*ReconnectingRegisteredCallbacksWebsocket) SetURL ¶
func (socket *ReconnectingRegisteredCallbacksWebsocket) SetURL(URL string)
type RegisteredCallbacksWebsocket ¶
type RegisteredCallbacksWebsocket struct {
OnMessage func(messageType int, msg []byte)
OnError func(err error)
OnClose func(code int, reason string)
// contains filtered or unexported fields
}
func (*RegisteredCallbacksWebsocket) Close ¶
func (socket *RegisteredCallbacksWebsocket) Close()
func (*RegisteredCallbacksWebsocket) GetParserRegistry ¶
func (socket *RegisteredCallbacksWebsocket) GetParserRegistry() *parser.MessageParsers_Registry
func (*RegisteredCallbacksWebsocket) SendJSON ¶
func (socket *RegisteredCallbacksWebsocket) SendJSON(v interface{}) error
func (*RegisteredCallbacksWebsocket) SendPreparedMessage ¶
func (socket *RegisteredCallbacksWebsocket) SendPreparedMessage(preparedMessage *ws.PreparedMessage) error
func (*RegisteredCallbacksWebsocket) SendPrivateMessage ¶
func (*RegisteredCallbacksWebsocket) SendText ¶
func (socket *RegisteredCallbacksWebsocket) SendText(text string) error
Source Files
Click to show internal directories.
Click to hide internal directories.