Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

dag

package

Go to main page

Versions in this module

v2

v2.1.5

Jan 6, 2026

v2.1.4

Dec 19, 2025

Changes in this version

+ type BatchContentStore interface

+ RetrieveContents func(hashes []string) (map[string][]byte, error)

+ StoreContents func(contents map[string][]byte) error

+ type BatchLeafStore interface

+ RetrieveLeaves func(hashes []string) (map[string]*DagLeaf, error)

+ StoreLeaves func(leaves []*DagLeaf) error

+ type ContentStore interface

+ DeleteContent func(hash string) error

+ HasContent func(hash string) (bool, error)

+ RetrieveContent func(hash string) ([]byte, error)

+ StoreContent func(hash string, content []byte) error

+ type DagIndex struct

+ Children map[string][]string

+ LeafHashes []string

+ Parents map[string]string

+ func NewDagIndex() *DagIndex

+ type DagStore struct

+ Labels map[string]string

+ LeafCount int

+ Root string

+ func FromCBORToStore(data []byte, leafStore LeafStore, contentStore ContentStore) (*DagStore, error)

+ func FromJSONToStore(data []byte, leafStore LeafStore, contentStore ContentStore) (*DagStore, error)

+ func NewDagStore(d *Dag) *DagStore

+ func NewDagStoreWithOptions(d *Dag, opts ...DagStoreOption) *DagStore

+ func NewDagStoreWithStorage(d *Dag, leafStore LeafStore, contentStore ContentStore) *DagStore

+ func NewEmptyDagStore(leafStore LeafStore, contentStore ContentStore) *DagStore

+ func NewEmptyDagStoreWithOptions(opts ...DagStoreOption) *DagStore

+ func (ds *DagStore) AddBatchedTransmissionPacket(packet *BatchedTransmissionPacket) error

+ func (ds *DagStore) AddToIndex(leafHash string, parentHash string, children []string)

+ func (ds *DagStore) AddTransmissionPacket(packet *TransmissionPacket) error

+ func (ds *DagStore) BuildIndex() error

+ func (ds *DagStore) CalculateLabels() error

+ func (ds *DagStore) ClearIndex()

+ func (ds *DagStore) CountLeavesStreaming() (int, error)

+ func (ds *DagStore) CreateDirectory(path string) error

+ func (ds *DagStore) CreateDirectoryStreaming(path string) error

+ func (ds *DagStore) DeleteLeaf(hash string) error

+ func (ds *DagStore) GetContentFromLeaf(hash string) ([]byte, error)

+ func (ds *DagStore) GetContentFromLeafStreaming(hash string) ([]byte, error)

+ func (ds *DagStore) GetHashesByLabelRange(startLabel, endLabel string) ([]string, error)

+ func (ds *DagStore) GetIndex() *DagIndex

+ func (ds *DagStore) GetLeafSequence() ([]*TransmissionPacket, error)

+ func (ds *DagStore) GetPartial(leafHashes []string, pruneLinks bool) (*Dag, error)

+ func (ds *DagStore) HasIndex() bool

+ func (ds *DagStore) HasLeaf(hash string) (bool, error)

+ func (ds *DagStore) IsPartial() bool

+ func (ds *DagStore) IterateDag(processLeaf func(leaf *DagLeaf, parent *DagLeaf) error) error

+ func (ds *DagStore) IterateDagStreaming(processLeaf func(leaf *DagLeaf, parent *DagLeaf) error) error

+ func (ds *DagStore) IterateDagWithIndex(processLeaf func(leafHash string, parentHash string) error) error

+ func (ds *DagStore) MarkIndexBuilt()

+ func (ds *DagStore) RetrieveLeaf(hash string) (*DagLeaf, error)

+ func (ds *DagStore) RetrieveLeafWithoutContent(hash string) (*DagLeaf, error)

+ func (ds *DagStore) SetRoot(rootHash string) error

+ func (ds *DagStore) StoreLeaf(leaf *DagLeaf) error

+ func (ds *DagStore) StoreLeavesInBatches(leaves []*DagLeaf) error

