Versions in this module Expand all Collapse all v0 v0.0.4 Jul 20, 2026 v0.0.3 Jul 20, 2026 v0.0.2 Jul 19, 2026 v0.0.1 Jul 19, 2026 Changes in this version + const GB + const KB + const MB + const MaxCompactAttributes + const SignatureSNOD + const SuperblockV0 + const SuperblockV2 + const SuperblockV3 + const Unlimited + type ChunkIterator struct + func (it *ChunkIterator) Chunk() (interface{}, error) + func (it *ChunkIterator) ChunkCoords() []uint64 + func (it *ChunkIterator) ChunkDims() []uint64 + func (it *ChunkIterator) DatasetDims() []uint64 + func (it *ChunkIterator) Err() error + func (it *ChunkIterator) Next() bool + func (it *ChunkIterator) OnProgress(fn func(current, total int)) + func (it *ChunkIterator) Progress() (current, total int) + func (it *ChunkIterator) Reset() + func (it *ChunkIterator) Total() int + type CreateMode int + const CreateExclusive + const CreateTruncate + type Dataset struct + func (d *Dataset) Address() uint64 + func (d *Dataset) Attributes() ([]*core.Attribute, error) + func (d *Dataset) ChunkIterator() (*ChunkIterator, error) + func (d *Dataset) ChunkIteratorWithContext(ctx context.Context) (*ChunkIterator, error) + func (d *Dataset) Info() (string, error) + func (d *Dataset) ListAttributes() ([]string, error) + func (d *Dataset) Name() string + func (d *Dataset) Read() ([]float64, error) + func (d *Dataset) ReadAttribute(name string) (interface{}, error) + func (d *Dataset) ReadCompound() ([]core.CompoundValue, error) + func (d *Dataset) ReadHyperslab(selection *HyperslabSelection) (interface{}, error) + func (d *Dataset) ReadSlice(start, count []uint64) (interface{}, error) + func (d *Dataset) ReadStrings() ([]string, error) + func (d *Dataset) ReadVLenBytes() ([][]byte, error) + type DatasetOption func(*datasetConfig) + func WithArrayDims(dims []uint64) DatasetOption + func WithChunkDims(dims []uint64) DatasetOption + func WithEnumValues(names []string, values []int64) DatasetOption + func WithFletcher32() DatasetOption + func WithGZIPCompression(level int) DatasetOption + func WithMaxDims(maxDims []uint64) DatasetOption + func WithOpaqueTag(tag string, size uint32) DatasetOption + func WithShuffle() DatasetOption + func WithStringSize(size uint32) DatasetOption + type DatasetWriter struct + func (ds *DatasetWriter) DeleteAttribute(name string) error + func (ds *DatasetWriter) RebalanceAttributeBTree() error + func (ds *DatasetWriter) WriteAttribute(name string, value interface{}) error + func (dw *DatasetWriter) Close() error + func (dw *DatasetWriter) Resize(newDims []uint64) error + func (dw *DatasetWriter) Write(data interface{}) error + func (dw *DatasetWriter) WriteRaw(data []byte) error + type Datatype int + const ArrayFloat32 + const ArrayFloat64 + const ArrayInt16 + const ArrayInt32 + const ArrayInt64 + const ArrayInt8 + const ArrayUint16 + const ArrayUint32 + const ArrayUint64 + const ArrayUint8 + const EnumInt16 + const EnumInt32 + const EnumInt64 + const EnumInt8 + const EnumUint16 + const EnumUint32 + const EnumUint64 + const EnumUint8 + const Float32 + const Float64 + const Int16 + const Int32 + const Int64 + const Int8 + const ObjectReference + const Opaque + const RegionReference + const String + const Uint16 + const Uint32 + const Uint64 + const Uint8 + const VLenFloat32 + const VLenFloat64 + const VLenInt32 + const VLenInt64 + const VLenString + const VLenUint32 + const VLenUint64 + const VLenUint8 + type File struct + func Create(filename string, mode CreateMode) (*File, error) + func Open(filename string) (*File, error) + func (f *File) Close() error + func (f *File) Reader() io.ReaderAt + func (f *File) Root() *Group + func (f *File) Superblock() *core.Superblock + func (f *File) SuperblockVersion() uint8 + func (f *File) Walk(fn func(path string, obj Object)) + type FileWriteConfig struct + BTreeRebalancing bool + SuperblockVersion uint8 + type FileWriter struct + func CreateForWrite(filename string, mode CreateMode, opts ...interface{}) (*FileWriter, error) + func OpenForWrite(filename string, mode OpenMode, opts ...WriteOption) (*FileWriter, error) + func (fw *FileWriter) Close() error + func (fw *FileWriter) CreateCompoundDataset(name string, compoundType *core.DatatypeMessage, dims []uint64, ...) (*DatasetWriter, error) + func (fw *FileWriter) CreateDataset(name string, dtype Datatype, dims []uint64, opts ...DatasetOption) (*DatasetWriter, error) + func (fw *FileWriter) CreateDenseGroup(name string, links map[string]string) error + func (fw *FileWriter) CreateExternalLink(linkPath, fileName, objectPath string) error + func (fw *FileWriter) CreateGroup(path string) (*GroupWriter, error) + func (fw *FileWriter) CreateGroupWithLinks(name string, links map[string]string) error + func (fw *FileWriter) CreateHardLink(linkPath, targetPath string) error + func (fw *FileWriter) CreateSoftLink(linkPath, targetPath string) error + func (fw *FileWriter) Delete(path string) error + func (fw *FileWriter) DisableLazyRebalancing() error + func (fw *FileWriter) DisableRebalancing() + func (fw *FileWriter) EnableIncrementalRebalancing(config structures.IncrementalRebalancingConfig) error + func (fw *FileWriter) EnableLazyRebalancing(config structures.LazyRebalancingConfig) error + func (fw *FileWriter) EnableRebalancing() + func (fw *FileWriter) ForceBatchRebalance() error + func (fw *FileWriter) GetIncrementalRebalancingProgress() (structures.RebalancingProgress, error) + func (fw *FileWriter) GetLazyRebalancingStats() (totalUnderflow, totalPending int, oldestRebalance time.Duration) + func (fw *FileWriter) IsIncrementalRebalancingEnabled() bool + func (fw *FileWriter) IsLazyRebalancingEnabled() bool + func (fw *FileWriter) OpenDataset(path string) (*DatasetWriter, error) + func (fw *FileWriter) RebalanceAllBTrees() error + func (fw *FileWriter) RebalancingEnabled() bool + func (fw *FileWriter) StopIncrementalRebalancing() error + type FileWriterOption func(*FileWriter) error + func WithIncrementalRebalancing(opts ...IncrementalOption) FileWriterOption + func WithLazyRebalancing(opts ...LazyOption) FileWriterOption + func WithSmartRebalancing(opts ...SmartOption) FileWriterOption + type Group struct + func (g *Group) Attributes() ([]*core.Attribute, error) + func (g *Group) Children() []Object + func (g *Group) Name() string + type GroupMetadata struct + type GroupWriter struct + func (g *GroupWriter) DeleteAttribute(name string) error + func (g *GroupWriter) Path() string + func (g *GroupWriter) WriteAttribute(name string, value interface{}) error + type HeapID struct + CollectionAddress uint64 + ObjectIndex uint16 + SeqLen uint32 + func (hid HeapID) Encode() []byte + type HyperslabSelection struct + Block []uint64 + Count []uint64 + Start []uint64 + Stride []uint64 + type IncrementalOption func(*structures.IncrementalRebalancingConfig) + func IncrementalBudget(budget time.Duration) IncrementalOption + func IncrementalInterval(interval time.Duration) IncrementalOption + func IncrementalProgressCallback(callback func(structures.RebalancingProgress)) IncrementalOption + type LazyOption func(*structures.LazyRebalancingConfig) + func LazyBatchSize(size int) LazyOption + func LazyMaxDelay(delay time.Duration) LazyOption + func LazyThreshold(threshold float64) LazyOption + type ModeDecision struct + Confidence float64 + Factors map[string]float64 + Reason string + SelectedMode string + Timestamp time.Time + type NamedDatatype struct + func (n *NamedDatatype) Datatype() *core.DatatypeMessage + func (n *NamedDatatype) Name() string + type Object interface + Name func() string + type OpenMode int + const OpenReadOnly + const OpenReadWrite + type SmartOption func(*SmartRebalancingConfig) + func SmartAllowedModes(modes ...string) SmartOption + func SmartAutoDetect(enabled bool) SmartOption + func SmartAutoSwitch(enabled bool) SmartOption + func SmartMinFileSize(size uint64) SmartOption + func SmartOnModeChange(callback func(ModeDecision)) SmartOption + type SmartRebalancingConfig struct + AllowedModes []string + AutoDetect bool + AutoSwitch bool + MaxCPUPercent int + MinFileSize uint64 + OnModeChange func(decision ModeDecision) + type WriteOption func(*FileWriteConfig) + func WithBTreeRebalancing(enable bool) WriteOption + func WithSuperblockVersion(version uint8) WriteOption
Go to main page