tree

Documentation

Index

• func NewTreeBackend() storage.Backend
• type BlockData
  • func (z *BlockData) DecodeMsg(dc *msgp.Reader) (err error)
  • func (z *BlockData) EncodeMsg(en *msgp.Writer) (err error)
  • func (z *BlockData) MarshalMsg(b []byte) (o []byte, err error)
  • func (z *BlockData) Msgsize() (s int)
  • func (z *BlockData) UnmarshalMsg(bts []byte) (o []byte, err error)
  • func (z *BlockData) UnmarshalMsgWithCfg(bts []byte, cfg *msgp.RuntimeConfig) (o []byte, err error)
• type LocationEntry
  • func NewLocationEntryFromKeySO(key ibtree.Key) LocationEntry
  • func (self LocationEntry) BlockSize() uint64
  • func (z *LocationEntry) DecodeMsg(dc *msgp.Reader) (err error)
  • func (z LocationEntry) EncodeMsg(en *msgp.Writer) (err error)
  • func (z LocationEntry) MarshalMsg(b []byte) (o []byte, err error)
  • func (z LocationEntry) Msgsize() (s int)
  • func (self LocationEntry) String() string
  • func (self LocationEntry) ToKeyOS() ibtree.Key
  • func (self LocationEntry) ToKeySO() ibtree.Key
  • func (z *LocationEntry) UnmarshalMsg(bts []byte) (o []byte, err error)
  • func (z *LocationEntry) UnmarshalMsgWithCfg(bts []byte, cfg *msgp.RuntimeConfig) (o []byte, err error)
• type LocationSlice
  • func NewLocationSliceFromBlockId(bid ibtree.BlockId) LocationSlice
  • func (z *LocationSlice) DecodeMsg(dc *msgp.Reader) (err error)
  • func (z LocationSlice) EncodeMsg(en *msgp.Writer) (err error)
  • func (z LocationSlice) MarshalMsg(b []byte) (o []byte, err error)
  • func (z LocationSlice) Msgsize() (s int)
  • func (self *LocationSlice) ToBlockId() ibtree.BlockId
  • func (z *LocationSlice) UnmarshalMsg(bts []byte) (o []byte, err error)
  • func (z *LocationSlice) UnmarshalMsgWithCfg(bts []byte, cfg *msgp.RuntimeConfig) (o []byte, err error)
• type OpEntry
  • func (z *OpEntry) DecodeMsg(dc *msgp.Reader) (err error)
  • func (z *OpEntry) EncodeMsg(en *msgp.Writer) (err error)
  • func (z *OpEntry) MarshalMsg(b []byte) (o []byte, err error)
  • func (z *OpEntry) Msgsize() (s int)
  • func (self OpEntry) String() string
  • func (z *OpEntry) UnmarshalMsg(bts []byte) (o []byte, err error)
  • func (z *OpEntry) UnmarshalMsgWithCfg(bts []byte, cfg *msgp.RuntimeConfig) (o []byte, err error)
• type OpSlice
  • func (z *OpSlice) DecodeMsg(dc *msgp.Reader) (err error)
  • func (z OpSlice) EncodeMsg(en *msgp.Writer) (err error)
  • func (z OpSlice) MarshalMsg(b []byte) (o []byte, err error)
  • func (z OpSlice) Msgsize() (s int)
  • func (z *OpSlice) UnmarshalMsg(bts []byte) (o []byte, err error)
  • func (z *OpSlice) UnmarshalMsgWithCfg(bts []byte, cfg *msgp.RuntimeConfig) (o []byte, err error)
• type Superblock
  • func (z *Superblock) DecodeMsg(dc *msgp.Reader) (err error)
  • func (z *Superblock) EncodeMsg(en *msgp.Writer) (err error)
  • func (z *Superblock) MarshalMsg(b []byte) (o []byte, err error)
  • func (z *Superblock) Msgsize() (s int)
  • func (z *Superblock) UnmarshalMsg(bts []byte) (o []byte, err error)
  • func (z *Superblock) UnmarshalMsgWithCfg(bts []byte, cfg *msgp.RuntimeConfig) (o []byte, err error)

Functions

func NewTreeBackend

func NewTreeBackend() storage.Backend

Types

type BlockData

type BlockData struct {
	storage.BlockMetadata `zid:"0"`
	Location              LocationSlice `zid:"1"`
}

func (*BlockData) DecodeMsg

func (z *BlockData) DecodeMsg(dc *msgp.Reader) (err error)

DecodeMsg implements msgp.Decodable We treat empty fields as if we read a Nil from the wire.

func (*BlockData) EncodeMsg

func (z *BlockData) EncodeMsg(en *msgp.Writer) (err error)

EncodeMsg implements msgp.Encodable

func (*BlockData) MarshalMsg

func (z *BlockData) MarshalMsg(b []byte) (o []byte, err error)

MarshalMsg implements msgp.Marshaler

func (*BlockData) Msgsize

func (z *BlockData) Msgsize() (s int)

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*BlockData) UnmarshalMsg

func (z *BlockData) UnmarshalMsg(bts []byte) (o []byte, err error)

UnmarshalMsg implements msgp.Unmarshaler

func (*BlockData) UnmarshalMsgWithCfg

func (z *BlockData) UnmarshalMsgWithCfg(bts []byte, cfg *msgp.RuntimeConfig) (o []byte, err error)

type LocationEntry

type LocationEntry struct {
	Offset uint64 `zid:"0"`
	Size   uint64 `zid:"1"`
}

func NewLocationEntryFromKeySO

func NewLocationEntryFromKeySO(key ibtree.Key) LocationEntry

NewLocationEntryFromKeySO decodes ibtree.Key with size, offset order

func (LocationEntry) BlockSize

func (self LocationEntry) BlockSize() uint64

func (*LocationEntry) DecodeMsg

func (z *LocationEntry) DecodeMsg(dc *msgp.Reader) (err error)

DecodeMsg implements msgp.Decodable We treat empty fields as if we read a Nil from the wire.

func (LocationEntry) EncodeMsg

func (z LocationEntry) EncodeMsg(en *msgp.Writer) (err error)

EncodeMsg implements msgp.Encodable

func (LocationEntry) MarshalMsg

func (z LocationEntry) MarshalMsg(b []byte) (o []byte, err error)

MarshalMsg implements msgp.Marshaler

func (LocationEntry) Msgsize

func (z LocationEntry) Msgsize() (s int)

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (LocationEntry) String

func (self LocationEntry) String() string

func (LocationEntry) ToKeyOS

func (self LocationEntry) ToKeyOS() ibtree.Key

ToKeyOS converts LocationEntry to ibtree.Key with offset, size order

func (LocationEntry) ToKeySO

func (self LocationEntry) ToKeySO() ibtree.Key

ToKeySO converts LocationEntry to ibtree.Key with size, offset order

func (*LocationEntry) UnmarshalMsg

func (z *LocationEntry) UnmarshalMsg(bts []byte) (o []byte, err error)

UnmarshalMsg implements msgp.Unmarshaler

func (*LocationEntry) UnmarshalMsgWithCfg

func (z *LocationEntry) UnmarshalMsgWithCfg(bts []byte, cfg *msgp.RuntimeConfig) (o []byte, err error)

type LocationSlice

type LocationSlice []LocationEntry

func NewLocationSliceFromBlockId

func NewLocationSliceFromBlockId(bid ibtree.BlockId) LocationSlice

func (*LocationSlice) DecodeMsg

func (z *LocationSlice) DecodeMsg(dc *msgp.Reader) (err error)

DecodeMsg implements msgp.Decodable We treat empty fields as if we read a Nil from the wire.

func (LocationSlice) EncodeMsg

func (z LocationSlice) EncodeMsg(en *msgp.Writer) (err error)

EncodeMsg implements msgp.Encodable

func (LocationSlice) MarshalMsg

func (z LocationSlice) MarshalMsg(b []byte) (o []byte, err error)

MarshalMsg implements msgp.Marshaler

func (LocationSlice) Msgsize

func (z LocationSlice) Msgsize() (s int)

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*LocationSlice) ToBlockId

func (self *LocationSlice) ToBlockId() ibtree.BlockId

