tcp_server

Documentation

Index

• Constants
• func DispatchResults(conn net.Conn, res api.Response)
• func HandleRequest(conn net.Conn, reqch chan api.Request, resch chan api.Response)
• func ParseRequest(data []byte) api.Request
• func ReadFull(conn net.Conn) []byte
• func StartTCPServer(reqch chan api.Request, resch chan api.Response)
• type Client
• type Server

Constants

const (
	CONN_HOST = "localhost"
	CONN_PORT = "5309"
	CONN_TYPE = "tcp"
)

Functions

func DispatchResults

func DispatchResults(conn net.Conn, res api.Response)

Dispatch results to the proper client

func HandleRequest

func HandleRequest(conn net.Conn, reqch chan api.Request, resch chan api.Response)

When we get a request, parse the msgpack'd data and send it to the API server

func ParseRequest

func ParseRequest(data []byte) api.Request

Decode raw bytes into an API Request

func ReadFull

func ReadFull(conn net.Conn) []byte

Read a full TCP request, up until the terminating seqeunce

func StartTCPServer

func StartTCPServer(reqch chan api.Request, resch chan api.Response)

The TCP Server listens for client connections, parses the msgpack'd data, and sends the request to the API server

Types

type Client

type Client struct {
	// Did the Client send the proper initialization request?
	Initialized bool

	// Is the client connected?
	Connected bool

	// Hooks the client is listening for
	Hooks string
}

type Server

type Server struct {
	Clients []Client
}