Versions in this module Expand all Collapse all v0 v0.0.1 Jun 22, 2020 Changes in this version + func GetMeshLIB(getAllPeers GetSearchPeersFunc, backendThreshold int) bstream.BlockRef + type GetSearchPeersFunc func() []*dmesh.SearchPeer + type IndexedBlock struct + Blk *bstream.Block + Idx *search.SingleIndex + type LiveBackend struct + func New(dmeshClient dmeshClient.SearchClient, searchPeer *dmesh.SearchPeer, ...) *LiveBackend + func (b *LiveBackend) Check(ctx context.Context, in *pbhealth.HealthCheckRequest) (*pbhealth.HealthCheckResponse, error) + func (b *LiveBackend) GetHeadInfo(ctx context.Context, r *pbhead.HeadInfoRequest) (*pbhead.HeadInfoResponse, error) + func (b *LiveBackend) Launch(grpcListenAddr string) + func (b *LiveBackend) SetupSubscriptionHub(startBlock bstream.BlockRef, blockMapper search.BlockMapper, ...) error + func (b *LiveBackend) StreamHeadInfo(r *pbhead.HeadInfoRequest, ...) error + func (b *LiveBackend) StreamMatches(req *pb.BackendRequest, stream pb.Backend_StreamMatchesServer) error + func (b *LiveBackend) WaitHubReady() + type LiveQuery struct + BleveQuery *search.BleveQuery + Ctx context.Context + IncomingMatches chan *pb.SearchMatch + LastBlockRead uint64 + LiveMarkerLastSentBlockNum uint64 + LiveMarkerReached bool + MatchCollector search.MatchCollector + Request *pb.BackendRequest + func (q *LiveQuery) ForwardProcessBlock(blk *bstream.Block, obj interface{}) error + func (q *LiveQuery) ProcessMatches(matches []search.SearchMatch, blk *bstream.Block, irrBlockNum uint64, ...) error + func (q *LiveQuery) ProcessSingleBlocks(ctx context.Context, indexedBlock *IndexedBlock, ...) (err error) + type TailManager struct + func NewTailManager(getSearchPeers GetSearchPeersFunc, dmeshClient dmeshClient.Client, ...) *TailManager + func (t *TailManager) CurrentLIB() bstream.BlockRef + func (t *TailManager) Launch() + func (t *TailManager) Ready() bool + func (t *TailManager) TailLock(startBlockNum uint64) (releaseFunc func(), err error)
Go to main page