CernVM-FS  2.10.0
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Pages
IngestionPipeline Member List

This is the complete list of members for IngestionPipeline, including all inherited members.

average_chunk_size_IngestionPipelineprivate
CallbackPtr typedefObservable< upload::SpoolerResult >
Callbacks typedefObservable< upload::SpoolerResult >protected
CallbackTN typedefCallbackable< upload::SpoolerResult >
chunking_enabled_IngestionPipelineprivate
compression_algorithm_IngestionPipelineprivate
generate_legacy_bulk_chunks_IngestionPipelineprivate
hash_algorithm_IngestionPipelineprivate
IngestionPipeline(upload::AbstractUploader *uploader, const upload::SpoolerDefinition &spooler_definition)IngestionPipelineexplicit
item_allocator_IngestionPipelineprivate
kMaxFilesInFlightIngestionPipelineprivatestatic
kMaxPipelineMemIngestionPipelineprivatestatic
kNforkChunkIngestionPipelineprivatestatic
kNforkCompressIngestionPipelineprivatestatic
kNforkHashIngestionPipelineprivatestatic
kNforkReadIngestionPipelineprivatestatic
kNforkRegisterIngestionPipelineprivatestatic
kNforkWriteIngestionPipelineprivatestatic
MakeCallback(typename BoundCallback< upload::SpoolerResult, DelegateT >::CallbackMethod method, DelegateT *delegate)Callbackable< upload::SpoolerResult >inlinestatic
MakeCallback(typename Callback< upload::SpoolerResult >::CallbackFunction function)Callbackable< upload::SpoolerResult >inlinestatic
MakeClosure(typename BoundClosure< upload::SpoolerResult, DelegateT, ClosureDataT >::CallbackMethod method, DelegateT *delegate, const ClosureDataT &closure_data)Callbackable< upload::SpoolerResult >inlinestatic
maximal_chunk_size_IngestionPipelineprivate
minimal_chunk_size_IngestionPipelineprivate
NotifyListeners(const upload::SpoolerResult &parameter)Observable< upload::SpoolerResult >protected
Observable()Observable< upload::SpoolerResult >protected
OnFileProcessed(const upload::SpoolerResult &spooler_result)IngestionPipeline
Process(IngestionSource *source, bool allow_chunking, shash::Suffix hash_suffix=shash::kSuffixNone)IngestionPipeline
RegisterListener(typename BoundClosure< upload::SpoolerResult, DelegateT, ClosureDataT >::CallbackMethod method, DelegateT *delegate, ClosureDataT data)Observable< upload::SpoolerResult >
RegisterListener(typename BoundCallback< upload::SpoolerResult, DelegateT >::CallbackMethod method, DelegateT *delegate)Observable< upload::SpoolerResult >
RegisterListener(typename Callback< upload::SpoolerResult >::CallbackFunction fn)Observable< upload::SpoolerResult >
RegisterListener(CallbackPtr callback_object)Observable< upload::SpoolerResult >protected
Spawn()IngestionPipeline
spawned_IngestionPipelineprivate
tasks_chunk_IngestionPipelineprivate
tasks_compress_IngestionPipelineprivate
tasks_hash_IngestionPipelineprivate
tasks_read_IngestionPipelineprivate
tasks_register_IngestionPipelineprivate
tasks_write_IngestionPipelineprivate
tube_counter_IngestionPipelineprivate
tube_input_IngestionPipelineprivate
tubes_chunk_IngestionPipelineprivate
tubes_compress_IngestionPipelineprivate
tubes_hash_IngestionPipelineprivate
tubes_register_IngestionPipelineprivate
tubes_write_IngestionPipelineprivate
UnregisterListener(CallbackPtr callback_object)Observable< upload::SpoolerResult >
UnregisterListeners()Observable< upload::SpoolerResult >
uploader_IngestionPipelineprivate
WaitFor()IngestionPipeline
~IngestionPipeline()IngestionPipeline
~Observable()Observable< upload::SpoolerResult >virtual