Documentation ¶
Index ¶
- Constants
- func Serialise(r StoreItem) []byte
- func WriteHeader(p *data.Page, header StoreItem, offset uint16)
- type Node
- func (n *Node) CloseNode()
- func (n *Node) Next() uint32
- func (n *Node) NextFreePosition() uint16
- func (n *Node) Previous() uint32
- func (n *Node) Read(offset uint16, length uint32, buffer []byte) (uint32, error)
- func (n *Node) SetNext(next uint32)
- func (n *Node) SetNextFreePosition(nextFreePos uint16)
- func (n *Node) SetPrevious(previous uint32)
- func (n *Node) SpaceRemaining() uint16
- func (n *Node) Write(data []byte) (uint16, error)
- type Record
- type StoreItem
- type Stream
- func (s *Stream) Add(payload []byte) (uint32, error)
- func (s *Stream) Get(key uint32) (Record, error)
- func (s *Stream) GetFrom(key uint32, num uint16) ([]Record, error)
- func (s *Stream) IndexPage() uint32
- func (s *Stream) LastValueWrittenPage() uint32
- func (s *Stream) LastValueWrittenPos() uint16
- func (s *Stream) NextKey() uint32
- func (s *Stream) SetIndexPage(pageNum uint32)
- func (s *Stream) SetStoreHeadPage(pageNum uint32)
- func (s *Stream) SetStoreTailPage(pageNum uint32)
- func (s *Stream) StoreHeadPage() uint32
- func (s *Stream) StoreTailPage() uint32
Constants ¶
View Source
const ( PrevPageOffset = 0 PrevPageSize = uint16(unsafe.Sizeof(uint32(0))) NextPageOffset = PrevPageSize NextPageSize = uint16(unsafe.Sizeof(uint32(0))) NextFreePositionOffset = NextPageOffset + NextPageSize NextFreePositionSize = uint16(unsafe.Sizeof(uint32(0))) //LastValueWritenOffset = NextFreePositionOffset + NextFreePositionSize //LastValueWrittenSize = uint16(unsafe.Sizeof(uint32(0))) HeaderSize = NextFreePositionOffset + NextFreePositionSize //LastValueWritenOffset + LastValueWrittenSize )
View Source
const ( IndexRootPageOffset = 0 IndexRootPageSize = uint16(unsafe.Sizeof(uint32(0))) StoreHeadPageOffset = IndexRootPageOffset + IndexRootPageSize StoreHeadPageSize = uint16(unsafe.Sizeof(uint32(0))) StoreTailPageOffset = StoreHeadPageOffset + StoreHeadPageSize StoreTailPageSize = uint16(unsafe.Sizeof(uint32(0))) NextKeyOffset = StoreTailPageOffset + StoreTailPageSize NextKeySize = uint16(unsafe.Sizeof(uint32(0))) LastValueWrittenPageOffset = NextKeyOffset + NextKeySize LastValueWrittenPageSize = uint16(unsafe.Sizeof(uint32(0))) LastValueWrittenPosOffset = LastValueWrittenPageOffset + LastValueWrittenPageSize LastValueWrittenPosSize = uint16(unsafe.Sizeof(uint16(0))) StreamHeader = LastValueWrittenPosOffset + LastValueWrittenPosSize )
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Node ¶
type Node struct {
// contains filtered or unexported fields
}
func InititaliseNode ¶
func (*Node) NextFreePosition ¶
func (*Node) SetNextFreePosition ¶
func (*Node) SetPrevious ¶
func (*Node) SpaceRemaining ¶
type Stream ¶
type Stream struct {
// contains filtered or unexported fields
}
func (*Stream) LastValueWrittenPage ¶
func (*Stream) LastValueWrittenPos ¶
func (*Stream) SetIndexPage ¶
func (*Stream) SetStoreHeadPage ¶
func (*Stream) SetStoreTailPage ¶
func (*Stream) StoreHeadPage ¶
func (*Stream) StoreTailPage ¶
Click to show internal directories.
Click to hide internal directories.