server

package
v0.0.0-...-2ac5646 Latest Latest
Warning

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

Go to latest
Published: Jan 25, 2017 License: Apache-2.0 Imports: 21 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func LocalIP

func LocalIP() (net.IP, error)

func PublishCmdline

func PublishCmdline()

func ReadMessage

func ReadMessage(r io.Reader) (uint32, []byte, error)

func RegisterCoreDump

func RegisterCoreDump(path string)

Types

type Client

type Client struct {
	Session
}

type Server

type Server struct {
	// contains filtered or unexported fields
}

func NewServer

func NewServer(store storage.JobQueue) *Server

func (*Server) EvtLoop

func (self *Server) EvtLoop()

func (*Server) Start

func (self *Server) Start(addr string)

type Session

type Session struct {
	SessionId int64

	ConnectAt time.Time
	// contains filtered or unexported fields
}

func (*Session) Send

func (self *Session) Send(data []byte) bool

type Tuple

type Tuple struct {
	// contains filtered or unexported fields
}

type Worker

type Worker struct {
	net.Conn
	Session
	// contains filtered or unexported fields
}

func (*Worker) MarshalJSON

func (self *Worker) MarshalJSON() ([]byte, error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL