filter

Documentation

Index

• func RegisterFilter(name string, filter func() interface{})
• type Filter
  • func New(cfg config.Server) *Filter
  • func (this *Filter) HandleClientConnect(client net.Conn) error
  • func (this *Filter) HandleClientDisconnect(client net.Conn)
  • func (this *Filter) HandleClientRead(client net.Conn, rwc core.ReadWriteCount)
  • func (this *Filter) HandleClientRequest(buf []byte) error
  • func (this *Filter) HandleClientWrite(client net.Conn, rwc core.ReadWriteCount)
  • func (this *Filter) Start()
  • func (this *Filter) Stop()
• type FilterInterface
• type FilterRequestContent
  • func (this *FilterRequestContent) Connect(client net.Conn) error
  • func (this *FilterRequestContent) Disconnect(client net.Conn)
  • func (this *FilterRequestContent) Init(cfg config.Server) bool
  • func (this *FilterRequestContent) Read(client net.Conn, rwc core.ReadWriteCount)
  • func (this *FilterRequestContent) Request(buf []byte) error
  • func (this *FilterRequestContent) Stop()
  • func (this *FilterRequestContent) Write(client net.Conn, rwc core.ReadWriteCount)
• type LimitChinaAccessFilter
  • func (this *LimitChinaAccessFilter) Connect(client net.Conn) error
  • func (this *LimitChinaAccessFilter) Disconnect(client net.Conn)
  • func (this *LimitChinaAccessFilter) Init(cfg config.Server) bool
  • func (this *LimitChinaAccessFilter) Read(client net.Conn, rwc core.ReadWriteCount)
  • func (this *LimitChinaAccessFilter) Request(buf []byte) error
  • func (this *LimitChinaAccessFilter) Stop()
  • func (this *LimitChinaAccessFilter) Write(client net.Conn, rwc core.ReadWriteCount)
• type LimitMaxConnectionFilter
  • func (this *LimitMaxConnectionFilter) Connect(client net.Conn) error
  • func (this *LimitMaxConnectionFilter) Disconnect(client net.Conn)
  • func (this *LimitMaxConnectionFilter) Init(cfg config.Server) bool
  • func (this *LimitMaxConnectionFilter) Read(client net.Conn, rwc core.ReadWriteCount)
  • func (this *LimitMaxConnectionFilter) Request(buf []byte) error
  • func (this *LimitMaxConnectionFilter) Stop()
  • func (this *LimitMaxConnectionFilter) Write(client net.Conn, rwc core.ReadWriteCount)
• type LimitPerIPConnectionFilter
  • func (this *LimitPerIPConnectionFilter) Connect(client net.Conn) error
  • func (this *LimitPerIPConnectionFilter) Disconnect(client net.Conn)
  • func (this *LimitPerIPConnectionFilter) Init(cfg config.Server) bool
  • func (this *LimitPerIPConnectionFilter) Read(client net.Conn, rwc core.ReadWriteCount)
  • func (this *LimitPerIPConnectionFilter) Request(buf []byte) error
  • func (this *LimitPerIPConnectionFilter) Stop()
  • func (this *LimitPerIPConnectionFilter) Write(client net.Conn, rwc core.ReadWriteCount)
• type LimitPeripRateFilter
  • func (this *LimitPeripRateFilter) Connect(client net.Conn) error
  • func (this *LimitPeripRateFilter) Disconnect(client net.Conn)
  • func (this *LimitPeripRateFilter) Init(cfg config.Server) bool
  • func (this *LimitPeripRateFilter) Read(client net.Conn, rwc core.ReadWriteCount)
  • func (this *LimitPeripRateFilter) Request(buf []byte) error
  • func (this *LimitPeripRateFilter) Stop()
  • func (this *LimitPeripRateFilter) Write(client net.Conn, rwc core.ReadWriteCount)
• type LimitReconnectRateFilter
  • func (this *LimitReconnectRateFilter) Connect(client net.Conn) error
  • func (this *LimitReconnectRateFilter) Disconnect(client net.Conn)
  • func (this *LimitReconnectRateFilter) Init(cfg config.Server) bool
  • func (this *LimitReconnectRateFilter) Read(client net.Conn, rwc core.ReadWriteCount)
  • func (this *LimitReconnectRateFilter) Request(buf []byte) error
  • func (this *LimitReconnectRateFilter) Stop()
  • func (this *LimitReconnectRateFilter) Write(client net.Conn, rwc core.ReadWriteCount)

Functions

func RegisterFilter

func RegisterFilter(name string, filter func() interface{})

Types

type Filter

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

func New

func New(cfg config.Server) *Filter

func (*Filter) HandleClientConnect

func (this *Filter) HandleClientConnect(client net.Conn) error

func (*Filter) HandleClientDisconnect

func (this *Filter) HandleClientDisconnect(client net.Conn)

func (*Filter) HandleClientRead

func (this *Filter) HandleClientRead(client net.Conn, rwc core.ReadWriteCount)

func (*Filter) HandleClientRequest

func (this *Filter) HandleClientRequest(buf []byte) error

func (*Filter) HandleClientWrite

func (this *Filter) HandleClientWrite(client net.Conn, rwc core.ReadWriteCount)

func (*Filter) Start

func (this *Filter) Start()

func (*Filter) Stop

func (this *Filter) Stop()

type FilterInterface

type FilterInterface interface {
	Init(cf config.Server) bool
	Connect(client net.Conn) error
	Read(client net.Conn, rwc core.ReadWriteCount)
	Write(client net.Conn, rwc core.ReadWriteCount)
	Request([]byte) error
	Disconnect(client net.Conn)
	Stop()
}

