Versions in this module Expand all Collapse all v0 v0.0.1 Jun 22, 2020 Changes in this version + var LivenessQuery *search.BleveQuery + func NewQueryThreadsOptimizer(maxThreads int, sortDesc bool, lowBlockNum uint64, ...) *queryThreadsOptimizer + func TestNewClient(t *testing.T, searchEngine *ArchiveBackend) (pb.BackendClient, func()) + type ArchiveBackend struct + MaxQueryThreads int + Pool *IndexPool + SearchPeer *dmesh.SearchPeer + func NewBackend(pool *IndexPool, dmeshClient dmeshClient.Client, searchPeer *dmesh.SearchPeer, ...) *ArchiveBackend + func (b *ArchiveBackend) Check(ctx context.Context, in *pbhealth.HealthCheckRequest) (*pbhealth.HealthCheckResponse, error) + func (b *ArchiveBackend) GetHeadInfo(ctx context.Context, r *pbhead.HeadInfoRequest) (*pbhead.HeadInfoResponse, error) + func (b *ArchiveBackend) Launch() + func (b *ArchiveBackend) SetMaxQueryThreads(threads int) + func (b *ArchiveBackend) StreamHeadInfo(r *pbhead.HeadInfoRequest, ...) error + func (b *ArchiveBackend) StreamMatches(req *pbsearch.BackendRequest, stream pbsearch.Backend_StreamMatchesServer) error + func (b *ArchiveBackend) WarmUpArchive(ctx context.Context, low, high uint64, bquery *search.BleveQuery) error + func (b *ArchiveBackend) WarmupWithQuery(query string, low, high uint64) error + type IndexPool struct + IndexesPath string + LowestServeableBlockNum uint64 + PerQueryThreads int + ReadOnlyIndexesPaths []string + ReadPool []*search.ShardIndex + SearchPeer *dmesh.SearchPeer + ShardSize uint64 + func NewIndexPool(indexesPath string, readOnlyIndexesPaths []string, shardSize uint64, ...) (*IndexPool, error) + func (p *IndexPool) AppendReadIndexes(idx ...*search.ShardIndex) + func (p *IndexPool) CleanOnDiskIndexes(startBlock, stopBlock uint64) error + func (p *IndexPool) CloseIndexes() (err error) + func (p *IndexPool) GetIndexIterator(lowBlockNum, highBlockNum uint64, sortDesc bool) (*indexIterator, error) + func (p *IndexPool) GetLowestServeableBlockNum() uint64 + func (p *IndexPool) IsReady() bool + func (p *IndexPool) LastReadOnlyIndexedBlock() uint64 + func (p *IndexPool) LastReadOnlyIndexedBlockID() string + func (p *IndexPool) LowestServeableBlockNumAbove(blockNum uint64) uint64 + func (p *IndexPool) PollRemoteIndices(startBlockNum, stopBlockNum uint64) + func (p *IndexPool) ScanOnDiskIndexes(startBlock uint64) error + func (p *IndexPool) SetLowestServeableBlockNum(startBlockNum uint64) error + func (p *IndexPool) SetReady() error + func (p *IndexPool) SyncFromStorage(startBlock, stopBlock uint64, maxIndexes int, parallelDownloads int) error + func (p *IndexPool) Upload(baseIndex uint64, indexPath string) (err error) + type Truncator struct + func NewTruncator(indexPool *IndexPool, blockCount uint64) *Truncator + func (t *Truncator) Launch()