filters

Documentation

Index

• Constants
• type ConnectCB
• type ConnectFilter
  • func NewConnect(cb ConnectCB) *ConnectFilter
  • func (cf *ConnectFilter) HandleOpen(ctx fairy.IFilterCtx)
  • func (cf *ConnectFilter) Name() string
• type ExecutorFilter
  • func NewExecutor() *ExecutorFilter
  • func (ef *ExecutorFilter) HandleRead(ctx fairy.IFilterCtx)
  • func (ef *ExecutorFilter) Name() string
• type FrameFilter
  • func NewFrame(frame fairy.IFrame) *FrameFilter
  • func (ff *FrameFilter) HandleRead(ctx fairy.IFilterCtx)
  • func (ff *FrameFilter) HandleWrite(ctx fairy.IFilterCtx)
  • func (ff *FrameFilter) Name() string
• type LoggingFilter
  • func NewLogging() *LoggingFilter
  • func (lf *LoggingFilter) HandleClose(ctx fairy.IFilterCtx)
  • func (lf *LoggingFilter) HandleError(ctx fairy.IFilterCtx)
  • func (lf *LoggingFilter) HandleOpen(ctx fairy.IFilterCtx)
  • func (lf *LoggingFilter) HandleRead(ctx fairy.IFilterCtx)
  • func (lf *LoggingFilter) HandleWrite(ctx fairy.IFilterCtx)
  • func (lf *LoggingFilter) Name() string
  • func (lf *LoggingFilter) SetMask(m int)
• type PacketFilter
  • func NewPacket(identity fairy.IIdentity, codec fairy.ICodec) *PacketFilter
  • func (pf *PacketFilter) HandleRead(ctx fairy.IFilterCtx)
  • func (self *PacketFilter) HandleWrite(ctx fairy.IFilterCtx)
  • func (pf *PacketFilter) Name() string
• type RC4Filter
  • func NewRC4(key string) *RC4Filter
  • func (rf *RC4Filter) HandleRead(ctx fairy.IFilterCtx)
  • func (rf *RC4Filter) HandleWrite(ctx fairy.IFilterCtx)
  • func (rf *RC4Filter) Name() string
  • func (rf *RC4Filter) SetKey(key string)
• type TelnetCB
• type TelnetFilter
  • func NewTelnet() *TelnetFilter
  • func (self *TelnetFilter) HandleOpen(ctx fairy.IFilterCtx)
  • func (self *TelnetFilter) HandleRead(ctx fairy.IFilterCtx)
  • func (tf *TelnetFilter) HandleWrite(ctx fairy.IFilterCtx)
  • func (tf *TelnetFilter) Name() string
  • func (tf *TelnetFilter) SetCallback(cb TelnetCB)
  • func (tf *TelnetFilter) SetPrompt(value string)

Constants

const (
	LoggingRead    = 0x01
	LoggingWrite   = 0x02
	LoggingAccept  = 0x04
	LoggingConnect = 0x08
	LoggingClose   = 0x10
	LoggingError   = 0x20
	LoggingAll     = 0xff
)

const (
	// TelnetMsgKey 消息唯一标识
	TelnetMsgKey = "TelnetMsg"
)

Types

type ConnectCB

type ConnectCB func(fairy.IConn)

ConnectCB 连接回调函数

type ConnectFilter

type ConnectFilter struct {
	base.Filter
	// contains filtered or unexported fields
}

ConnectFilter 连接成功时调用回调,注意:并非线程安全

func NewConnect

func NewConnect(cb ConnectCB) *ConnectFilter

NewConnect 连接成功回调

func (*ConnectFilter) HandleOpen

func (cf *ConnectFilter) HandleOpen(ctx fairy.IFilterCtx)

func (*ConnectFilter) Name

func (cf *ConnectFilter) Name() string

type ExecutorFilter

type ExecutorFilter struct {
	base.Filter
}

ExecutorFilter 默认的消息执行

func NewExecutor

func NewExecutor() *ExecutorFilter

func (*ExecutorFilter) HandleRead

func (ef *ExecutorFilter) HandleRead(ctx fairy.IFilterCtx)

