Documentation ¶
Index ¶
- Variables
- func Reg(xferFilter XferFilter)
- type Gzip
- type XferFilter
- type XferPipe
- func (x *XferPipe) Append(filterId ...byte) error
- func (x *XferPipe) AppendFrom(src *XferPipe)
- func (x *XferPipe) Ids() []byte
- func (x *XferPipe) Len() int
- func (x *XferPipe) OnPack(data []byte) ([]byte, error)
- func (x *XferPipe) OnUnpack(data []byte) ([]byte, error)
- func (x *XferPipe) Range(callback func(idx int, filter XferFilter) bool)
- func (x *XferPipe) Reset()
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrXferPipeTooLong = errors.New("The length of transfer pipe cannot be bigger than 255")
ErrXferPipeTooLong error
Functions ¶
Types ¶
type XferFilter ¶
type XferFilter interface { Id() byte OnPack([]byte) ([]byte, error) OnUnpack([]byte) ([]byte, error) }
XferFilter handles byte stream of packet when transfer.
type XferPipe ¶
type XferPipe struct {
// contains filtered or unexported fields
}
XferPipe transfer filter pipe, handlers from outer-most to inner-most. Note: the length can not be bigger than 255!
func (*XferPipe) AppendFrom ¶
AppendFrom appends transfer filters from a *XferPipe.
Click to show internal directories.
Click to hide internal directories.