queryport

Documentation

Index

• func Application(config c.Config)
• type RequestHandler
• type Server
  • func NewServer(laddr string, callb RequestHandler, config c.Config) (s *Server, err error)
  • func (s *Server) Close() (err error)
  • func (s *Server) Statistics() ServerStats
• type ServerStats

Functions

func Application

func Application(config c.Config)

Application is example application logic that uses query-port server

Types

type RequestHandler

type RequestHandler func(
	req interface{}, conn net.Conn, quitch <-chan bool)

RequestHandler shall interpret the request message from client and post response message(s) on `respch` channel, until `quitch` is closed. When there are no more response to post handler shall close `respch`.

type Server

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

Server handles queryport connections.

func NewServer

func NewServer(
	laddr string, callb RequestHandler,
	config c.Config) (s *Server, err error)

NewServer creates a new queryport daemon.

func (*Server) Close

func (s *Server) Close() (err error)

Close queryport daemon. Close method only shuts down lister sockets Established connections will be only closed once client closes those connections.

func (*Server) Statistics

func (s *Server) Statistics() ServerStats

type ServerStats

type ServerStats struct {
	Connections int64
}