+ func (ds *DagStore) ToCBOR() ([]byte, error)

+ func (ds *DagStore) ToDag() (*Dag, error)

+ func (ds *DagStore) ToJSON() ([]byte, error)

+ func (ds *DagStore) UpdateParentHashesStreaming(batchSize int) error

+ func (ds *DagStore) Verify() error

+ func (ds *DagStore) VerifyLeaf(hash string) error

+ func (ds *DagStore) VerifyLeafWithParent(leafHash string, parentHash string, proof *ClassicTreeBranch) error

+ func (ds *DagStore) VerifyStreaming() error

+ type DagStoreOption func(*DagStore)

+ func WithContentStore(store ContentStore) DagStoreOption

+ func WithLeafStore(store LeafStore) DagStoreOption

+ func WithSeparateContent(separate bool) DagStoreOption

+ type LeafCounter interface

+ Count func() int

+ type LeafEnumerator interface

+ GetAllLeafHashes func() []string

+ type LeafStore interface

+ DeleteLeaf func(hash string) error

+ HasLeaf func(hash string) (bool, error)

+ RetrieveLeaf func(hash string) (*DagLeaf, error)

+ StoreLeaf func(leaf *DagLeaf) error

+ type MemoryContentStore struct

+ func NewMemoryContentStore() *MemoryContentStore

+ func (s *MemoryContentStore) DeleteContent(hash string) error

+ func (s *MemoryContentStore) HasContent(hash string) (bool, error)

+ func (s *MemoryContentStore) RetrieveContent(hash string) ([]byte, error)

+ func (s *MemoryContentStore) RetrieveContents(hashes []string) (map[string][]byte, error)

+ func (s *MemoryContentStore) StoreContent(hash string, content []byte) error

+ func (s *MemoryContentStore) StoreContents(contents map[string][]byte) error

+ type MemoryLeafStore struct

+ func NewMemoryLeafStore() *MemoryLeafStore

+ func (s *MemoryLeafStore) Count() int

+ func (s *MemoryLeafStore) DeleteLeaf(hash string) error

+ func (s *MemoryLeafStore) GetAllLeafHashes() []string

+ func (s *MemoryLeafStore) GetAllLeaves() map[string]*DagLeaf

+ func (s *MemoryLeafStore) HasLeaf(hash string) (bool, error)

+ func (s *MemoryLeafStore) RetrieveLeaf(hash string) (*DagLeaf, error)

+ func (s *MemoryLeafStore) RetrieveLeaves(hashes []string) (map[string]*DagLeaf, error)

+ func (s *MemoryLeafStore) StoreLeaf(leaf *DagLeaf) error

+ func (s *MemoryLeafStore) StoreLeaves(leaves []*DagLeaf) error

+ type RelationshipCache interface

+ GetCachedRelationships func() map[string]string

v2.0.4

Oct 27, 2025

v2.0.3

Oct 24, 2025

v2.0.2

Oct 23, 2025

v2.0.1

Oct 23, 2025

v2.0.0

Oct 23, 2025

Changes in this version

+ const DefaultBatchSize

+ const DefaultChunkSize

+ var BatchSize = DefaultBatchSize

+ var ChunkSize = DefaultChunkSize

+ func CalculateTotalContentSize(dag *Dag) int64

+ func CalculateTotalDagSize(dag *Dag) (int64, error)

+ func DisableBatching()

+ func DisableChunking()

+ func SetBatchSize(size int)

+ func SetChunkSize(size int)

+ func SetDefaultBatchSize()

+ func SetDefaultChunkSize()

+ func SortMapByKeys(inputMap map[string]string) map[string]string

+ type BatchedTransmissionPacket struct

+ Leaves []*DagLeaf

+ PacketIndex int

+ Relationships map[string]string

+ TotalPackets int

+ func BatchedTransmissionPacketFromCBOR(data []byte) (*BatchedTransmissionPacket, error)

+ func BatchedTransmissionPacketFromJSON(data []byte) (*BatchedTransmissionPacket, error)

+ func BatchedTransmissionPacketFromSerializable(s *SerializableBatchedTransmissionPacket) *BatchedTransmissionPacket

