memstor

Documentation

Index

• Constants
• Variables
• type DirectoryMap
• type MemoryStorageReader
  • func NewMemoryStorageReaderFromWriter(w *MemoryStorageWriter) MemoryStorageReader
  • func (v MemoryStorageReader) FindDirectoryEntry(id ledger.SectionID, ref reference.Holder) (ledger.Ordinal, error)
  • func (v MemoryStorageReader) FindDirectoryEntryLocator(id ledger.SectionID, ref reference.Holder) (ledger.StorageLocator, error)
  • func (v MemoryStorageReader) FinderOfFirst(ledger.SectionID) readbundle.DirectoryIndexFinder
  • func (v MemoryStorageReader) FinderOfLast(ledger.SectionID) readbundle.DirectoryIndexFinder
  • func (v MemoryStorageReader) FinderOfNext(sectionID ledger.SectionID) readbundle.DirectoryIndexFinder
  • func (v MemoryStorageReader) GetDirectoryEntryLocator(index ledger.DirectoryIndex) (ledger.StorageLocator, error)
  • func (v MemoryStorageReader) GetEntryStorage(locator ledger.StorageLocator) (readbundle.Slice, error)
  • func (v MemoryStorageReader) GetPayloadStorage(locator ledger.StorageLocator, size int) (readbundle.Slice, error)
• type MemoryStorageWriter
  • func NewMemoryStorageWriter(pn pulse.Number, maxSection ledger.SectionID, pageSize int) *MemoryStorageWriter
  • func (p *MemoryStorageWriter) DirtyReader() bundle.DirtyReader
  • func (p *MemoryStorageWriter) GetDirectoryEntries(section ledger.SectionID) [][]bundle.DirectoryEntry
  • func (p *MemoryStorageWriter) GetDirectoryEntry(index ledger.DirectoryIndex) bundle.DirectoryEntry
  • func (p *MemoryStorageWriter) GetDirectoryEntryLocator(index ledger.DirectoryIndex) (ledger.StorageLocator, error)
  • func (p *MemoryStorageWriter) GetEntryStorage(locator ledger.StorageLocator) (readbundle.Slice, error)
  • func (p *MemoryStorageWriter) GetPayloadStorage(locator ledger.StorageLocator, size int) (readbundle.Slice, error)
  • func (p *MemoryStorageWriter) IsReadOnly() bool
  • func (p *MemoryStorageWriter) MarkReadOnly() error
  • func (p *MemoryStorageWriter) PulseNumber() pulse.Number
  • func (p *MemoryStorageWriter) TakeSnapshot() (bundle.Snapshot, error)

Constants

const MinStoragePageSize = directoryEntrySize * 16

Variables

var ErrCtlRecNotFound = throw.E("control record not found")

var ErrIndexSectionMismatch = throw.E("section mismatch by index")

var ErrIndexUnknownOrdinal = throw.E("unknown ordinal by index")

var ErrInvalidOrdinalIndex = throw.E("ordinal index has wrong size")

Types

type DirectoryMap

type DirectoryMap interface {
	FindLocator(reference.Holder) ledger.StorageLocator
	FindOrdinal(reference.Holder) ledger.Ordinal
	GetByOrdinal(ledger.Ordinal) ledger.StorageLocator
}

type MemoryStorageReader

type MemoryStorageReader struct {
	// contains filtered or unexported fields
}

func NewMemoryStorageReaderFromWriter

func NewMemoryStorageReaderFromWriter(w *MemoryStorageWriter) MemoryStorageReader

func (MemoryStorageReader) FindDirectoryEntry

func (v MemoryStorageReader) FindDirectoryEntry(id ledger.SectionID, ref reference.Holder) (ledger.Ordinal, error)

func (MemoryStorageReader) FindDirectoryEntryLocator

func (v MemoryStorageReader) FindDirectoryEntryLocator(id ledger.SectionID, ref reference.Holder) (ledger.StorageLocator, error)

func (MemoryStorageReader) FinderOfFirst

func (v MemoryStorageReader) FinderOfFirst(ledger.SectionID) readbundle.DirectoryIndexFinder

func (MemoryStorageReader) FinderOfLast

func (v MemoryStorageReader) FinderOfLast(ledger.SectionID) readbundle.DirectoryIndexFinder

func (MemoryStorageReader) FinderOfNext

func (v MemoryStorageReader) FinderOfNext(sectionID ledger.SectionID) readbundle.DirectoryIndexFinder

func (MemoryStorageReader) GetDirectoryEntryLocator

func (v MemoryStorageReader) GetDirectoryEntryLocator(index ledger.DirectoryIndex) (ledger.StorageLocator, error)

func (MemoryStorageReader) GetEntryStorage

func (v MemoryStorageReader) GetEntryStorage(locator ledger.StorageLocator) (readbundle.Slice, error)

func (MemoryStorageReader) GetPayloadStorage

func (v MemoryStorageReader) GetPayloadStorage(locator ledger.StorageLocator, size int) (readbundle.Slice, error)

type MemoryStorageWriter

type MemoryStorageWriter struct {
	// contains filtered or unexported fields
}

func NewMemoryStorageWriter

func NewMemoryStorageWriter(pn pulse.Number, maxSection ledger.SectionID, pageSize int) *MemoryStorageWriter

func (*MemoryStorageWriter) DirtyReader

func (p *MemoryStorageWriter) DirtyReader() bundle.DirtyReader

func (*MemoryStorageWriter) GetDirectoryEntries

func (p *MemoryStorageWriter) GetDirectoryEntries(section ledger.SectionID) [][]bundle.DirectoryEntry

func (*MemoryStorageWriter) GetDirectoryEntry

func (p *MemoryStorageWriter) GetDirectoryEntry(index ledger.DirectoryIndex) bundle.DirectoryEntry

func (*MemoryStorageWriter) GetDirectoryEntryLocator

func (p *MemoryStorageWriter) GetDirectoryEntryLocator(index ledger.DirectoryIndex) (ledger.StorageLocator, error)

func (*MemoryStorageWriter) GetEntryStorage

func (p *MemoryStorageWriter) GetEntryStorage(locator ledger.StorageLocator) (readbundle.Slice, error)

func (*MemoryStorageWriter) GetPayloadStorage

func (p *MemoryStorageWriter) GetPayloadStorage(locator ledger.StorageLocator, size int) (readbundle.Slice, error)

func (*MemoryStorageWriter) IsReadOnly

func (p *MemoryStorageWriter) IsReadOnly() bool

func (*MemoryStorageWriter) MarkReadOnly

func (p *MemoryStorageWriter) MarkReadOnly() error

func (*MemoryStorageWriter) PulseNumber

func (p *MemoryStorageWriter) PulseNumber() pulse.Number

func (*MemoryStorageWriter) TakeSnapshot

func (p *MemoryStorageWriter) TakeSnapshot() (bundle.Snapshot, error)