Method List
-
#active_job Ductr::Configuration
-
#adapter Ductr::Job
-
#adapter Ductr::Trigger
-
#adapter Ductr::Configuration
-
#adapter Ductr::ETL::Control
-
adapter_registry Ductr
-
#adapters Ductr::Configuration
-
#adapters Ductr::ETL::Parser
-
#add Ductr::RufusTrigger
-
#add Ductr::Trigger
-
#add Ductr::Registry
-
add_output Ductr::Log::Logger
-
after Ductr::Pipeline
-
#alive? Ductr::PipelineStep
-
all Ductr::Store
-
all_done? Ductr::Store
-
#all_jobs Ductr::Store::JobStore
-
#all_pipelines Ductr::Store::PipelineStore
-
#apply_active_job_config Ductr::Configuration
-
#async Ductr::Pipeline
-
#buffer Ductr::ETL::BufferedTransform
-
#buffer Ductr::ETL::BufferedDestination
-
#buffer_size Ductr::ETL::BufferedTransform
-
#buffer_size Ductr::ETL::BufferedDestination
-
#call Ductr::SequelBase::PollingHandler
-
#call Ductr::Log::ColorFormatter
-
#call_method Ductr::ETL::Control
-
#close Ductr::ETL::BufferedDestination
-
#close Ductr::ETL::Destination
-
#close Ductr::ETL::BufferedTransform
-
#close Ductr::ETL::Transform
-
#close! Ductr::Adapter
-
config Ductr
-
#config Ductr::Adapter
-
configure Ductr
-
#control Ductr::ETL::FiberControl
-
#current_step Ductr::PipelineRunner
-
#db Ductr::SequelBase::Adapter
-
#debug Ductr::Log::Logger
-
destination Ductr::ETLJob
-
destination Ductr::KibaJob
-
destination_registry Ductr::Adapter
-
#destinations Ductr::ETL::Runner
-
development? Ductr
-
#done Ductr::Store::PipelineSerializer::SerializedPipelineStep
-
#done? Ductr::PipelineStep
-
#done? Ductr::Store::PipelineSerializer::SerializedPipelineStep
-
#each Ductr::ETL::PaginatedSource
-
#each Ductr::SequelBase::BasicSource
-
#each Ductr::ETL::Source
-
#each_page Ductr::ETL::PaginatedSource
-
#each_page Ductr::SequelBase::PaginatedSource
-
#enqueue_job Ductr::PipelineStep
-
env Ductr
-
#error Ductr::Store::JobSerializer::SerializedJob
-
#error Ductr::Job
-
#error Ductr::Store::PipelineSerializer::SerializedPipeline
-
#error Ductr::Log::Logger
-
#fatal Ductr::Log::Logger
-
#fiber Ductr::ETL::FiberControl
-
#fiber Ductr::PipelineStep
-
#find Ductr::Registry
-
#flush_buffer Ductr::ETL::BufferedTransform
-
#flush_buffer Ductr::ETL::BufferedDestination
-
#flush_jobs Ductr::PipelineStep
-
#from_key Ductr::SequelBase::MatchLookup
-
#gen_bin Ductr::CLI::NewProjectGenerator
-
#gen_config Ductr::CLI::NewProjectGenerator
-
#gen_root Ductr::CLI::NewProjectGenerator
-
included Ductr::JobStatus
-
#info Ductr::Log::Logger
-
#init Ductr::CLI::NewProjectGenerator
-
#initialize Ductr::Scheduler
-
#initialize Ductr::Store::PipelineSerializer::SerializedPipelineStep
-
#initialize Ductr::PipelineRunner
-
#initialize Ductr::Registry
-
#initialize Ductr::Store::PipelineSerializer::SerializedPipeline
-
#initialize Ductr::ETL::Control
-
#initialize Ductr::Pipeline
-
#initialize Ductr::PipelineStep
-
#initialize Ductr::Trigger
-
#initialize Ductr::Log::FileOutput
-
#initialize Ductr::Adapter
-
#initialize Ductr::Log::StandardOutput
-
#initialize Ductr::Store::JobSerializer::SerializedJob
-
#initialize Ductr::ETL::FiberControl
-
#initialize Ductr::Log::Logger
-
#initialize Ductr::SequelBase::PollingHandler
-
#initialize Ductr::ETL::Runner
-
#initialize Ductr::JobETLRunner
-
#initialize Ductr::Configuration
-
#job_id Ductr::Store::JobSerializer::SerializedJob
-
#job_id Ductr::Store::PipelineSerializer::SerializedPipeline
-
#job_method Ductr::ETL::Control
-
#jobs Ductr::Store::PipelineSerializer::SerializedPipelineStep
-
#jobs Ductr::PipelineStep
-
#left Ductr::PipelineStep
-
level Ductr::Log::Logger
-
level= Ductr::Log::Logger
-
#logger Ductr::Job
-
logger Ductr
-
#logging Ductr::Configuration
-
lookup Ductr::KibaJob
-
lookup Ductr::ETLJob
-
lookup_registry Ductr::Adapter
-
#name Ductr::Adapter
-
#name Ductr::PipelineStep
-
#new Ductr::CLI::Default
-
#on_flush Ductr::ETL::BufferedTransform
-
#on_flush Ductr::SequelBase::BufferedDestination
-
#on_flush Ductr::SequelBase::MatchLookup
-
#on_flush Ductr::SequelBase::BufferedLookup
-
#on_flush Ductr::ETL::BufferedDestination
-
#on_flush Ductr::SequelBase::BufferedUpsertDestination
-
#open Ductr::Adapter
-
#open! Ductr::Adapter
-
#options Ductr::ETL::Control
-
outputs Ductr::Log::Logger
-
#page_size Ductr::ETL::PaginatedSource
-
#parse_annotations Ductr::ETL::Parser
-
#perform Ductr::Job
-
#perform Ductr::CLI::Main
-
#pipeline Ductr::PipelineStep
-
#pipes Ductr::ETL::Runner
-
#process Ductr::SequelBase::BasicLookup
-
#process Ductr::ETL::BufferedTransform
-
#process Ductr::ETL::Transform
-
production? Ductr
-
read Ductr::Store
-
#read_jobs Ductr::Store::JobStore
-
register Ductr::Store
-
#register_job Ductr::Store::JobStore
-
#register_pipeline Ductr::Store::PipelineStore
-
#remaining_steps Ductr::PipelineRunner
-
#resume Ductr::PipelineStep
-
#resume Ductr::ETL::FiberControl
-
#right Ductr::ETL::FiberControl
-
#root Ductr::Configuration
-
#run Ductr::Pipeline
-
#run Ductr::JobETLRunner
-
#run Ductr::Job
-
#run Ductr::ETL::FiberRunner
-
#run Ductr::PipelineRunner
-
#run Ductr::ETL::KibaRunner
-
#runner Ductr::Pipeline
-
#schedule Ductr::CLI::Main
-
send_to Ductr::ETLJob
-
#serialize_job Ductr::Store::JobSerializer
-
#serialize_pipeline Ductr::Store::PipelineSerializer
-
source Ductr::KibaJob
-
source Ductr::ETLJob
-
source_registry Ductr::Adapter
-
source_root Ductr::CLI::NewProjectGenerator
-
#sources Ductr::ETL::Runner
-
start Ductr::Scheduler
-
#start Ductr::Trigger
-
#status Ductr::Job
-
#status Ductr::Store::JobSerializer::SerializedJob
-
#status Ductr::Store::PipelineSerializer::SerializedPipeline
-
#status= Ductr::JobStatus
-
#status= Ductr::Pipeline
-
#step_by Ductr::PipelineRunner
-
#step_names Ductr::PipelineRunner
-
#steps Ductr::Store::PipelineSerializer::SerializedPipeline
-
#steps Ductr::PipelineRunner
-
#stop Ductr::RufusTrigger
-
stop Ductr::Scheduler
-
#stop Ductr::SequelBase::PollingTrigger
-
#stop Ductr::Trigger
-
#stopped? Ductr::JobStatus
-
#stopped? Ductr::Store::JobSerializer::SerializedJob
-
#stopped? Ductr::Store::PipelineSerializer::SerializedPipeline
-
#store Ductr::Configuration
-
store Ductr
-
#store_adapter Ductr::Configuration
-
#store_options Ductr::Configuration
-
#store_parameters Ductr::Configuration
-
#sync Ductr::Pipeline
-
#to_key Ductr::SequelBase::MatchLookup
-
transform Ductr::KibaJob
-
transform Ductr::ETLJob
-
#transforms Ductr::ETL::Runner
-
trigger Ductr::Scheduler
-
trigger_registry Ductr::Adapter
-
trigger_registry Ductr
-
triggers Ductr::Scheduler
-
type Ductr::ETL::Control
-
#values Ductr::Registry
-
#warn Ductr::Log::Logger
-
#write Ductr::Log::StandardOutput
-
#write Ductr::ETL::Destination
-
write Ductr::Store
-
#write Ductr::ETL::BufferedDestination
-
#write Ductr::SequelBase::BasicDestination
-
#write_job Ductr::Store::JobStore
-
#write_pipeline Ductr::Store::PipelineStore
-
#yml Ductr::Configuration