Documentation
¶
Index ¶
- Constants
- func EncodeColBfKey(idx uint16, metaloc string) string
- func EncodeColDataKey(idx uint16, metaloc string) string
- func EncodeColMetaKey(idx uint16, metaloc string) string
- func EncodeDeltaDataKey(idx uint16, deltaloc string) string
- func EncodeDeltaMetaKey(deltaloc string) string
- func FetchColumnData(buf *bytes.Buffer, mgr base.INodeManager, id *common.ID, fs *objectio.ObjectFS, ...) (res containers.Vector, err error)
- func FetchDeltaData(buf *bytes.Buffer, mgr base.INodeManager, fs *objectio.ObjectFS, ...) (res containers.Vector, err error)
- func PinEvictableNode(mgr base.INodeManager, key string, factory EvictableNodeFactory) (base.INodeHandle, error)
- type BackendKind
- type BfNode
- type ColDataNode
- type ColumnMetaNode
- type DeltaDataNode
- type DeltaMetaNode
- type EvictableNodeFactory
Constants ¶
View Source
const ( Disk = iota S3 )
View Source
const (
ConstPinDuration = 5 * time.Second
)
Variables ¶
This section is empty.
Functions ¶
func EncodeColBfKey ¶
func EncodeColDataKey ¶
func EncodeColMetaKey ¶
func EncodeDeltaDataKey ¶
func EncodeDeltaMetaKey ¶
func FetchColumnData ¶
func FetchDeltaData ¶
func PinEvictableNode ¶
func PinEvictableNode(mgr base.INodeManager, key string, factory EvictableNodeFactory) (base.INodeHandle, error)
Types ¶
type BfNode ¶
type BfNode struct {
*buffer.Node
Bf index.StaticFilter
// contains filtered or unexported fields
}
type ColDataNode ¶
type ColDataNode struct {
*buffer.Node
Data containers.Vector
// contains filtered or unexported fields
}
func NewColDataNode ¶
func (*ColDataNode) GetData ¶
func (n *ColDataNode) GetData(buf *bytes.Buffer) (containers.Vector, error)
type ColumnMetaNode ¶
type ColumnMetaNode struct {
*buffer.Node
// data
objectio.ColumnObject
Zonemap *index.ZoneMap
// contains filtered or unexported fields
}
func NewColumnMetaNode ¶
func NewColumnMetaNode(mgr base.INodeManager, metaKey string, fs *objectio.ObjectFS, idx uint16, metaloc string, typ types.Type) *ColumnMetaNode
type DeltaDataNode ¶
type DeltaDataNode struct {
*buffer.Node
Data containers.Vector
// contains filtered or unexported fields
}
func NewDeltaDataNode ¶
func (*DeltaDataNode) GetData ¶
func (n *DeltaDataNode) GetData(buf *bytes.Buffer) (containers.Vector, error)
type DeltaMetaNode ¶
type DeltaMetaNode struct {
*buffer.Node
// data
objectio.BlockObject
// contains filtered or unexported fields
}
func NewDeltaMetaNode ¶
func NewDeltaMetaNode(mgr base.INodeManager, metaKey string, fs *objectio.ObjectFS, deltaloc string) *DeltaMetaNode
type EvictableNodeFactory ¶
Source Files
Click to show internal directories.
Click to hide internal directories.