Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewAsyncReader ¶
Types ¶
type AsyncHash ¶
type AsyncHash struct {
// contains filtered or unexported fields
}
func NewAsyncHash ¶
type AsyncHashIdx ¶
type AsyncHashIdx struct {
// contains filtered or unexported fields
}
func NewAsyncHashIdx ¶
func NewAsyncHashIdx(sz int) *AsyncHashIdx
func (*AsyncHashIdx) Done ¶
func (h *AsyncHashIdx) Done() uint32
func (*AsyncHashIdx) Free ¶
func (h *AsyncHashIdx) Free(qBlk *blk.BlkT, idx int)
Free can be called from any goroutine
func (*AsyncHashIdx) Queue ¶
func (h *AsyncHashIdx) Queue(qBlk *blk.BlkT)
Blocks must arrive in order
func (*AsyncHashIdx) Run ¶
func (h *AsyncHashIdx) Run()
Source Files
Click to show internal directories.
Click to hide internal directories.