Versions in this module Expand all Collapse all v0 v0.6.0 Mar 19, 2024 Changes in this version + var ErrNotComplete = errors.New("socket: not complete event") + type Buffer struct + func CombineSlices(validated bool, buffers ...*Buffer) *Buffer + func NewBuffer() *Buffer + func (r *Buffer) AppendDataEvent(event SocketDataBuffer) + func (r *Buffer) AppendDetailEvent(event SocketDataDetail) + func (r *Buffer) Clean() + func (r *Buffer) DataLength() int + func (r *Buffer) DataSize() int64 + func (r *Buffer) DeleteExpireEvents(expireDuration time.Duration) int + func (r *Buffer) DetailLength() int + func (r *Buffer) Details() *list.List + func (r *Buffer) DetectNotSendingLastPosition() *Position + func (r *Buffer) FindFirstDataBuffer(dataID uint64) SocketDataBuffer + func (r *Buffer) FirstSocketBuffer() SocketDataBuffer + func (r *Buffer) IsCurrentPacketReadFinished() bool + func (r *Buffer) LastSocketBuffer() SocketDataBuffer + func (r *Buffer) Len() int + func (r *Buffer) Merge(other *Buffer) + func (r *Buffer) OffsetPosition(offset int) *Position + func (r *Buffer) Peek(p []byte) (n int, err error) + func (r *Buffer) Position() *Position + func (r *Buffer) PrepareForReading() bool + func (r *Buffer) Read(p []byte) (n int, err error) + func (r *Buffer) ReadFromCurrent(p []byte) (element *list.Element, n int) + func (r *Buffer) ReadUntilBufferFull(data []byte) error + func (r *Buffer) RemoveReadElements() bool + func (r *Buffer) ResetForLoopReading() + func (r *Buffer) SkipCurrentElement() bool + func (r *Buffer) Slice(validated bool, start, end *Position) *Buffer + type Position struct + func (p *Position) Clone() *Position + func (p *Position) DataID() uint64 + func (p *Position) Seq() int + type SocketDataBuffer interface + BufferData func() []byte + BufferLen func() int + BufferStartPosition func() int + DataID func() uint64 + DataSequence func() int + Direction func() enums.SocketDataDirection + EndTime func() uint64 + GenerateConnectionID func() string + HaveReduceDataAfterChunk func() bool + IsFinished func() bool + IsStart func() bool + StartTime func() uint64 + TotalSize func() uint64 + type SocketDataDetail interface + DataID func() uint64 + type SocketDataEventLimited struct + From int + Size int + func (s *SocketDataEventLimited) BufferData() []byte + func (s *SocketDataEventLimited) BufferLen() int + func (s *SocketDataEventLimited) BufferStartPosition() int