server

Documentation

Index

• Constants
• Variables
• func AddChannel(name string, c *Client)
• func AddClient(c *Client)
• func Authorize(c *Client, data []byte) error
• func Configure() error
• func Encode(data Data) ([]byte, error)
• func FindClient(c *Client) bool
• func JsonAdd(data []byte, key string, value interface{}) ([]byte, error)
• func Log(level int, msg ...interface{})
• func Log_error(msg ...interface{})
• func MessageReceived(c *Client, pmsg []byte)
• func RemoveChannel(name string)
• func RemoveClient(c *Client)
• func Start() int
• type Client
  • func (c *Client) ClearChannel()
  • func (c *Client) GetChannel() *ClientChannel
  • func (c *Client) GetConnectionType() string
  • func (c *Client) GetID() int
  • func (c *Client) GetIP() string
  • func (c *Client) GetVersion() int
  • func (c *Client) Send(b []byte)
  • func (c *Client) SetChannel(clientChannel *ClientChannel)
  • func (c *Client) SetConnectionType(ctype string)
  • func (c *Client) SetID(id int)
  • func (c *Client) SetVersion(version int)
• type ClientChannel
  • func FindChannel(name string) *ClientChannel
  • func NewClientChannel(name string, client *Client) *ClientChannel
  • func (c *ClientChannel) Add(client *Client)
  • func (c *ClientChannel) EndIfEmpty() bool
  • func (c *ClientChannel) Name() string
  • func (c *ClientChannel) Quit()
  • func (c *ClientChannel) Remove(client *Client)
  • func (c *ClientChannel) SendAll(msg []byte, client *Client)
  • func (c *ClientChannel) SendOthers(msg []byte, client *Client)
• type ClientData
• type Data
  • func Decode(data []byte) (Data, error)
• type Server
  • func New(address string) *Server
  • func NewWithTLSConfig(address string, config *tls.Config) *Server
  • func (s *Server) Listen() error
  • func (s *Server) MessageTerminator(terminator byte)

Constants

const DEFAULT_LOGLEVEL int = 0

const DEFAULT_PORT int = 6837

const LOG_CHANNEL int = 2

const LOG_CONNECTION int = 1

const LOG_DEBUG int = 3

const LOG_INFO int = 0

const LOG_PROTOCOL int = 4

const LOG_SILENT int = -1

Variables

var Cert string

var EndMessage byte = '\n'

var Key string

var StopServers context.CancelFunc

Functions

func AddChannel

func AddChannel(name string, c *Client)

func AddClient

func AddClient(c *Client)

func Authorize

func Authorize(c *Client, data []byte) error

func Configure

func Configure() error

func Encode

func Encode(data Data) ([]byte, error)

func FindClient

func FindClient(c *Client) bool

func JsonAdd

func JsonAdd(data []byte, key string, value interface{}) ([]byte, error)

func Log

func Log(level int, msg ...interface{})

func Log_error

func Log_error(msg ...interface{})

func MessageReceived

func MessageReceived(c *Client, pmsg []byte)

func RemoveChannel

func RemoveChannel(name string)

func RemoveClient

func RemoveClient(c *Client)

func Start

func Start() int

Types

type Client

type Client struct {
	sync.Mutex

	Close context.CancelFunc
	// contains filtered or unexported fields
}

func (*Client) ClearChannel

func (c *Client) ClearChannel()

func (*Client) GetChannel

func (c *Client) GetChannel() *ClientChannel

func (*Client) GetConnectionType

func (c *Client) GetConnectionType() string

func (*Client) GetID

func (c *Client) GetID() int

func (*Client) GetIP

func (c *Client) GetIP() string

func (*Client) GetVersion

func (c *Client) GetVersion() int

func (*Client) Send

func (c *Client) Send(b []byte)

Send bytes to client

func (*Client) SetChannel

func (c *Client) SetChannel(clientChannel *ClientChannel)

func (*Client) SetConnectionType

func (c *Client) SetConnectionType(ctype string)

func (*Client) SetID

func (c *Client) SetID(id int)

func (*Client) SetVersion

func (c *Client) SetVersion(version int)

type ClientChannel

type ClientChannel struct {
	sync.Mutex

	ClientsAll    map[int]*Client
	ClientsMaster map[int]*Client
	ClientsSlave  map[int]*Client
	// contains filtered or unexported fields
}

func FindChannel

func FindChannel(name string) *ClientChannel

func NewClientChannel

func NewClientChannel(name string, client *Client) *ClientChannel

func (*ClientChannel) Add

func (c *ClientChannel) Add(client *Client)

func (*ClientChannel) EndIfEmpty

func (c *ClientChannel) EndIfEmpty() bool

func (*ClientChannel) Name

func (c *ClientChannel) Name() string

func (*ClientChannel) Quit

func (c *ClientChannel) Quit()

func (*ClientChannel) Remove

func (c *ClientChannel) Remove(client *Client)

func (*ClientChannel) SendAll

func (c *ClientChannel) SendAll(msg []byte, client *Client)

func (*ClientChannel) SendOthers

func (c *ClientChannel) SendOthers(msg []byte, client *Client)

type ClientData

type ClientData struct {
	ID             int    `json:"id"`
	ConnectionType string `json:"connection_type"`
}

type Data

type Data struct {
	Type             string       `json:"type"`
	Channel          string       `json:"channel,omitempty"`
	ConnectionType   string       `json:"connection_type,omitempty"`
	Version          int          `json:"version,omitempty"`
	Origin           int          `json:"origin,omitempty"`
	Key              string       `json:"key,omitempty"`
	ID               int          `json:"user_id,omitempty"`
	UserIds          []int        `json:"user_ids,omitempty"`
	Clients          []ClientData `json:"clients,omitempty"`
	Client           *ClientData  `json:"client,omitempty"`
	Error            string       `json:"error,omitempty"`
	Motd             string       `json:"motd,omitempty"`
	MotdForceDisplay bool         `json:"force_display,omitempty"`
}

func Decode

func Decode(data []byte) (Data, error)

type Server

type Server struct {
	sync.Mutex
	sync.WaitGroup

	Stop context.CancelFunc
	// contains filtered or unexported fields
}

TCP server

var S4 *Server

var S6 *Server

var SAll *Server

func New

func New(address string) *Server

Creates new tcp server instance

func NewWithTLSConfig

func NewWithTLSConfig(address string, config *tls.Config) *Server

func (*Server) Listen

func (s *Server) Listen() error

Listen starts network server

func (*Server) MessageTerminator

func (s *Server) MessageTerminator(terminator byte)

Set message terminator