+ func (packet *BatchedTransmissionPacket) GetRootLeaf() *DagLeaf

+ func (packet *BatchedTransmissionPacket) ToCBOR() ([]byte, error)

+ func (packet *BatchedTransmissionPacket) ToJSON() ([]byte, error)

+ func (packet *BatchedTransmissionPacket) ToSerializable() *SerializableBatchedTransmissionPacket

+ type ClassicTreeBranch struct

+ Leaf string

+ Proof *merkletree.Proof

+ type Dag struct

+ Labels map[string]string

+ Leafs map[string]*DagLeaf

+ Root string

+ func CreateDag(path string, timestampRoot bool) (*Dag, error)

+ func CreateDagAdvanced(path string, additionalData map[string]string) (*Dag, error)

+ func CreateDagCustom(path string, rootAdditionalData map[string]string, processor LeafProcessor) (*Dag, error)

+ func CreateDagWithConfig(path string, config *DagBuilderConfig) (*Dag, error)

+ func FromCBOR(data []byte) (*Dag, error)

+ func FromJSON(data []byte) (*Dag, error)

+ func FromSerializable(s *SerializableDag) *Dag

+ func ReadDag(path string) (*Dag, error)

+ func (d *Dag) ApplyAndVerifyBatchedTransmissionPacket(packet *BatchedTransmissionPacket) error

+ func (d *Dag) ApplyAndVerifyTransmissionPacket(packet *TransmissionPacket) error

+ func (d *Dag) ApplyBatchedTransmissionPacket(packet *BatchedTransmissionPacket)

+ func (d *Dag) ApplyTransmissionPacket(packet *TransmissionPacket)

+ func (d *Dag) CalculateLabels() error

+ func (d *Dag) ClearLabels()

+ func (d *Dag) GetBatchedLeafSequence() []*BatchedTransmissionPacket

+ func (d *Dag) GetHashesByLabelRange(startLabel, endLabel string) ([]string, error)

+ func (d *Dag) GetLabel(hash string) (string, error)

+ func (d *Dag) GetLeafSequence() []*TransmissionPacket

+ func (d *Dag) GetPartial(leafHashes []string, pruneLinks bool) (*Dag, error)

+ func (d *Dag) IsPartial() bool

+ func (d *Dag) IterateDag(processLeaf func(leaf *DagLeaf, parent *DagLeaf) error) error

+ func (d *Dag) RemoveAllContent()

+ func (d *Dag) Verify() error

+ func (d *Dag) VerifyBatchedTransmissionPacket(packet *BatchedTransmissionPacket) error

+ func (d *Dag) VerifyTransmissionPacket(packet *TransmissionPacket) error

+ func (dag *Dag) CreateDirectory(path string) error

+ func (dag *Dag) GetContentFromLeaf(leaf *DagLeaf) ([]byte, error)

+ func (dag *Dag) ToCBOR() ([]byte, error)

+ func (dag *Dag) ToJSON() ([]byte, error)

+ func (dag *Dag) ToSerializable() *SerializableDag

+ type DagBranch struct

+ Leaf *DagLeaf

+ MerkleProofs map[string]*ClassicTreeBranch

+ Path []*DagLeaf

+ type DagBuilder struct

+ Leafs map[string]*DagLeaf

+ func CreateDagBuilder() *DagBuilder

+ func (b *DagBuilder) AddLeaf(leaf *DagLeaf, parentLeaf *DagLeaf) error

+ func (b *DagBuilder) AddLeafSafe(leaf *DagLeaf, parentLeaf *DagLeaf) error

+ func (b *DagBuilder) BuildDag(root string) *Dag

+ type DagBuilderConfig struct

+ AdditionalData map[string]string

+ EnableParallel bool

+ MaxWorkers int

+ Processor LeafProcessor

+ TimestampRoot bool

+ func DefaultConfig() *DagBuilderConfig

+ func ParallelConfig() *DagBuilderConfig

+ func ParallelConfigWithWorkers(workers int) *DagBuilderConfig

+ type DagLeaf struct

+ AdditionalData map[string]string

