server

package
v0.4.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 21, 2021 License: MIT Imports: 27 Imported by: 0

Documentation

Index

Constants

View Source 
const LOG_CHANNEL int = 2
View Source 
const LOG_CONNECTION int = 1
View Source 
const LOG_DEBUG int = 3
View Source 
const LOG_INFO int = 0
View Source 
const LOG_PROTOCOL int = 4
View Source 
const LOG_SILENT int = -1

Variables

View Source 
var DEFAULT_ADDRESS string = ":6837"
View Source 
var DEFAULT_CERT_FILE string = ""
View Source 
var DEFAULT_CONF_DIR string
View Source 
var DEFAULT_CONF_FILE string = ""
View Source 
var DEFAULT_CONF_NAME string = "nvdaRemoteServer.json"
View Source 
var DEFAULT_CONF_READ bool = true
View Source 
var DEFAULT_CREATE_DIR bool = false
View Source 
var DEFAULT_GEN_CERT_FILE string = ""
View Source 
var DEFAULT_GEN_CONF_DIR bool = false
View Source 
var DEFAULT_GEN_CONF_FILE string = ""
View Source 
var DEFAULT_KEY_FILE string = ""
View Source 
var DEFAULT_LAUNCH bool = true
View Source 
var DEFAULT_LOG_FILE string = ""
View Source 
var DEFAULT_LOG_LEVEL int = 0
View Source 
var DEFAULT_MOTD string = ""
View Source 
var DEFAULT_MOTD_ALWAYS_DISPLAY bool = false
View Source 
var DEFAULT_PID_FILE string = ""
View Source 
var DEFAULT_SEND_ORIGIN bool = true
View Source 
var EndMessage byte = '\n'
View Source 
var Launch bool
View Source 
var PID int
View Source 
var PID_STR string
View Source 
var PS string = string(os.PathSeparator)
View Source 
var Servers []*Server
View Source 
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 interface{}) ([]byte, error)

func FindClient 

func FindClient(c *Client) bool

func JsonAdd 

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

func Launch_fail added in v0.2.2 

func Launch_fail()

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 PidfileClear added in v0.3.5 

func PidfileClear()

func PidfileSet added in v0.3.5 

func PidfileSet()

func RemoveChannel 

func RemoveChannel(name string)

func RemoveClient 

func RemoveClient(c *Client)

func Start 

func Start() int

Types

type AddressList added in v0.3.1 

type AddressList []string

func (*AddressList) Set added in v0.3.1 

func (a *AddressList) Set(v string) error

func (*AddressList) String added in v0.3.1 

func (a *AddressList) String() string

type Cfg added in v0.4.0 

type Cfg struct {
	PidFile           string      `json:"pid_file"`
	LogFile           string      `json:"log_file"`
	LogLevel          int         `json:"log_level"`
	Addresses         AddressList `json:"addresses"`
	Cert              string      `json:"cert_file"`
	Key               string      `json:"key_file"`
	Motd              string      `json:"motd"`
	MotdAlwaysDisplay bool        `json:"motd_always_display"`
	SendOrigin        bool        `json:"send_origin"`
	// contains filtered or unexported fields
}

func (*Cfg) CmdGet added in v0.4.0 

func (c *Cfg) CmdGet()

func (*Cfg) CmdSet added in v0.4.0 

func (c *Cfg) CmdSet()

func (*Cfg) Cwd added in v0.4.0 

func (c *Cfg) Cwd(d string)

func (*Cfg) Decode added in v0.4.0 

func (c *Cfg) Decode(d []byte) error

func (*Cfg) FindFile added in v0.4.0 

func (c *Cfg) FindFile() string

func (*Cfg) Generate added in v0.4.0 

func (c *Cfg) Generate() error

func (*Cfg) IsDefault added in v0.4.0 

func (c *Cfg) IsDefault() bool

func (*Cfg) Log added in v0.4.0 

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

func (*Cfg) LogWrite added in v0.4.0 

func (c *Cfg) LogWrite()

func (*Cfg) Log_error added in v0.4.0 

func (c *Cfg) Log_error(msg ...interface{})

func (*Cfg) Read added in v0.4.0 

func (c *Cfg) Read() error

func (*Cfg) ReadFile added in v0.4.0 

func (c *Cfg) ReadFile(f string) ([]byte, error)

func (*Cfg) SearchFile added in v0.4.0 

func (c *Cfg) SearchFile(f string) string

func (*Cfg) Setup added in v0.4.0 

func (c *Cfg) Setup() error

func (*Cfg) Write added in v0.4.0 

func (c *Cfg) Write(file string) error

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 added in v0.1.10 

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 added in v0.1.10 

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"`
	MotdAlwaysDisplay 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

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.