Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type MaxHeapUint64 ¶
type MaxHeapUint64 []uint64
func (*MaxHeapUint64) Delete ¶
func (h *MaxHeapUint64) Delete()
func (MaxHeapUint64) Len ¶
func (h MaxHeapUint64) Len() int
func (MaxHeapUint64) Less ¶
func (h MaxHeapUint64) Less(i, j int) bool
func (*MaxHeapUint64) Pop ¶
func (h *MaxHeapUint64) Pop() interface{}
func (*MaxHeapUint64) Push ¶
func (h *MaxHeapUint64) Push(x interface{})
func (MaxHeapUint64) Swap ¶
func (h MaxHeapUint64) Swap(i, j int)
type RingBuffer ¶
type RingBuffer struct {
// contains filtered or unexported fields
}
RingBuffer is just a ring buffer
func NewRingBuffer ¶
func NewRingBuffer(size int) *RingBuffer
func (*RingBuffer) DeleteAll ¶
func (rb *RingBuffer) DeleteAll()
func (*RingBuffer) Dequeue ¶
func (rb *RingBuffer) Dequeue() interface{}
func (RingBuffer) Empty ¶
func (rb RingBuffer) Empty() bool
func (*RingBuffer) Enqueue ¶
func (rb *RingBuffer) Enqueue(item interface{})
func (RingBuffer) Full ¶
func (rb RingBuffer) Full() bool
func (RingBuffer) Size ¶
func (rb RingBuffer) Size() int
type StreamData ¶
used for RecvStream's data reordering
Source Files
Click to show internal directories.
Click to hide internal directories.