+ ClassicMerkleRoot []byte

+ Content []byte

+ ContentHash []byte

+ ContentSize int64

+ CurrentLinkCount int

+ DagSize int64

+ Hash string

+ ItemName string

+ LeafCount int

+ LeafMap map[string]merkletree.DataBlock

+ Links []string

+ MerkleTree *merkletree.MerkleTree

+ ParentHash string

+ Proofs map[string]*ClassicTreeBranch

+ Type LeafType

+ func (leaf *DagLeaf) AddLink(hash string)

+ func (leaf *DagLeaf) Clone() *DagLeaf

+ func (leaf *DagLeaf) CreateDirectoryLeaf(path string, dag *Dag) error

+ func (leaf *DagLeaf) EstimateSize() int

+ func (leaf *DagLeaf) GetBranch(key string) (*ClassicTreeBranch, error)

+ func (leaf *DagLeaf) GetIndexForKey(key string) (int, bool)

+ func (leaf *DagLeaf) HasLink(hash string) bool

+ func (leaf *DagLeaf) ToSerializable() *SerializableDagLeaf

+ func (leaf *DagLeaf) VerifyBranch(branch *ClassicTreeBranch) error

+ func (leaf *DagLeaf) VerifyChildrenAgainstMerkleRoot(dag *Dag) error

+ func (leaf *DagLeaf) VerifyLeaf() error

+ func (leaf *DagLeaf) VerifyRootLeaf(dag *Dag) error

+ type DagLeafBuilder struct

+ Data []byte

+ ItemName string

+ Label int64

+ LeafType LeafType

+ Links []string

+ func CreateDagLeafBuilder(name string) *DagLeafBuilder

+ func (b *DagLeafBuilder) AddLink(hash string)

+ func (b *DagLeafBuilder) BuildLeaf(additionalData map[string]string) (*DagLeaf, error)

+ func (b *DagLeafBuilder) BuildRootLeaf(dag *DagBuilder, additionalData map[string]string) (*DagLeaf, error)

+ func (b *DagLeafBuilder) SetData(data []byte)

+ func (b *DagLeafBuilder) SetType(leafType LeafType)

+ type KeyValue struct

+ Key string

+ Value string

+ func SortMapForVerification(inputMap map[string]string) []KeyValue

+ type LeafProcessor func(path string, relPath string, entry fs.DirEntry, isRoot bool, leafType LeafType) map[string]string

+ type LeafType string

+ const ChunkLeafType

+ const DirectoryLeafType

+ const FileLeafType

+ type SerializableBatchedTransmissionPacket struct

+ Leaves []*SerializableDagLeaf

+ Relationships map[string]string

+ type SerializableDag struct

+ Leafs map[string]*SerializableDagLeaf

+ Root string

+ type SerializableDagLeaf struct

+ AdditionalData map[string]string

+ ClassicMerkleRoot []byte

+ Content []byte

+ ContentHash []byte

+ ContentSize int64

+ CurrentLinkCount int

+ DagSize int64

+ Hash string

+ ItemName string

+ LeafCount int

+ Links []string

+ StoredProofs map[string]*ClassicTreeBranch

+ Type LeafType

+ type SerializableTransmissionPacket struct

+ Leaf *SerializableDagLeaf

+ ParentHash string

+ Proofs map[string]*ClassicTreeBranch

+ type TransmissionPacket struct

+ Leaf *DagLeaf

+ ParentHash string

+ Proofs map[string]*ClassicTreeBranch

+ func TransmissionPacketFromCBOR(data []byte) (*TransmissionPacket, error)

+ func TransmissionPacketFromJSON(data []byte) (*TransmissionPacket, error)

+ func TransmissionPacketFromSerializable(s *SerializableTransmissionPacket) *TransmissionPacket

+ func (packet *TransmissionPacket) ToCBOR() ([]byte, error)

+ func (packet *TransmissionPacket) ToJSON() ([]byte, error)

+ func (packet *TransmissionPacket) ToSerializable() *SerializableTransmissionPacket

Other modules containing this package

github.com/HORNET-Storage/Scionic-Merkle-Tree