search

type BleveQuery struct {
	Raw string

	FieldTransformer sqe.FieldTransformer

	FieldNames []string
	Validator  BleveQueryValidator
	// contains filtered or unexported fields
}

type BleveQueryFactory func(rawQuery string) *BleveQuery

type BleveQueryValidator interface {
	Validate(q *BleveQuery) error
}

type BlockMapper interface {
	Map(block *bstream.Block) ([]*document.Document, error)
	Validate() error
}

type BoundaryBlockInfo struct {
	Num  uint64
	ID   string
	Time time.Time
}

type GetSearchPeersFunc func() []*dmesh.SearchPeer

type IndexedField struct {
	Name      string    `json:"name"`
	ValueType ValueType `json:"type"`
}

type IndexedFieldsMapFunc func() map[string]*IndexedField

type MatchCollector func(ctx context.Context, lowBlockNum, highBlockNum uint64, results bsearch.DocumentMatchCollection) ([]SearchMatch, error)

type MultiError []error

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

type QueryMetrics struct {

	// The number of transactions we have seen from our shard results
	TransactionSeenCount int64

	// The number of actual walked indexes, regardless if it was actually used to return results or not (cancel index)
	SearchedIndexesCount *atomic.Uint32

	// The number of actual usueful searched indexes, those that were used to return results
	UtilizedIndexesCount *atomic.Uint32

	// The total transaction count utilized through utilized indexes
	UtilizedTrxCount *atomic.Uint32

	// The total time passed cumulatively in each utilized indexes
	UtilizedTotalDuration *atomic.Duration
	// contains filtered or unexported fields
}

type SearchMatch interface {
	BlockNum() uint64
	TransactionIDPrefix() string

	GetIndex() uint64
	SetIndex(index uint64)

	FillProtoSpecific(match *pbsearch.SearchMatch, blk *bstream.Block) error
}

type ShardIndex struct {
	index.Index

	IndexBuilder    index.IndexBuilder
	IndexTargetPath string

	// These two values represent the "potential" start and end
	// block. It doesn't mean there is actual data within those two
	// blocks: ex: if block endBlock had 0 transactions, we wouldn't
	// shrink `endBlock`.
	//
	// The chain of [startBlock, endBlock] -> [startBlock, endBlock]
	// *must* be absolutely continuous from index to index within the
	// process, and between the different segments of indexes
	// (readOnly, merging, writable, and live)
	StartBlock     uint64 // inclusive
	StartBlockID   string
	StartBlockTime time.Time
	EndBlock       uint64 // inclusive
	EndBlockID     string
	EndBlockTime   time.Time

	Lock sync.RWMutex
	// contains filtered or unexported fields
}

type SingleIndex struct {
	index.Index
	// contains filtered or unexported fields
}

type ValueType int32