type FilterRequestContent

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

func (*FilterRequestContent) Connect

func (this *FilterRequestContent) Connect(client net.Conn) error

func (*FilterRequestContent) Disconnect

func (this *FilterRequestContent) Disconnect(client net.Conn)

func (*FilterRequestContent) Init

func (this *FilterRequestContent) Init(cfg config.Server) bool

func (*FilterRequestContent) Read

func (this *FilterRequestContent) Read(client net.Conn, rwc core.ReadWriteCount)

func (*FilterRequestContent) Request

func (this *FilterRequestContent) Request(buf []byte) error

func (*FilterRequestContent) Stop

func (this *FilterRequestContent) Stop()

func (*FilterRequestContent) Write

func (this *FilterRequestContent) Write(client net.Conn, rwc core.ReadWriteCount)

type LimitChinaAccessFilter

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

func (*LimitChinaAccessFilter) Connect

func (this *LimitChinaAccessFilter) Connect(client net.Conn) error

func (*LimitChinaAccessFilter) Disconnect

func (this *LimitChinaAccessFilter) Disconnect(client net.Conn)

func (*LimitChinaAccessFilter) Init

func (this *LimitChinaAccessFilter) Init(cfg config.Server) bool

func (*LimitChinaAccessFilter) Read

func (this *LimitChinaAccessFilter) Read(client net.Conn, rwc core.ReadWriteCount)

func (*LimitChinaAccessFilter) Request

func (this *LimitChinaAccessFilter) Request(buf []byte) error

func (*LimitChinaAccessFilter) Stop

func (this *LimitChinaAccessFilter) Stop()

func (*LimitChinaAccessFilter) Write

func (this *LimitChinaAccessFilter) Write(client net.Conn, rwc core.ReadWriteCount)

type LimitMaxConnectionFilter

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

func (*LimitMaxConnectionFilter) Connect

func (this *LimitMaxConnectionFilter) Connect(client net.Conn) error

func (*LimitMaxConnectionFilter) Disconnect

func (this *LimitMaxConnectionFilter) Disconnect(client net.Conn)

func (*LimitMaxConnectionFilter) Init

func (this *LimitMaxConnectionFilter) Init(cfg config.Server) bool

func (*LimitMaxConnectionFilter) Read

func (this *LimitMaxConnectionFilter) Read(client net.Conn, rwc core.ReadWriteCount)

func (*LimitMaxConnectionFilter) Request

func (this *LimitMaxConnectionFilter) Request(buf []byte) error

func (*LimitMaxConnectionFilter) Stop

func (this *LimitMaxConnectionFilter) Stop()

func (*LimitMaxConnectionFilter) Write

func (this *LimitMaxConnectionFilter) Write(client net.Conn, rwc core.ReadWriteCount)

type LimitPerIPConnectionFilter

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

func (*LimitPerIPConnectionFilter) Connect

func (this *LimitPerIPConnectionFilter) Connect(client net.Conn) error

func (*LimitPerIPConnectionFilter) Disconnect

func (this *LimitPerIPConnectionFilter) Disconnect(client net.Conn)

func (*LimitPerIPConnectionFilter) Init

func (this *LimitPerIPConnectionFilter) Init(cfg config.Server) bool

func (*LimitPerIPConnectionFilter) Read

func (this *LimitPerIPConnectionFilter) Read(client net.Conn, rwc core.ReadWriteCount)

func (*LimitPerIPConnectionFilter) Request

func (this *LimitPerIPConnectionFilter) Request(buf []byte) error

func (*LimitPerIPConnectionFilter) Stop

func (this *LimitPerIPConnectionFilter) Stop()

func (*LimitPerIPConnectionFilter) Write

func (this *LimitPerIPConnectionFilter) Write(client net.Conn, rwc core.ReadWriteCount)

type LimitPeripRateFilter

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

func (*LimitPeripRateFilter) Connect

func (this *LimitPeripRateFilter) Connect(client net.Conn) error

func (*LimitPeripRateFilter) Disconnect

func (this *LimitPeripRateFilter) Disconnect(client net.Conn)

func (*LimitPeripRateFilter) Init

func (this *LimitPeripRateFilter) Init(cfg config.Server) bool

func (*LimitPeripRateFilter) Read

func (this *LimitPeripRateFilter) Read(client net.Conn, rwc core.ReadWriteCount)

func (*LimitPeripRateFilter) Request

func (this *LimitPeripRateFilter) Request(buf []byte) error

func (*LimitPeripRateFilter) Stop

func (this *LimitPeripRateFilter) Stop()

func (*LimitPeripRateFilter) Write

func (this *LimitPeripRateFilter) Write(client net.Conn, rwc core.ReadWriteCount)

type LimitReconnectRateFilter

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

func (*LimitReconnectRateFilter) Connect

func (this *LimitReconnectRateFilter) Connect(client net.Conn) error

func (*LimitReconnectRateFilter) Disconnect

func (this *LimitReconnectRateFilter) Disconnect(client net.Conn)

func (*LimitReconnectRateFilter) Init

func (this *LimitReconnectRateFilter) Init(cfg config.Server) bool

func (*LimitReconnectRateFilter) Read

func (this *LimitReconnectRateFilter) Read(client net.Conn, rwc core.ReadWriteCount)

func (*LimitReconnectRateFilter) Request

func (this *LimitReconnectRateFilter) Request(buf []byte) error

func (*LimitReconnectRateFilter) Stop

func (this *LimitReconnectRateFilter) Stop()

func (*LimitReconnectRateFilter) Write

func (this *LimitReconnectRateFilter) Write(client net.Conn, rwc core.ReadWriteCount)