Everett
Loading...
Searching...
No Matches
Public Types | Public Member Functions | Private Types | Static Private Member Functions | Private Attributes | List of all members
everett::index_pipeline< P > Struct Template Reference

#include <index_pipeline.h>

Inheritance diagram for everett::index_pipeline< P >:
everett::index_detail::pipeline_driver< P, profile_blob< P >, index_builder< P > >

Public Types

using policy_type = P
 
using blob_type = profile_blob< P >
 
using pair_type = std::shared_ptr< blob_type const >
 
- Public Types inherited from everett::index_detail::pipeline_driver< P, profile_blob< P >, index_builder< P > >
using policy_type = P
 
using blob_type = profile_blob< P >
 
using pair_type = std::shared_ptr< blob_type const >
 

Public Member Functions

 index_pipeline (pair_type target, std::vector< pair_type > native_stages)
 
pair_type finish ()
 
- Public Member Functions inherited from everett::index_detail::pipeline_driver< P, profile_blob< P >, index_builder< P > >
 pipeline_driver (pair_type target, std::vector< std::unique_ptr< index_builder< P > > > stages)
 
 pipeline_driver (pipeline_driver const &)=delete
 
 pipeline_driver (pipeline_driver &&)=default
 
pipeline_driver & operator= (pipeline_driver const &)=delete
 
pipeline_driver & operator= (pipeline_driver &&)=default
 
bool done () const noexcept
 
bool finished () const noexcept
 
bool failed () const noexcept
 
std::size_t size () const noexcept
 
std::uint64_t step (std::uint64_t quanta)
 
std::span< std::uint64_t const > emitted_samples () const &noexcept
 
std::span< std::uint64_t const > emitted_samples () const &&=delete
 
std::span< std::uint64_t const > consumed_entries () const &noexcept
 
std::span< std::uint64_t const > consumed_entries () const &&=delete
 
std::span< std::uint64_t const > emitted_suffix_units () const &noexcept
 
std::span< std::uint64_t const > emitted_suffix_units () const &&=delete
 
std::uint64_t source_suffix_units () const noexcept
 
sampling_work const & source_work () const &noexcept
 
sampling_work const & source_work () const &&=delete
 

Private Types

using base = index_detail::pipeline_driver< P, blob_type, index_builder< P > >
 

Static Private Member Functions

static std::vector< std::unique_ptr< index_builder< P > > > make_stages (std::span< pair_type const > sources)
 

Private Attributes

std::vector< pair_type > results_
 

Additional Inherited Members

- Protected Attributes inherited from everett::index_detail::pipeline_driver< P, profile_blob< P >, index_builder< P > >
pair_type target_
 
sample_cursor< P, profile_blob< P > > source_
 
profile_sample_encoder< P > source_encoder_
 
std::vector< std::unique_ptr< index_builder< P > > > stages_
 
std::vector< std::uint64_t > emitted_
 
std::vector< std::uint64_t > consumed_
 
std::vector< std::uint64_t > emitted_suffix_units_
 
std::uint64_t source_suffix_units_
 
bool finished_
 
bool failed_
 

Member Typedef Documentation

◆ base

template<class P >
using everett::index_pipeline< P >::base = index_detail::pipeline_driver<P, blob_type, index_builder<P> >
private

◆ blob_type

template<class P >
using everett::index_pipeline< P >::blob_type = profile_blob<P>

◆ pair_type

template<class P >
using everett::index_pipeline< P >::pair_type = std::shared_ptr<blob_type const>

◆ policy_type

template<class P >
using everett::index_pipeline< P >::policy_type = P

Constructor & Destructor Documentation

◆ index_pipeline()

template<class P >
everett::index_pipeline< P >::index_pipeline ( pair_type  target,
std::vector< pair_type >  native_stages 
)
inline

Member Function Documentation

◆ finish()

template<class P >
pair_type everett::index_pipeline< P >::finish ( )
inline

◆ make_stages()

template<class P >
static std::vector< std::unique_ptr< index_builder< P > > > everett::index_pipeline< P >::make_stages ( std::span< pair_type const >  sources)
inlinestaticprivate

Member Data Documentation

◆ results_

template<class P >
std::vector<pair_type> everett::index_pipeline< P >::results_
private

The documentation for this struct was generated from the following file: