Everett
Loading...
Searching...
No Matches
Public Types | Public Member Functions | Protected Attributes | Private Member Functions | List of all members
everett::index_detail::pipeline_driver< P, Target, Stage > Struct Template Reference

#include <index_pipeline_detail.h>

Inheritance diagram for everett::index_detail::pipeline_driver< P, Target, Stage >:
everett::file_index_pipeline< P, Ops >

Public Types

using policy_type = P
 
using blob_type = Target
 
using pair_type = std::shared_ptr< blob_type const >
 

Public Member Functions

 pipeline_driver (pair_type target, std::vector< std::unique_ptr< Stage > > stages)
 
 pipeline_driver (pipeline_driver const &)=delete
 
pipeline_driver & operator= (pipeline_driver const &)=delete
 
 pipeline_driver (pipeline_driver &&)=default
 
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
 

Protected Attributes

pair_type target_
 
sample_cursor< P, Target > source_
 
profile_sample_encoder< P > source_encoder_
 
std::vector< std::unique_ptr< Stage > > 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_ = 0
 
bool finished_ = false
 
bool failed_ = false
 

Private Member Functions

bool advance_one ()
 

Member Typedef Documentation

◆ blob_type

template<class P , class Target , class Stage >
using everett::index_detail::pipeline_driver< P, Target, Stage >::blob_type = Target

◆ pair_type

template<class P , class Target , class Stage >
using everett::index_detail::pipeline_driver< P, Target, Stage >::pair_type = std::shared_ptr<blob_type const>

◆ policy_type

template<class P , class Target , class Stage >
using everett::index_detail::pipeline_driver< P, Target, Stage >::policy_type = P

Constructor & Destructor Documentation

◆ pipeline_driver() [1/3]

template<class P , class Target , class Stage >
everett::index_detail::pipeline_driver< P, Target, Stage >::pipeline_driver ( pair_type  target,
std::vector< std::unique_ptr< Stage > >  stages 
)
inline

◆ pipeline_driver() [2/3]

template<class P , class Target , class Stage >
everett::index_detail::pipeline_driver< P, Target, Stage >::pipeline_driver ( pipeline_driver< P, Target, Stage > const &  )
delete

◆ pipeline_driver() [3/3]

template<class P , class Target , class Stage >
everett::index_detail::pipeline_driver< P, Target, Stage >::pipeline_driver ( pipeline_driver< P, Target, Stage > &&  )
default

Member Function Documentation

◆ advance_one()

template<class P , class Target , class Stage >
bool everett::index_detail::pipeline_driver< P, Target, Stage >::advance_one ( )
inlineprivate

◆ consumed_entries() [1/2]

template<class P , class Target , class Stage >
std::span< std::uint64_t const > everett::index_detail::pipeline_driver< P, Target, Stage >::consumed_entries ( ) const &&
delete

◆ consumed_entries() [2/2]

template<class P , class Target , class Stage >
std::span< std::uint64_t const > everett::index_detail::pipeline_driver< P, Target, Stage >::consumed_entries ( ) const &
inlinenoexcept

◆ done()

template<class P , class Target , class Stage >
bool everett::index_detail::pipeline_driver< P, Target, Stage >::done ( ) const
inlinenoexcept

◆ emitted_samples() [1/2]

template<class P , class Target , class Stage >
std::span< std::uint64_t const > everett::index_detail::pipeline_driver< P, Target, Stage >::emitted_samples ( ) const &&
delete

◆ emitted_samples() [2/2]

template<class P , class Target , class Stage >
std::span< std::uint64_t const > everett::index_detail::pipeline_driver< P, Target, Stage >::emitted_samples ( ) const &
inlinenoexcept

◆ emitted_suffix_units() [1/2]

template<class P , class Target , class Stage >
std::span< std::uint64_t const > everett::index_detail::pipeline_driver< P, Target, Stage >::emitted_suffix_units ( ) const &&
delete

