Versions in this module Expand all Collapse all v0 v0.4.0 May 5, 2022 Changes in this version + func MakeNodeFileName(id uint64) string + func NewBufferHandle(n nif.INodeHandle, mgr mgrif.IBufferManager) nif.IBufferHandle + func NewNodeBuffer(id uint64, node buf.IMemoryNode) iface.INodeBuffer + func NewNodeCleaner(filename []byte) iface.Cleaner + func NewNodeHandle(ctx *NodeHandleCtx) nif.INodeHandle + func NewNodeIO(nh iface.INodeHandle, dir []byte) iface.IOHandle + func NewNodeIOWithReader(nh iface.INodeHandle, reader io.Reader) iface.IOHandle + func NewNodeReader(nh iface.INodeHandle, filename []byte, reader io.Reader) iface.Reader + func NewNodeWriter(nh iface.INodeHandle, filename []byte) iface.Writer + type BufferHandle struct + Handle iface.INodeHandle + Manager mgrif.IBufferManager + func (h *BufferHandle) Close() error + func (h *BufferHandle) GetHandle() nif.INodeHandle + func (h *BufferHandle) GetID() uint64 + type NodeBuffer struct + ID uint64 + func (nb *NodeBuffer) GetID() uint64 + type NodeCleaner struct + Filename []byte + func (nc *NodeCleaner) Clean() error + type NodeHandle struct + Buff buf.IBuffer + Constructor buf.MemoryNodeConstructor + File common.IVFile + ID uint64 + IO iface.IOHandle + Iter uint64 + Manager mgrif.IBufferManager + RTState iface.NodeRTState + Refs uint64 + Spillable bool + State iface.NodeState + UseCompress bool + func (h *NodeHandle) Clean() error + func (h *NodeHandle) Close() error + func (h *NodeHandle) CommitLoad() error + func (h *NodeHandle) FlushData() error + func (h *NodeHandle) GetBuffer() buf.IBuffer + func (h *NodeHandle) GetCapacity() uint64 + func (h *NodeHandle) GetFile() common.IVFile + func (h *NodeHandle) GetID() uint64 + func (h *NodeHandle) GetNodeCreator() buf.MemoryNodeConstructor + func (h *NodeHandle) GetState() nif.NodeState + func (h *NodeHandle) HasRef() bool + func (h *NodeHandle) IncIteration() uint64 + func (h *NodeHandle) IsClosed() bool + func (h *NodeHandle) IsCompress() bool + func (h *NodeHandle) IsSpillable() bool + func (h *NodeHandle) Iteration() uint64 + func (h *NodeHandle) MakeHandle() nif.IBufferHandle + func (h *NodeHandle) PrepareLoad() bool + func (h *NodeHandle) Ref() + func (h *NodeHandle) RollbackLoad() + func (h *NodeHandle) SetBuffer(buf buf.IBuffer) error + func (h *NodeHandle) String() string + func (h *NodeHandle) UnRef() bool + func (h *NodeHandle) Unload() + func (h *NodeHandle) Unloadable() bool + type NodeHandleCtx struct + Buff buf.IBuffer + Constructor buf.MemoryNodeConstructor + Dir []byte + File common.IVFile + ID uint64 + Manager mgrif.IBufferManager + Spillable bool + UseCompress bool + type NodeReader struct + Filename []byte + Handle iface.INodeHandle + Reader io.Reader + func (nr *NodeReader) Load() (err error) + type NodeWriter struct + Filename []byte + Handle iface.INodeHandle + func (sw *NodeWriter) Flush() (err error)
Go to main page