Documentation
¶
Index ¶
- func Identification(b []byte, way Way) string
- func IdentificationV2(b []byte, way Way) string
- type BPSLimiter
- type BlockDecryptFP
- type BlockEncryptFP
- type FlowLimitFP
- type FlowProcessor
- type FlowProcessors
- func (fp FlowProcessors) Close()
- func (fp *FlowProcessors) Delete(name string)
- func (fp *FlowProcessors) GetByName(name string) *ProcessorNode
- func (fp FlowProcessors) List() []string
- func (fp FlowProcessors) Process(bytes []byte) []byte
- func (fp FlowProcessors) ProcessReverse(bytes []byte) []byte
- func (fp *FlowProcessors) Register(processor FlowProcessor, name string)
- type FlowStatisticsFP
- type Identifier
- type LimitedBPSBucket
- type LimitedPPSBucket
- type PPSLimiter
- type ProcessorNode
- type Salsa20DecryptFP
- type Salsa20EncryptFP
- type Way
- type ZSTDCompressFP
- type ZSTDDecompressFP
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Identification ¶
Identification @Description: @param b @param way @return string
func IdentificationV2 ¶
IdentificationV2 @Description: In Default -> |protocol|src,src_port(tcp or udp)|dst,dst_port(tcp or udp)|
Out -> |protocol|dst,dst_port(tcp or udp)|src,src_port(tcp or udp)|
@param b @param way @return string
Types ¶
type BPSLimiter ¶
type BPSLimiter struct {
// contains filtered or unexported fields
}
BPSLimiter @Description:
func NewBPSLimiterFP ¶
func NewBPSLimiterFP(bandwidth int, mtu int) BPSLimiter
NewBPSLimiterFP @Description: @param bandwidth @param mtu @return BPSLimiter
func (*BPSLimiter) Init ¶
func (l *BPSLimiter) Init() bool
Init @Description: @receiver l @return bool
func (*BPSLimiter) Process ¶
func (l *BPSLimiter) Process(raw []byte) []byte
Process @Description: @receiver l @param raw @return []byte
type BlockDecryptFP ¶
type BlockDecryptFP struct {
// contains filtered or unexported fields
}
BlockDecryptFP @Description:
func NewBlockDecryptFP ¶
func NewBlockDecryptFP(crypt kcp.BlockCrypt) *BlockDecryptFP
NewBlockDecryptFP @Description: @param key @return fp @return err
func (*BlockDecryptFP) Init ¶
func (e *BlockDecryptFP) Init() bool
Init @Description: @receiver e @return bool
func (*BlockDecryptFP) Process ¶
func (e *BlockDecryptFP) Process(raw []byte) []byte
Process @Description: @receiver e @param raw @return []byte
type BlockEncryptFP ¶
type BlockEncryptFP struct {
// contains filtered or unexported fields
}
BlockEncryptFP @Description:
func NewBlockEncryptFP ¶
func NewBlockEncryptFP(crypt kcp.BlockCrypt) *BlockEncryptFP
NewBlockEncryptFP @Description: @param key @return fp @return err
func (*BlockEncryptFP) Init ¶
func (e *BlockEncryptFP) Init() bool
Init @Description: @receiver e @return bool
func (*BlockEncryptFP) Process ¶
func (e *BlockEncryptFP) Process(raw []byte) []byte
Process @Description: @receiver e @param raw @return []byte
type FlowLimitFP ¶
type FlowLimitFP struct {
Flow uint64 //起始点
Limit uint64 //限制
// contains filtered or unexported fields
}
FlowLimitFP @Description:
func NewFlowLimitFP ¶
func NewFlowLimitFP(counter *FlowStatisticsFP, flow, limit uint64, kick func()) FlowLimitFP
NewFlowLimitFP @Description: @return *FlowLimitFP
func (*FlowLimitFP) Init ¶
func (f *FlowLimitFP) Init() bool
Init @Description: @receiver f @return bool
func (*FlowLimitFP) Process ¶
func (f *FlowLimitFP) Process(raw []byte) []byte
Process @Description: @receiver f @param raw @return []byte
type FlowProcessor ¶
type FlowProcessor interface {
//
// Init
// @Description: init processor
//
Init() bool
//
// Process
// @Description: do process method
// @param raw
// @return []byte
//
Process(raw []byte) []byte
//
// Close
// @Description:
//
Close()
}
FlowProcessor @Description: flow data processor interface
type FlowProcessors ¶
type FlowProcessors struct {
Name string
// contains filtered or unexported fields
}
FlowProcessors @Description: processors
func NewFlowProcessor ¶
func NewFlowProcessor() *FlowProcessors
NewFlowProcessor @Description: @return *FlowProcessors
func (*FlowProcessors) Delete ¶
func (fp *FlowProcessors) Delete(name string)
Delete @Description: @receiver fp @param name
func (*FlowProcessors) GetByName ¶
func (fp *FlowProcessors) GetByName(name string) *ProcessorNode
GetByName @Description: @receiver fp @param name @return *ProcessorNode
func (FlowProcessors) List ¶
func (fp FlowProcessors) List() []string
List @Description: @receiver fp @return []string
func (FlowProcessors) Process ¶
func (fp FlowProcessors) Process(bytes []byte) []byte
Process @Description: start process data by using processor positively @receiver fp
func (FlowProcessors) ProcessReverse ¶
func (fp FlowProcessors) ProcessReverse(bytes []byte) []byte
ProcessReverse @Description: start process data by using processor reversely @receiver fp
func (*FlowProcessors) Register ¶
func (fp *FlowProcessors) Register(processor FlowProcessor, name string)
Register @Description: register for data processor @receiver fp @param processor
type FlowStatisticsFP ¶
type FlowStatisticsFP struct {
Name string
Flow uint64
FlowStamp uint64
FlowCommitStamp uint64
FlowSpeed uint64
Packet uint64
PacketStamp uint64
PacketSpeed uint64
RecordGap int
Print bool
// contains filtered or unexported fields
}
FlowStatisticsFP @Description:
func (*FlowStatisticsFP) Close ¶
func (fp *FlowStatisticsFP) Close()
Close @Description: @receiver fp
func (*FlowStatisticsFP) Commit ¶
func (fp *FlowStatisticsFP) Commit() uint64
Commit @Description: @receiver fp @return uint64
func (*FlowStatisticsFP) Dump ¶
func (fp *FlowStatisticsFP) Dump(file string) error
Dump @Description: @receiver fp @param file @return error
func (*FlowStatisticsFP) Init ¶
func (fp *FlowStatisticsFP) Init() bool
Init @Description: @receiver fp
func (*FlowStatisticsFP) LoadFromDump ¶
func (fp *FlowStatisticsFP) LoadFromDump(file string) error
LoadFromDump @Description: @receiver fp @param file @return error
func (*FlowStatisticsFP) Process ¶
func (fp *FlowStatisticsFP) Process(raw []byte) []byte
Process @Description: @receiver fp @param raw @return []byte
type Identifier ¶ added in v0.0.4
type Identifier struct {
// contains filtered or unexported fields
}
func NewIdentifier ¶ added in v0.0.4
func NewIdentifier() *Identifier
func (*Identifier) Dst ¶ added in v0.0.7
func (i *Identifier) Dst(b []byte) string
func (*Identifier) Src ¶ added in v0.0.7
func (i *Identifier) Src(b []byte) string
func (*Identifier) SymbolIn ¶ added in v0.0.4
func (i *Identifier) SymbolIn(b []byte) (id string)
func (*Identifier) SymbolOut ¶ added in v0.0.4
func (i *Identifier) SymbolOut(b []byte) (id string)
type LimitedBPSBucket ¶
type LimitedBPSBucket struct {
// contains filtered or unexported fields
}
func NewLimitedBPSBucket ¶
func NewLimitedBPSBucket(maxSpeed uint64, mtu int) *LimitedBPSBucket
func (*LimitedBPSBucket) Take ¶
func (l *LimitedBPSBucket) Take(p []byte)
Take @Description: @receiver l
type LimitedPPSBucket ¶
type LimitedPPSBucket struct {
// contains filtered or unexported fields
}
LimitedPPSBucket @Description:
func NewLimitedPPSBucket ¶
func NewLimitedPPSBucket(maxSpeed uint64, mtu int) *LimitedPPSBucket
NewLimitedPPSBucket @Description: @return LimitedPPSBucket
func (*LimitedPPSBucket) Take ¶
func (l *LimitedPPSBucket) Take(p []byte)
Take @Description: 从桶中取令牌，如果余量不足以取出则等待 @receiver l
type PPSLimiter ¶
type PPSLimiter struct {
// contains filtered or unexported fields
}
PPSLimiter @Description:
func NewPPSLimiterFP ¶
func NewPPSLimiterFP(bandwidth int, mtu int) PPSLimiter
NewPPSLimiterFP @Description: @param bandwidth @param mtu @return *PPSLimiter
func (*PPSLimiter) Init ¶
func (l *PPSLimiter) Init() bool
Init @Description: @receiver PPSLimiter @return bool
func (*PPSLimiter) Process ¶
func (l *PPSLimiter) Process(raw []byte) []byte
Process @Description: @receiver l @param raw @return []byte
type ProcessorNode ¶
type ProcessorNode struct {
Name string
Processor FlowProcessor
Next *ProcessorNode
Last *ProcessorNode
}
ProcessorNode @Description: processor chain node
type Salsa20DecryptFP ¶
type Salsa20DecryptFP struct {
// contains filtered or unexported fields
}
Salsa20DecryptFP @Description:
func NewSalsa20DecryptFP ¶
func NewSalsa20DecryptFP(key []byte) (fp *Salsa20DecryptFP, err error)
NewSalsa20DecryptFP @Description: @param key @return fp @return err
func (*Salsa20DecryptFP) Init ¶
func (e *Salsa20DecryptFP) Init() bool
Init @Description: @receiver e @return bool
func (*Salsa20DecryptFP) Process ¶
func (e *Salsa20DecryptFP) Process(raw []byte) []byte
Process @Description: @receiver e @param raw @return []byte
type Salsa20EncryptFP ¶
type Salsa20EncryptFP struct {
// contains filtered or unexported fields
}
Salsa20EncryptFP @Description:
func NewSalsa20EncryptFP ¶
func NewSalsa20EncryptFP(key []byte) (fp *Salsa20EncryptFP, err error)
NewSalsa20EncryptFP @Description: @param key @return fp @return err
func (*Salsa20EncryptFP) Init ¶
func (e *Salsa20EncryptFP) Init() bool
Init @Description: @receiver e @return bool
func (*Salsa20EncryptFP) Process ¶
func (e *Salsa20EncryptFP) Process(raw []byte) []byte
Process @Description: @receiver e @param raw @return []byte
type ZSTDCompressFP ¶
type ZSTDCompressFP struct {
// contains filtered or unexported fields
}
ZSTDCompressFP @Description:
func (*ZSTDCompressFP) Init ¶
func (c *ZSTDCompressFP) Init() bool
Init @Description: @receiver c @return bool
func (*ZSTDCompressFP) Process ¶
func (c *ZSTDCompressFP) Process(raw []byte) []byte
Process @Description: @receiver c @param raw @return []byte
type ZSTDDecompressFP ¶
type ZSTDDecompressFP struct {
// contains filtered or unexported fields
}
ZSTDDecompressFP @Description:
func (*ZSTDDecompressFP) Init ¶
func (c *ZSTDDecompressFP) Init() bool
Init @Description: @receiver c @return bool
func (*ZSTDDecompressFP) Process ¶
func (c *ZSTDDecompressFP) Process(raw []byte) []byte
Process @Description: @receiver c @param raw @return []byte
Source Files