tcp

Documentation

Index

• Constants
• type ClientHandler
  • func (h *ClientHandler) Active(ctx channel.HandlerContext)
  • func (h *ClientHandler) Connect(ctx channel.HandlerContext, localAddr net.Addr, remoteAddr net.Addr, ...)
  • func (h *ClientHandler) Disconnect(ctx channel.HandlerContext, future channel.Future)
  • func (h *ClientHandler) Inactive(ctx channel.HandlerContext)
  • func (h *ClientHandler) Read(ctx channel.HandlerContext, obj interface{})
  • func (h *ClientHandler) ReadCompleted(ctx channel.HandlerContext)
  • func (h *ClientHandler) Registered(ctx channel.HandlerContext)
  • func (h *ClientHandler) Unregistered(ctx channel.HandlerContext)
  • func (h *ClientHandler) Write(ctx channel.HandlerContext, obj interface{}, future channel.Future)
• type DecodeHandler
  • func NewDecodeHandler() *DecodeHandler
• type Server
  • func (k *Server) Start(localAddr net.Addr)
• type ServerChildHandler
  • func (h *ServerChildHandler) Active(ctx channel.HandlerContext)
  • func (h *ServerChildHandler) Connect(ctx channel.HandlerContext, localAddr net.Addr, remoteAddr net.Addr, ...)
  • func (h *ServerChildHandler) Disconnect(ctx channel.HandlerContext, future channel.Future)
  • func (h *ServerChildHandler) Inactive(ctx channel.HandlerContext)
  • func (h *ServerChildHandler) Read(ctx channel.HandlerContext, obj interface{})
  • func (h *ServerChildHandler) ReadCompleted(ctx channel.HandlerContext)
  • func (h *ServerChildHandler) Registered(ctx channel.HandlerContext)
  • func (h *ServerChildHandler) Unregistered(ctx channel.HandlerContext)
  • func (h *ServerChildHandler) Write(ctx channel.HandlerContext, obj interface{}, future channel.Future)

Constants

const BODY = channel.ReplayState(2)

const HEAD = channel.ReplayState(1)

Types

type ClientHandler

type ClientHandler struct {
	channel.DefaultHandler
}

func (*ClientHandler) Active

func (h *ClientHandler) Active(ctx channel.HandlerContext)

func (*ClientHandler) Connect

func (h *ClientHandler) Connect(ctx channel.HandlerContext, localAddr net.Addr, remoteAddr net.Addr, future channel.Future)

func (*ClientHandler) Disconnect

func (h *ClientHandler) Disconnect(ctx channel.HandlerContext, future channel.Future)

func (*ClientHandler) Inactive

func (h *ClientHandler) Inactive(ctx channel.HandlerContext)

func (*ClientHandler) Read

func (h *ClientHandler) Read(ctx channel.HandlerContext, obj interface{})

func (*ClientHandler) ReadCompleted

func (h *ClientHandler) ReadCompleted(ctx channel.HandlerContext)

func (*ClientHandler) Registered

func (h *ClientHandler) Registered(ctx channel.HandlerContext)

func (*ClientHandler) Unregistered

func (h *ClientHandler) Unregistered(ctx channel.HandlerContext)

func (*ClientHandler) Write

func (h *ClientHandler) Write(ctx channel.HandlerContext, obj interface{}, future channel.Future)

type DecodeHandler

type DecodeHandler struct {
	*channel.ReplayDecoder
	// contains filtered or unexported fields
}

func NewDecodeHandler

func NewDecodeHandler() *DecodeHandler

type Server

type Server struct {
}

func (*Server) Start

func (k *Server) Start(localAddr net.Addr)

type ServerChildHandler

type ServerChildHandler struct {
	channel.DefaultHandler
}

func (*ServerChildHandler) Active

func (h *ServerChildHandler) Active(ctx channel.HandlerContext)

func (*ServerChildHandler) Connect

func (h *ServerChildHandler) Connect(ctx channel.HandlerContext, localAddr net.Addr, remoteAddr net.Addr, future channel.Future)

func (*ServerChildHandler) Disconnect

func (h *ServerChildHandler) Disconnect(ctx channel.HandlerContext, future channel.Future)

func (*ServerChildHandler) Inactive

func (h *ServerChildHandler) Inactive(ctx channel.HandlerContext)

func (*ServerChildHandler) Read

func (h *ServerChildHandler) Read(ctx channel.HandlerContext, obj interface{})

func (*ServerChildHandler) ReadCompleted

func (h *ServerChildHandler) ReadCompleted(ctx channel.HandlerContext)

func (*ServerChildHandler) Registered

func (h *ServerChildHandler) Registered(ctx channel.HandlerContext)

func (*ServerChildHandler) Unregistered

func (h *ServerChildHandler) Unregistered(ctx channel.HandlerContext)

func (*ServerChildHandler) Write

func (h *ServerChildHandler) Write(ctx channel.HandlerContext, obj interface{}, future channel.Future)