server

Documentation

Index

• Constants
• func NewServer() apis.IServer
• func Server(serverType string, serverAddress string) (apis.IServer, error)
• type ConnectionServer
  • func (cs *ConnectionServer) Shutdown()
  • func (cs *ConnectionServer) Start()
  • func (cs *ConnectionServer) Stop()
• type FuncHandler
• type QueueOpFunc
• type SessionHandler
  • func NewSessionHandler(conn net.Conn, services *qmgr.ServiceManager) *SessionHandler
  • func (s *SessionHandler) DispatchConn()
  • func (s *SessionHandler) QuitListener()
  • func (s *SessionHandler) Stop()
  • func (s *SessionHandler) WriteResponse(resp apis.IResponse) error

Constants

const (
	CMD_PING       = "PING"
	CMD_CREATE_SVC = "CRT"
	CMD_DROP_SVC   = "DROP"
	CMD_QUIT       = "QUIT"
	CMD_UNIX_TS    = "TS"
	CMD_LIST       = "LIST"
	CMD_CTX        = "CTX"
	CMD_LOGLEVEL   = "LOGLEVEL"
	CMD_PANIC      = "PANIC"
	CMD_DBSTATS    = "DBSTATS"
)

const (
	SimpleServerType = "simple"
)

Functions

func NewServer

func NewServer() apis.IServer

func Server

func Server(serverType string, serverAddress string) (apis.IServer, error)

Types

type ConnectionServer

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

func (*ConnectionServer) Shutdown

func (cs *ConnectionServer) Shutdown()

func (*ConnectionServer) Start

func (cs *ConnectionServer) Start()

func (*ConnectionServer) Stop

func (cs *ConnectionServer) Stop()

type FuncHandler

type FuncHandler func([]string) apis.IResponse

type QueueOpFunc

type QueueOpFunc func(req []string) error

type SessionHandler

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

func NewSessionHandler

func NewSessionHandler(conn net.Conn, services *qmgr.ServiceManager) *SessionHandler

func (*SessionHandler) DispatchConn

func (s *SessionHandler) DispatchConn()

DispatchConn dispatcher. Entry point to start connection handling.

func (*SessionHandler) QuitListener

func (s *SessionHandler) QuitListener()

func (*SessionHandler) Stop

func (s *SessionHandler) Stop()

Stop the processing loop.

func (*SessionHandler) WriteResponse

func (s *SessionHandler) WriteResponse(resp apis.IResponse) error

WriteResponse writes apis.IResponse into connection writer.