func (*LocationSlice) UnmarshalMsg

func (z *LocationSlice) UnmarshalMsg(bts []byte) (o []byte, err error)

UnmarshalMsg implements msgp.Unmarshaler

func (*LocationSlice) UnmarshalMsgWithCfg

func (z *LocationSlice) UnmarshalMsgWithCfg(bts []byte, cfg *msgp.RuntimeConfig) (o []byte, err error)

type OpEntry

type OpEntry struct {
	Location LocationEntry `zid:"0"`
	Free     bool          `zid:"1"`
}

func (*OpEntry) DecodeMsg

func (z *OpEntry) DecodeMsg(dc *msgp.Reader) (err error)

DecodeMsg implements msgp.Decodable We treat empty fields as if we read a Nil from the wire.

func (*OpEntry) EncodeMsg

func (z *OpEntry) EncodeMsg(en *msgp.Writer) (err error)

EncodeMsg implements msgp.Encodable

func (*OpEntry) MarshalMsg

func (z *OpEntry) MarshalMsg(b []byte) (o []byte, err error)

MarshalMsg implements msgp.Marshaler

func (*OpEntry) Msgsize

func (z *OpEntry) Msgsize() (s int)

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (OpEntry) String

func (self OpEntry) String() string

func (*OpEntry) UnmarshalMsg

func (z *OpEntry) UnmarshalMsg(bts []byte) (o []byte, err error)

UnmarshalMsg implements msgp.Unmarshaler

func (*OpEntry) UnmarshalMsgWithCfg

func (z *OpEntry) UnmarshalMsgWithCfg(bts []byte, cfg *msgp.RuntimeConfig) (o []byte, err error)

type OpSlice

type OpSlice []OpEntry

func (*OpSlice) DecodeMsg

func (z *OpSlice) DecodeMsg(dc *msgp.Reader) (err error)

DecodeMsg implements msgp.Decodable We treat empty fields as if we read a Nil from the wire.

func (OpSlice) EncodeMsg

func (z OpSlice) EncodeMsg(en *msgp.Writer) (err error)

EncodeMsg implements msgp.Encodable

func (OpSlice) MarshalMsg

func (z OpSlice) MarshalMsg(b []byte) (o []byte, err error)

MarshalMsg implements msgp.Marshaler

func (OpSlice) Msgsize

func (z OpSlice) Msgsize() (s int)

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*OpSlice) UnmarshalMsg

func (z *OpSlice) UnmarshalMsg(bts []byte) (o []byte, err error)

UnmarshalMsg implements msgp.Unmarshaler

func (*OpSlice) UnmarshalMsgWithCfg

func (z *OpSlice) UnmarshalMsgWithCfg(bts []byte, cfg *msgp.RuntimeConfig) (o []byte, err error)

type Superblock

type Superblock struct {
	Generation      uint64        `zid:"0"`
	BytesUsed       uint64        `zid:"1"`
	BytesTotal      uint64        `zid:"2"`
	RootLocation    LocationSlice `zid:"3"`
	Pending         OpSlice       `zid:"4"`
	PendingLocation LocationSlice `zid:"5"`
}

func (*Superblock) DecodeMsg

func (z *Superblock) DecodeMsg(dc *msgp.Reader) (err error)

DecodeMsg implements msgp.Decodable We treat empty fields as if we read a Nil from the wire.

func (*Superblock) EncodeMsg

func (z *Superblock) EncodeMsg(en *msgp.Writer) (err error)

EncodeMsg implements msgp.Encodable

func (*Superblock) MarshalMsg

func (z *Superblock) MarshalMsg(b []byte) (o []byte, err error)

MarshalMsg implements msgp.Marshaler

func (*Superblock) Msgsize

func (z *Superblock) Msgsize() (s int)

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*Superblock) UnmarshalMsg

func (z *Superblock) UnmarshalMsg(bts []byte) (o []byte, err error)

UnmarshalMsg implements msgp.Unmarshaler

func (*Superblock) UnmarshalMsgWithCfg

func (z *Superblock) UnmarshalMsgWithCfg(bts []byte, cfg *msgp.RuntimeConfig) (o []byte, err error)