dropbag

type CloseRetainer interface {
	// guarantees that this object will not be closed until the returned Closer.Close() is called
	// multiple retainers are allowed, all of them must be closed to release the object
	// can return nil when retention guarantee is not possible (object is closed already)
	Retain() io.Closer
}

type CompositeDropPerPulseData interface {
	CoveringRange() pulse.Range // latest PulseData + earliest pulse number - will not include intermediate PulseData
	PulseDataCount() int
	GetPerPulseData(index int) DropPerPulseData
	FindPerPulseData(pulse.Number) DropPerPulseData
}

type CompositeDropStorage interface {
	CloseRetainer

	CoveringRange() pulse.Range // latest PulseData + earliest pulse number - will not include intermediate PulseData
	PerPulseData() CompositeDropPerPulseData

	// identified by the latest pulse in a range of the drop
	GetDropStorage(jetId jet.ExactID, pn pulse.Number) DropStorage

	NoticeUsage()
}

type CompositeDropStorageBuilder interface {
	CompositeDropStorageBuilder()
}

type DropEntry interface {
	Key() keyset.Key

	// actual directory this entry is listed in
	DirectorySectionId() DropSectionId
	// a sequential order for all entries being of a drop
	// for regular entry starts from 256 and goes up
	SequenceId() uint32

	// section of entry's content
	ContentSectionId() DropSectionId

	PeekEntry(ObjectExtractor) bool
	GetEntryUnbound(ObjectExtractor) (value interface{}, hasValue bool)
}

type DropJetTree interface {
	MinDepth() uint8
	MaxDepth() uint8
	Count() int
	PrefixToJetId(prefix jet.Prefix) jet.ExactID
	KeyToJetId(keyset.Key) jet.ExactID
}

type DropLifeline interface {
}

type DropPerPulseData interface {
	PulseRange() pulse.Range // complete range, with all pulse data included
	JetTree() DropJetTree

	OnlinePopulation() census.OnlinePopulation
	OfflinePopulation() census.OfflinePopulation
}

type DropSection interface {
	DropSectionId() DropSectionId
	DirectorySectionId() DropSectionId

	LoadEntry(DropEntry, ObjectExtractor) error
	LoadEntries([]DropEntry, ObjectExtractor) error
}

type DropSectionDirectory interface {
	DropSectionId() DropSectionId

	LookupKey(keyset.Key) (DropEntry, bool)
	LookupKeySet(keyset.KeySet) LookupPager
}

type DropSectionId uint8

type DropStorage interface {
	CloseRetainer

	Composite() CompositeDropStorage

	JetId() jet.LegID
	PulseNumber() pulse.Number // the rightmost/latest pulse number of this drop
	PerPulseData() DropPerPulseData

	DropType() DropType

	// a synthetic directory based on a few sections, marked as primary
	MainDirectory() DropSectionDirectory

	FindSection(DropSectionId) DropSection
	FindDirectory(DropSectionId) DropSectionDirectory
}

type DropStorageBuilder interface {
}

type DropStorageManager interface {
	// will actually open CompositeDropStorage that may have multiple DropStorage(s) incorporated
	OpenStorage(jetId jet.ExactID, pn pulse.Number) (DropStorage, error)
	OpenPulseStorage(pn pulse.Number) (CompositeDropPerPulseData, error)

	// each storage is lazy-closed, but can be explicitly marked for closing
	UnusedStorage(CompositeDropStorage)

	// returns nil when the required storage is not open
	GetOpenedStorage(jetId jet.ExactID, pn pulse.Number) DropStorage

	BuildStorage(pr pulse.Range) CompositeDropStorageBuilder
}

type DropType uint8

type EntryCollection interface {
}

type EntryPosition struct {
	StorageLoc StorageLocId
	SequenceId uint32
	StorageOfs int64
}

type EntryStorageAdapter interface {
}

type EntryStorageCabinet interface {
}

type EntryStorageShelf interface {
}

type ExtractorId string

type FieldId uint16

type FieldOffset int

type FieldOffsetMap interface {
	FindField(int FieldId) FieldOffset
}

type JetDrop interface {
	PulseNumber() pulse.Number
	GetGlobulaPulse() JetPulse

	FindEntryByKey(longbits.ByteString) JetDropEntry
	//	GetSectionDirectory(JetSectionId) JetDropSection
	GetSection(JetSectionId) JetDropSection
}

type JetDropEntry interface {
	Key() longbits.ByteString
	Section() JetDropSection
	IsAvailable() bool
	Data() []byte
}

type JetDropSection interface {
	EnumEntries()
}

type JetPulse interface {
	GetOnlinePopulation() census.OnlinePopulation
	GetPulseData() pulse.Range
}

type JetSectionDeclaration interface {
	HasDirectory() bool
	//IsSorted
	HasPayload() bool
}

type JetSectionDirectory interface {
	FindByKey(longbits.ByteString) JetDropEntry
	EnumKeys()
}

type JetSectionId uint16

type JetSectionType uint8

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

type KeySet interface {
}

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

type LookupMiss uint8

type LookupPageFunc func(estTotal, curTotal uint, found []DropEntry, misses [][]keyset.Key, skipped uint) bool

type LookupPager interface {
	RequestedKeySet() keyset.KeySet

	LoadKeys(maxPageSize uint, fn LookupPageFunc) error
	PeekKeys(maxPageSize uint, fn LookupPageFunc)
}

type ObjectExtractor interface {
	// extractors with the same id will share cached values etc
	ExtractorId() ExtractorId

	// Invoked when an entry has no cached value for this extractor id.
	// Extracts required data from the raw bytes and consumes it (process further).
	// The extracted result must be returned for caching.
	// Return:
	// 	(cacheValue) the extracted value
	// 	(boundValue) true when cacheValue depends on (raw), as it can be memory mapped and needs cleanup
	//  (estSize) approximate memory size of the extracted value, for cache eviction procedure.
	Extract(key keyset.Key, raw []byte) (cacheValue interface{}, boundValue bool, estSize uint)

	// Invoked when an entry has cached value for this extractor id.
	Reuse(key keyset.Key, cacheValue interface{}, boundValue bool)

	// Invoked by GetUnboundObject() when a cached value is bound.
	// This function must return an unbound copy of the (cacheValue).
	Unbind(cacheValue interface{}) interface{}
}

type StorageFile interface {
}

type StorageFileFolder interface {
}

type StorageFileReader interface {
}

type StorageFormatAdapter interface {
}

type StorageLocId uint32

type StorageReadAdapter interface {
	GetURI() StorageURI

	OpenForSeqRead() dbcommon.StorageSeqReader
	OpenForBlockRead() dbcommon.StorageBlockReader
}

type StorageURI string

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