◆ emitted_suffix_units() [2/2]

template<class P , class Target , class Stage >
std::span< std::uint64_t const > everett::index_detail::pipeline_driver< P, Target, Stage >::emitted_suffix_units ( ) const &
inlinenoexcept

◆ failed()

template<class P , class Target , class Stage >
bool everett::index_detail::pipeline_driver< P, Target, Stage >::failed ( ) const
inlinenoexcept

◆ finished()

template<class P , class Target , class Stage >
bool everett::index_detail::pipeline_driver< P, Target, Stage >::finished ( ) const
inlinenoexcept

◆ operator=() [1/2]

template<class P , class Target , class Stage >
pipeline_driver & everett::index_detail::pipeline_driver< P, Target, Stage >::operator= ( pipeline_driver< P, Target, Stage > &&  )
default

◆ operator=() [2/2]

template<class P , class Target , class Stage >
pipeline_driver & everett::index_detail::pipeline_driver< P, Target, Stage >::operator= ( pipeline_driver< P, Target, Stage > const &  )
delete

◆ size()

template<class P , class Target , class Stage >
std::size_t everett::index_detail::pipeline_driver< P, Target, Stage >::size ( ) const
inlinenoexcept

◆ source_suffix_units()

template<class P , class Target , class Stage >
std::uint64_t everett::index_detail::pipeline_driver< P, Target, Stage >::source_suffix_units ( ) const
inlinenoexcept

◆ source_work() [1/2]

template<class P , class Target , class Stage >
sampling_work const & everett::index_detail::pipeline_driver< P, Target, Stage >::source_work ( ) const &&
delete

◆ source_work() [2/2]

template<class P , class Target , class Stage >
sampling_work const & everett::index_detail::pipeline_driver< P, Target, Stage >::source_work ( ) const &
inlinenoexcept

◆ step()

template<class P , class Target , class Stage >
std::uint64_t everett::index_detail::pipeline_driver< P, Target, Stage >::step ( std::uint64_t  quanta)
inline

Member Data Documentation

◆ consumed_

template<class P , class Target , class Stage >
std::vector<std::uint64_t> everett::index_detail::pipeline_driver< P, Target, Stage >::consumed_
protected

◆ emitted_

template<class P , class Target , class Stage >
std::vector<std::uint64_t> everett::index_detail::pipeline_driver< P, Target, Stage >::emitted_
protected

◆ emitted_suffix_units_

template<class P , class Target , class Stage >
std::vector<std::uint64_t> everett::index_detail::pipeline_driver< P, Target, Stage >::emitted_suffix_units_
protected

◆ failed_

template<class P , class Target , class Stage >
bool everett::index_detail::pipeline_driver< P, Target, Stage >::failed_ = false
protected

◆ finished_

template<class P , class Target , class Stage >
bool everett::index_detail::pipeline_driver< P, Target, Stage >::finished_ = false
protected

◆ source_

template<class P , class Target , class Stage >
sample_cursor<P, Target> everett::index_detail::pipeline_driver< P, Target, Stage >::source_
protected

◆ source_encoder_

template<class P , class Target , class Stage >
profile_sample_encoder<P> everett::index_detail::pipeline_driver< P, Target, Stage >::source_encoder_
protected

◆ source_suffix_units_

template<class P , class Target , class Stage >
std::uint64_t everett::index_detail::pipeline_driver< P, Target, Stage >::source_suffix_units_ = 0
protected

◆ stages_

template<class P , class Target , class Stage >
std::vector<std::unique_ptr<Stage> > everett::index_detail::pipeline_driver< P, Target, Stage >::stages_
protected

◆ target_

template<class P , class Target , class Stage >
pair_type everett::index_detail::pipeline_driver< P, Target, Stage >::target_
protected
The documentation for this struct was generated from the following file:
Generated by doxygen 1.9.8