Versions in this module Expand all Collapse all v0 v0.2.0 May 11, 2026 Changes in this version + const PartialSuffix + var MaxConcurrentFlushers int = 16 + var ZstdDecoderConcurrency = runtime.NumCPU() + func CleanAccountsDbDir(accountsDbDir string) + func CleanSnapshotDownloadDir(downloadPath string, maxSnapshots int) + func CleanupPartialDownload(savePath string) + func FinalizePartialDownload(savePath string) error + func NewBufMonReader(name string, r io.ReadCloser, totalSize int64) *bufmonreader + func NewBufMonReaderFromFile(file *os.File) (*bufmonreader, error) + func NewBufMonReaderHTTP(ctx context.Context, url string) (*bufmonreader, error) + func NewBufMonReaderHTTPWithSave(ctx context.Context, url string, savePath string) (*bufmonreader, error) + func PopulateManifestSeed(s *state.MithrilState, m *SnapshotManifest) + type AccountsDbFields struct + BankHashInfo BankHashInfo + HistoricalRoots []uint64 + HistoricalRootsWithHash []SlotMapPair + Slot uint64 + Storages map[uint64]SlotAcctVecs + Version uint64 + func (acctDbFields *AccountsDbFields) UnmarshalWithDecoder(decoder *bin.Decoder) error + type AcctVec struct + FileSize uint64 + Id uint64 + func (acctVec *AcctVec) UnmarshalWithDecoder(decoder *bin.Decoder) error + type BankHashInfo struct + Hash [32]byte + SnapshotHash [32]byte + Stats BankHashStats + func (info *BankHashInfo) UnmarshalWithDecoder(decoder *bin.Decoder) error + type BankHashStats struct + NumExecutableAccts uint64 + NumLamportsStored uint64 + NumRemovedAccts uint64 + NumUpdatedAccts uint64 + TotalDataLen uint64 + func (stats *BankHashStats) UnmarshalWithDecoder(decoder *bin.Decoder) error + type BankIncrementalSnapshotPersistence struct + FullCapitalization uint64 + FullHash [32]byte + FullSlot uint64 + IncrementalCapitalization uint64 + IncrementalHash [32]byte + func (bankIncrSnapshotPersistence *BankIncrementalSnapshotPersistence) UnmarshalWithDecoder(decoder *bin.Decoder) error + type BlockHashVec struct + HashAndAge []HashAgePair + LastHash *[32]byte + LastHashIndex uint64 + MaxAge uint64 + func (bhv *BlockHashVec) UnmarshalWithDecoder(decoder *bin.Decoder) error + type Delegation struct + ActivationEpoch uint64 + DeactivationEpoch uint64 + Stake uint64 + VoterPubkey solana.PublicKey + WarmupCooldownRate float64 + func (delegation *Delegation) UnmarshalWithDecoder(decoder *bin.Decoder) error + type DelegationPair struct + Account solana.PublicKey + Delegation Delegation + func (delegationPair *DelegationPair) UnmarshalWithDecoder(decoder *bin.Decoder) error + type DeserializableVersionedBank struct + AccountsDataLen uint64 + Ancestors []SlotPair + BlockHeight uint64 + BlockhashQueue BlockHashVec + Capitalization uint64 + CollectedRent uint64 + CollectorFees uint64 + CollectorId solana.PublicKey + Epoch uint64 + EpochSchedule sealevel.SysvarEpochSchedule + EpochStakes []EpochStakesPair + FeeCalculator sealevel.FeeCalculator + FeeRateGovernor sealevel.FeeRateGovernor + GenesisCreationTime uint64 + HardForks []SlotPair + Hash [32]byte + HashesPerTick *uint64 + Inflation rewards.Inflation + IsDelta bool + MaxTickHeight uint64 + NsPerSlot bin.Uint128 + ParentHash [32]byte + ParentSlot uint64 + RentCollector RentCollector + SignatureCount uint64 + Slot uint64 + SlotsPerYear float64 + Stakes Stakes + TickHeight uint64 + TicksPerSlot uint64 + TransactionCount uint64 + UnusedAccounts UnusedAccounts + func (dsv *DeserializableVersionedBank) UnmarshalWithDecoder(decoder *bin.Decoder) error + type EpochStakes struct + EpochAuthorizedVoters []PubkeyPair + NodeIdToVoteAccounts []NodeVoteAccountsPair + Stakes Stakes + TotalStake uint64 + func (epochStakes *EpochStakes) UnmarshalWithDecoder(decoder *bin.Decoder) error + type EpochStakesPair struct + Key uint64 + Val EpochStakes + func (epochStakesPair *EpochStakesPair) UnmarshalWithDecoder(decoder *bin.Decoder) error + type HashAge struct + FeeCalculator sealevel.FeeCalculator + HashIndex uint64 + Timestamp uint64 + func (age *HashAge) UnmarshalWithDecoder(decoder *bin.Decoder) error + type HashAgePair struct + Key [32]byte + Val HashAge + func (hashAgePair *HashAgePair) UnmarshalWithDecoder(decoder *bin.Decoder) error + type NodeVoteAccounts struct + TotalStake uint64 + VoteAccounts []solana.PublicKey + func (nodeVoteAccts *NodeVoteAccounts) UnmarshalWithDecoder(decoder *bin.Decoder) error + type NodeVoteAccountsPair struct + Key solana.PublicKey + Val NodeVoteAccounts + func (pair *NodeVoteAccountsPair) UnmarshalWithDecoder(decoder *bin.Decoder) error + type ProgressCallback func(bytesRead, totalBytes int64) + type PubkeyPair struct + Key solana.PublicKey + Val solana.PublicKey + func (pubkeyPair *PubkeyPair) UnmarshalWithDecoder(decoder *bin.Decoder) error + type RentCollector struct + Epoch uint64 + EpochSchedule sealevel.SysvarEpochSchedule + Rent sealevel.SysvarRent + SlotsPerYear float64 + func (rentCollector *RentCollector) UnmarshalWithDecoder(decoder *bin.Decoder) error + type RewardInfo struct + Commission uint64 + Lamports uint64 + NewCreditsObserved uint64 + PostBalance uint64 + RewardType uint32 + StakerRewards uint64 + func (rewardInfo *RewardInfo) UnmarshalWithDecoder(decoder *bin.Decoder) error + type SerializableEpochRewardStatus struct + Active StartBlockHeightAndRewards + Type uint32 + func (epochRewardStatus *SerializableEpochRewardStatus) UnmarshalWithDecoder(decoder *bin.Decoder) error + type SerializableStakeRewards struct + RewardInfo RewardInfo + StakePubkey solana.PublicKey + func (stakeRewards *SerializableStakeRewards) UnmarshalWithDecoder(decoder *bin.Decoder) error + type ShardLogger struct + func NewShardLogger(numShards int, filePrefix string) *ShardLogger + func (sl *ShardLogger) BytesDone() int64 + func (sl *ShardLogger) Close(ctx context.Context) error + func (sl *ShardLogger) CloseWithProgress(ctx context.Context, onProgress func(completed, total int)) error + func (sl *ShardLogger) EnqueueRequest(k solana.PublicKey, v accountsdb.AccountIndexEntry) + func (sl *ShardLogger) SetProgressCallback(cb ShardProgressCallback) + func (sl *ShardLogger) TotalBytes() int64 + type ShardProgressCallback func(bytesDone, totalBytes int64) + type SlotAcctVecs struct + AcctVecs []AcctVec + Slot uint64 + func (slotAcctVecs *SlotAcctVecs) UnmarshalWithDecoder(decoder *bin.Decoder) error + type SlotMapPair struct + Hash [32]byte + Slot uint64 + func (pair *SlotMapPair) UnmarshalWithDecoder(decoder *bin.Decoder) error + type SlotPair struct + Slot uint64 + Val uint64 + func (slotPair *SlotPair) UnmarshalWithDecoder(decoder *bin.Decoder) error + type SnapshotManifest struct + AccountsDb *AccountsDbFields + Bank *DeserializableVersionedBank + BankIncrementalSnapshotPersistence *BankIncrementalSnapshotPersistence + EpochAccountHash [32]byte + LamportsPerSignature uint64 + LtHash *lthash.LtHash + VersionedEpochStakes []VersionedEpochStakesPair + func BuildAccountsDbAuto(ctx context.Context, fullSnapshotFile string, snapshotDownloadPath string, ...) (*accountsdb.AccountsDb, *SnapshotManifest, error) + func BuildAccountsDbPaths(ctx context.Context, snapshotFile string, incrementalSnapshotFile string, ...) (*accountsdb.AccountsDb, *SnapshotManifest, error) + func LoadManifestFromFile(filename string) (*SnapshotManifest, error) + func UnmarshalManifestFromSnapshot(ctx context.Context, filename string, accountsDbDir string) (*SnapshotManifest, error) + func (snapshot *SnapshotManifest) UnmarshalWithDecoder(decoder *bin.Decoder) error + type Stake struct + Epoch uint64 + StakeDelegations map[solana.PublicKey]StakePair + StakeHistory sealevel.SysvarStakeHistory + Unused uint64 + VoteAccounts []VoteAccountsPair + func (stakes *Stake) UnmarshalWithDecoder(decoder *bin.Decoder) error + type StakeInner struct + CreditsObserved uint64 + Delegation Delegation + func (stakeInner *StakeInner) UnmarshalWithDecoder(decoder *bin.Decoder) error + type StakePair struct + Account [32]byte + Stake StakeInner + func (stakePair *StakePair) UnmarshalWithDecoder(decoder *bin.Decoder) error + type Stakes struct + Delegations []DelegationPair + Epoch uint64 + StakeHistory sealevel.SysvarStakeHistory + Unused uint64 + VoteAccounts []VoteAccountsPair + func (stakes *Stakes) UnmarshalWithDecoder(decoder *bin.Decoder) error + type StartBlockHeightAndRewards struct + StakeRewardsByPartition map[solana.PublicKey]SerializableStakeRewards + StartBlockHeight uint64 + func (startBlockHeightAndRewards *StartBlockHeightAndRewards) UnmarshalWithDecoder(decoder *bin.Decoder) error + type UnusedAccounts struct + Unused1 []solana.PublicKey + Unused2 []solana.PublicKey + Unused3 []UnusedAccountsU64Pair + func (unusedAccts *UnusedAccounts) UnmarshalWithDecoder(decoder *bin.Decoder) error + type UnusedAccountsU64Pair struct + func (pair *UnusedAccountsU64Pair) UnmarshalWithDecoder(decoder *bin.Decoder) error + type VersionedEpochStakes struct + EpochAuthorizedVoters []PubkeyPair + NodeIdToVoteAccounts []NodeVoteAccountsPair + Stakes Stake + TotalStake uint64 + func (versionedEpochStakes *VersionedEpochStakes) UnmarshalWithDecoder(decoder *bin.Decoder) error + type VersionedEpochStakesPair struct + Epoch uint64 + Val VersionedEpochStakes + func (epochStakesPair *VersionedEpochStakesPair) UnmarshalWithDecoder(decoder *bin.Decoder) error + type VoteAccount struct + Executable byte + Lamports uint64 + LastTimestampSlot uint64 + LastTimestampTs int64 + NodePubkey solana.PublicKey + Owner solana.PublicKey + RentEpoch uint64 + func (voteAcct *VoteAccount) UnmarshalWithDecoder(decoder *bin.Decoder) error + type VoteAccountsPair struct + Key solana.PublicKey + Stake uint64 + Value VoteAccount + func (voteAcctsPair *VoteAccountsPair) UnmarshalWithDecoder(decoder *bin.Decoder) error v0.1.0-alpha.1 Jan 15, 2026