infra

Mar 28, 2024

Changes in this version

+ const DefaultFullMapCap

+ const DefaultPulledMapCap

+ func NewSnapshotFull(db *pebble.DB) silo.Snapshot

+ func NewSnapshotInterateOnce(db *pebble.DB) silo.Snapshot

+ type BackendFull struct

+ func NewBackendFull(path string) (BackendFull, error)

+ func (b BackendFull) Snapshot() silo.Snapshot

+ type BackendInterateOnce struct

+ func NewBackendInterateOnce(path string) (BackendInterateOnce, error)

+ func (b BackendInterateOnce) Snapshot() silo.Snapshot

+ type SnapshotFull struct

+ func (s *SnapshotFull) Close() error

+ func (s *SnapshotFull) Load() error

+ func (s *SnapshotFull) Next() (silo.DataNode, bool, error)

+ func (s *SnapshotFull) PullAll(node silo.DataNode) ([]silo.DataNode, error)

+ type SnapshotInterateOnce struct

+ func (s SnapshotInterateOnce) Close() error

+ func (s SnapshotInterateOnce) Next() (silo.DataNode, bool, error)

+ func (s SnapshotInterateOnce) PullAll(node silo.DataNode) ([]silo.DataNode, error)

Mar 27, 2024

Changes in this version

+ type DumpObserver struct

+ func NewDumpObserver() *DumpObserver

+ func (o *DumpObserver) Close()

+ func (o *DumpObserver) Entity(status silo.Status, _ map[string]int)

Mar 25, 2024

Changes in this version

+ var ErrPathIsNotValid = errors.New("path is not valid")

+ type Backend struct

+ func NewBackend(path string) (Backend, error)

+ func (b Backend) Close() error

+ func (b Backend) Get(node silo.DataNode) ([]silo.DataNode, error)

+ func (b Backend) Snapshot() silo.Snapshot

+ func (b Backend) Store(key silo.DataNode, value silo.DataNode) error

+ type BackendLogger struct

+ func (l BackendLogger) Fatalf(format string, args ...interface{})

+ func (l BackendLogger) Infof(format string, args ...interface{})

+ type DataRowReaderJSONLine struct

+ func NewDataRowReaderJSONLine() (*DataRowReaderJSONLine, error)

+ func NewDataRowReaderJSONLineFromFile(filename string) (*DataRowReaderJSONLine, error)

+ func (drr *DataRowReaderJSONLine) Close() error

+ func (drr *DataRowReaderJSONLine) ReadDataRow() (silo.DataRow, error)

+ type DataRowReaderWriterJSONLine struct

+ func NewDataRowReaderWriterJSONLine(input io.Reader, output io.Writer) *DataRowReaderWriterJSONLine

+ func (drr *DataRowReaderWriterJSONLine) Close() error

+ func (drr *DataRowReaderWriterJSONLine) ReadDataRow() (silo.DataRow, error)

+ type DumpJSONLine struct

+ func NewDumpJSONLine() *DumpJSONLine

+ func (d *DumpJSONLine) Close() error

+ func (d *DumpJSONLine) Write(node silo.DataNode, uuid string) error

+ type ScanObserver struct

+ func NewScanObserver() *ScanObserver

+ func (o *ScanObserver) Close()

+ func (o *ScanObserver) IngestedLink(_ silo.DataLink)

+ func (o *ScanObserver) IngestedRow(_ silo.DataRow)

+ type Snapshot struct

+ func (s Snapshot) Close() error

+ func (s Snapshot) Next() (silo.DataNode, bool, error)

+ func (s Snapshot) PullAll(node silo.DataNode) ([]silo.DataNode, error)