Versions in this module Expand all Collapse all v0 v0.2.0 Dec 6, 2022 v0.1.0 Dec 2, 2022 Changes in this version + var ErrNotEnoughData = errors.New("not enough data in buffer") + type ConnBuf struct + func NewConnBuf() *ConnBuf + func (cb *ConnBuf) Close() error + func (cb *ConnBuf) Peek(p []byte, n int) error + func (cb *ConnBuf) Read(p []byte) (n int, err error) + func (cb *ConnBuf) SetDownstream(w io.Writer) error + func (cb *ConnBuf) Write(p []byte) (n int, err error) + type Protocol interface + ApplyRules func(rules []config.Rule) error + Clone func() Protocol + Identify func(ctx context.Context, cBuf *ConnBuf) (config.Rule, error) + Name func() config.Protocol + type ProtocolManager struct + func NewProtocolManager() *ProtocolManager + func (pm *ProtocolManager) FindAction(ctx context.Context, cBuf *ConnBuf) (config.Action, error) + func (pm *ProtocolManager) GetProtocol(name config.Protocol) Protocol + func (pm *ProtocolManager) ImportProtocolGroup(pg config.ProtocolGroup) error + func (pm *ProtocolManager) RegisterProtocol(p Protocol)
Go to main page