common

Documentation

Index

• Constants
• func GetLocalTime() (*time.Location, error)
• func InitLogging(forceColours, disableTimestamp bool)
• func InitSyslog()
• func InitUid() error
• func ManageHeartbeats(cm ConnectionManager)
• func SetPongHandler(conn *WebsocketConn)
• type ConnectionManager
• type LoginMessage
• type WebsocketConn
  • func NewWebsocketConn(conn *websocket.Conn, descFmt string, args ...interface{}) *WebsocketConn
  • func (wsc WebsocketConn) String() string

Constants

const (
	MaxMessageSize = 8192
	RWTimeout      = 60 * time.Second
	HBTimeout      = RWTimeout / 2
)

Functions

func GetLocalTime

func GetLocalTime() (*time.Location, error)

func InitLogging

func InitLogging(forceColours, disableTimestamp bool)

func InitSyslog

func InitSyslog()

func InitUid

func InitUid() error

func ManageHeartbeats

func ManageHeartbeats(cm ConnectionManager)

func SetPongHandler

func SetPongHandler(conn *WebsocketConn)

Types

type ConnectionManager

type ConnectionManager interface {
	GetConnections() []*WebsocketConn
	RemoveConnection(conn *WebsocketConn)
}

type LoginMessage

type LoginMessage struct {
	AsReceiver bool   `json:"as_receiver"`
	Token      string `json:"token"`
}

type WebsocketConn

type WebsocketConn struct {
	Conn *websocket.Conn
	Desc string
}

func NewWebsocketConn

func NewWebsocketConn(conn *websocket.Conn, descFmt string, args ...interface{}) *WebsocketConn

func (WebsocketConn) String

func (wsc WebsocketConn) String() string