tcp

Documentation

Index

• func NewAgnetClient(listen string, handler func(channel.Pipeline)) error
• func StartAgnetServer(listen string, handler func(channel.Pipeline)) error
• type ClientDefaultHandler
  • func NewClientDefaultHandler() *ClientDefaultHandler
  • func (c *ClientDefaultHandler) ChannelActive(ctx channel.HandlerContext)
  • func (c *ClientDefaultHandler) ChannelInActive(ctx channel.HandlerContext)
  • func (c *ClientDefaultHandler) ChannelRead(_ channel.HandlerContext, msg interface{})
  • func (c *ClientDefaultHandler) OnError(ctx channel.HandlerContext, err error)
• type ServerDefaultHandler
  • func NewServerDefaultHandler() *ServerDefaultHandler
  • func (s *ServerDefaultHandler) ChannelActive(ctx channel.HandlerContext)
  • func (s *ServerDefaultHandler) ChannelInActive(ctx channel.HandlerContext)
  • func (s *ServerDefaultHandler) ChannelRead(ctx channel.HandlerContext, msg interface{})
  • func (s *ServerDefaultHandler) OnError(ctx channel.HandlerContext, err error)

Functions

func NewAgnetClient

func NewAgnetClient(listen string, handler func(channel.Pipeline)) error

func StartAgnetServer

func StartAgnetServer(listen string, handler func(channel.Pipeline)) error

Types

type ClientDefaultHandler

type ClientDefaultHandler struct {
	Log *log.Entry
}

func NewClientDefaultHandler

func NewClientDefaultHandler() *ClientDefaultHandler

func (*ClientDefaultHandler) ChannelActive

func (c *ClientDefaultHandler) ChannelActive(ctx channel.HandlerContext)

func (*ClientDefaultHandler) ChannelInActive

func (c *ClientDefaultHandler) ChannelInActive(ctx channel.HandlerContext)

func (*ClientDefaultHandler) ChannelRead

func (c *ClientDefaultHandler) ChannelRead(_ channel.HandlerContext, msg interface{})

func (*ClientDefaultHandler) OnError

func (c *ClientDefaultHandler) OnError(ctx channel.HandlerContext, err error)

type ServerDefaultHandler

type ServerDefaultHandler struct {
	Log *log.Entry
}

func NewServerDefaultHandler

func NewServerDefaultHandler() *ServerDefaultHandler

func (*ServerDefaultHandler) ChannelActive

func (s *ServerDefaultHandler) ChannelActive(ctx channel.HandlerContext)

func (*ServerDefaultHandler) ChannelInActive

func (s *ServerDefaultHandler) ChannelInActive(ctx channel.HandlerContext)

func (*ServerDefaultHandler) ChannelRead

func (s *ServerDefaultHandler) ChannelRead(ctx channel.HandlerContext, msg interface{})

func (*ServerDefaultHandler) OnError

func (s *ServerDefaultHandler) OnError(ctx channel.HandlerContext, err error)