HandleRead 转发到调度器中执行

func (*ExecutorFilter) Name

func (ef *ExecutorFilter) Name() string

type FrameFilter

type FrameFilter struct {
	base.Filter
	// contains filtered or unexported fields
}

FrameFilter 粘包处理

func NewFrame

func NewFrame(frame fairy.IFrame) *FrameFilter

func (*FrameFilter) HandleRead

func (ff *FrameFilter) HandleRead(ctx fairy.IFilterCtx)

func (*FrameFilter) HandleWrite

func (ff *FrameFilter) HandleWrite(ctx fairy.IFilterCtx)

func (*FrameFilter) Name

func (ff *FrameFilter) Name() string

type LoggingFilter

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

func NewLogging

func NewLogging() *LoggingFilter

func (*LoggingFilter) HandleClose

func (lf *LoggingFilter) HandleClose(ctx fairy.IFilterCtx)

func (*LoggingFilter) HandleError

func (lf *LoggingFilter) HandleError(ctx fairy.IFilterCtx)

func (*LoggingFilter) HandleOpen

func (lf *LoggingFilter) HandleOpen(ctx fairy.IFilterCtx)

func (*LoggingFilter) HandleRead

func (lf *LoggingFilter) HandleRead(ctx fairy.IFilterCtx)

func (*LoggingFilter) HandleWrite

func (lf *LoggingFilter) HandleWrite(ctx fairy.IFilterCtx)

func (*LoggingFilter) Name

func (lf *LoggingFilter) Name() string

func (*LoggingFilter) SetMask

func (lf *LoggingFilter) SetMask(m int)

type PacketFilter

type PacketFilter struct {
	base.Filter
	// contains filtered or unexported fields
}

PacketFilter 创建并解析Packet

func NewPacket

func NewPacket(identity fairy.IIdentity, codec fairy.ICodec) *PacketFilter

func (*PacketFilter) HandleRead

func (pf *PacketFilter) HandleRead(ctx fairy.IFilterCtx)

HandleRead 从Buffer中解析Packet

func (*PacketFilter) HandleWrite

func (self *PacketFilter) HandleWrite(ctx fairy.IFilterCtx)

func (*PacketFilter) Name

func (pf *PacketFilter) Name() string

type RC4Filter

type RC4Filter struct {
	base.Filter
	// contains filtered or unexported fields
}

RC4Filter rc4加密算法,key固定不可变

func NewRC4

func NewRC4(key string) *RC4Filter

NewRC4 create rc4 filter with secret default key

func (*RC4Filter) HandleRead

func (rf *RC4Filter) HandleRead(ctx fairy.IFilterCtx)

func (*RC4Filter) HandleWrite

func (rf *RC4Filter) HandleWrite(ctx fairy.IFilterCtx)

func (*RC4Filter) Name

func (rf *RC4Filter) Name() string

func (*RC4Filter) SetKey

func (rf *RC4Filter) SetKey(key string)

type TelnetCB

type TelnetCB func(conn fairy.IConn, str string)

TelnetCB 读处理回调

type TelnetFilter

type TelnetFilter struct {
	base.Filter
	// contains filtered or unexported fields
}

TelnetFilter 远程连接

func NewTelnet

func NewTelnet() *TelnetFilter

NewTelnet 创建TelnetFilter

func (*TelnetFilter) HandleOpen

func (self *TelnetFilter) HandleOpen(ctx fairy.IFilterCtx)

func (*TelnetFilter) HandleRead

func (self *TelnetFilter) HandleRead(ctx fairy.IFilterCtx)

func (*TelnetFilter) HandleWrite

func (tf *TelnetFilter) HandleWrite(ctx fairy.IFilterCtx)

func (*TelnetFilter) Name

func (tf *TelnetFilter) Name() string

func (*TelnetFilter) SetCallback

func (tf *TelnetFilter) SetCallback(cb TelnetCB)

SetCallback 设置回调函数

func (*TelnetFilter) SetPrompt

func (tf *TelnetFilter) SetPrompt(value string)

SetPrompt 设置提示符