Documentation
¶
Index ¶
- Constants
- func JetCtlRecordRef(id jet.ID, recordType uint64) reference.Global
- func SectionCtlRecordRef(id ledger.SectionID, recordType uint64) reference.Global
- func SortOrdinals(list []ledger.Ordinal)
- type FilamentHead
- type OrdinalListMapper
- type SectionSummaryWriter
- func (p *SectionSummaryWriter) ApplyRollback()
- func (p *SectionSummaryWriter) ApplyWrite() ([]ledger.DirectoryIndex, error)
- func (p *SectionSummaryWriter) PrepareWrite(snapshot bundle.Snapshot) error
- func (p *SectionSummaryWriter) ReadCatalog(dirtyReader bundle.DirtyReader, section ledger.SectionID) error
- type WriteAssistant
- func (p *WriteAssistant) Init(writer bundle.Writer, localDropCount int, callbackFn func(error))
- func (p *WriteAssistant) WriteDropSummary(id jet.DropID, finalizeFn func()) (catalog.DropReport, error)
- func (p *WriteAssistant) WriteFilamentSummary(id jet.DropID, lineBase reference.Local, fil lineage.FilamentSummary) error
- func (p *WriteAssistant) WriteLineSummary(id jet.DropID, recap lineage.FilamentSummary, report rms.RStateReport) error
- func (p *WriteAssistant) WritePlashStart(pd pulse.Data, population census.OnlinePopulation) (err error)
- func (p *WriteAssistant) WritePlashSummary() (err error)
- func (p *WriteAssistant) WriteSectionSummary(reader bundle.DirtyReader, section ledger.SectionID) error
Constants ¶
View Source
const FilamentHeadSize = 12
View Source
const SPNControlSection = pulse.Number(127)
View Source
const SerializationVersion = 0x0001_0000
Variables ¶
This section is empty.
Functions ¶
func SectionCtlRecordRef ¶
func SortOrdinals ¶
Types ¶
type FilamentHead ¶
type OrdinalListMapper ¶
type OrdinalListMapper []byte
func NewOrdinalListMapper ¶
func NewOrdinalListMapper(b []byte) OrdinalListMapper
func (OrdinalListMapper) Len ¶
func (v OrdinalListMapper) Len() int
type SectionSummaryWriter ¶
type SectionSummaryWriter struct {
// contains filtered or unexported fields
}
func (*SectionSummaryWriter) ApplyRollback ¶
func (p *SectionSummaryWriter) ApplyRollback()
func (*SectionSummaryWriter) ApplyWrite ¶
func (p *SectionSummaryWriter) ApplyWrite() ([]ledger.DirectoryIndex, error)
func (*SectionSummaryWriter) PrepareWrite ¶
func (p *SectionSummaryWriter) PrepareWrite(snapshot bundle.Snapshot) error
PrepareWrite implementation should be much lighter, but there is only one summary written, so it doesn't matter much
func (*SectionSummaryWriter) ReadCatalog ¶
func (p *SectionSummaryWriter) ReadCatalog(dirtyReader bundle.DirtyReader, section ledger.SectionID) error
type WriteAssistant ¶
type WriteAssistant struct {
// contains filtered or unexported fields
}
func (*WriteAssistant) Init ¶
func (p *WriteAssistant) Init(writer bundle.Writer, localDropCount int, callbackFn func(error))
func (*WriteAssistant) WriteDropSummary ¶
func (p *WriteAssistant) WriteDropSummary(id jet.DropID, finalizeFn func()) (catalog.DropReport, error)
func (*WriteAssistant) WriteFilamentSummary ¶
func (p *WriteAssistant) WriteFilamentSummary(id jet.DropID, lineBase reference.Local, fil lineage.FilamentSummary) error
func (*WriteAssistant) WriteLineSummary ¶
func (p *WriteAssistant) WriteLineSummary(id jet.DropID, recap lineage.FilamentSummary, report rms.RStateReport) error
func (*WriteAssistant) WritePlashStart ¶
func (p *WriteAssistant) WritePlashStart(pd pulse.Data, population census.OnlinePopulation) (err error)
func (*WriteAssistant) WritePlashSummary ¶
func (p *WriteAssistant) WritePlashSummary() (err error)
func (*WriteAssistant) WriteSectionSummary ¶
func (p *WriteAssistant) WriteSectionSummary(reader bundle.DirtyReader, section ledger.SectionID) error
Click to show internal directories.
Click to hide internal directories.