Table of Contents - concord-ruby-0.3.6 Documentation
Classes and Modules
- Concord
- Concord::Computation
- Concord::ComputationContext
- Concord::Metadata
- Concord::Thrift
- Concord::Thrift::BackPressure
- Concord::Thrift::BoltComputationRequest
- Concord::Thrift::BoltError
- Concord::Thrift::BoltManagerService
- Concord::Thrift::BoltManagerService::Client
- Concord::Thrift::BoltManagerService::Processor
- Concord::Thrift::BoltManagerService::SetEnvironmentVar_args
- Concord::Thrift::BoltManagerService::SetEnvironmentVar_result
- Concord::Thrift::BoltManagerService::Signal_args
- Concord::Thrift::BoltManagerService::Signal_result
- Concord::Thrift::BoltMetricsService
- Concord::Thrift::BoltMetricsService::Client
- Concord::Thrift::BoltMetricsService::Gauge_args
- Concord::Thrift::BoltMetricsService::Gauge_result
- Concord::Thrift::BoltMetricsService::Histogram_args
- Concord::Thrift::BoltMetricsService::Histogram_result
- Concord::Thrift::BoltMetricsService::Processor
- Concord::Thrift::BoltMetricsService::Sum_args
- Concord::Thrift::BoltMetricsService::Sum_result
- Concord::Thrift::BoltMetricsService::Timer_args
- Concord::Thrift::BoltMetricsService::Timer_result
- Concord::Thrift::BoltPipeService
- Concord::Thrift::BoltPipeService::Client
- Concord::Thrift::BoltPipeService::DispatchRecords_args
- Concord::Thrift::BoltPipeService::DispatchRecords_result
- Concord::Thrift::BoltPipeService::Processor
- Concord::Thrift::BoltProxyService
- Concord::Thrift::BoltProxyService::Client
- Concord::Thrift::BoltProxyService::Processor
- Concord::Thrift::BoltProxyService::RegisterWithScheduler_args
- Concord::Thrift::BoltProxyService::RegisterWithScheduler_result
- Concord::Thrift::BoltProxyService::UpdateSchedulerAddress_args
- Concord::Thrift::BoltProxyService::UpdateSchedulerAddress_result
- Concord::Thrift::BoltProxyService::UpdateTopology_args
- Concord::Thrift::BoltProxyService::UpdateTopology_result
- Concord::Thrift::BoltSchedulerService
- Concord::Thrift::BoltSchedulerService::Client
- Concord::Thrift::BoltSchedulerService::DeployComputation_args
- Concord::Thrift::BoltSchedulerService::DeployComputation_result
- Concord::Thrift::BoltSchedulerService::GetComputationSlug_args
- Concord::Thrift::BoltSchedulerService::GetComputationSlug_result
- Concord::Thrift::BoltSchedulerService::KillTask_args
- Concord::Thrift::BoltSchedulerService::KillTask_result
- Concord::Thrift::BoltSchedulerService::Processor
- Concord::Thrift::BoltSchedulerService::RegisterComputation_args
- Concord::Thrift::BoltSchedulerService::RegisterComputation_result
- Concord::Thrift::BoltSchedulerService::ScaleComputation_args
- Concord::Thrift::BoltSchedulerService::ScaleComputation_result
- Concord::Thrift::ComputationMetadata
- Concord::Thrift::ComputationService
- Concord::Thrift::ComputationService::BoltMetadata_args
- Concord::Thrift::ComputationService::BoltMetadata_result
- Concord::Thrift::ComputationService::BoltProcessRecords_args
- Concord::Thrift::ComputationService::BoltProcessRecords_result
- Concord::Thrift::ComputationService::BoltProcessTimer_args
- Concord::Thrift::ComputationService::BoltProcessTimer_result
- Concord::Thrift::ComputationService::Client
- Concord::Thrift::ComputationService::Destroy_args
- Concord::Thrift::ComputationService::Destroy_result
- Concord::Thrift::ComputationService::Init_args
- Concord::Thrift::ComputationService::Init_result
- Concord::Thrift::ComputationService::Processor
- Concord::Thrift::ComputationTx
- Concord::Thrift::Endpoint
- Concord::Thrift::ExecutorTaskInfoHelper
- Concord::Thrift::MutableEphemeralStateService
- Concord::Thrift::MutableEphemeralStateService::Client
- Concord::Thrift::MutableEphemeralStateService::GetState_args
- Concord::Thrift::MutableEphemeralStateService::GetState_result
- Concord::Thrift::MutableEphemeralStateService::Processor
- Concord::Thrift::MutableEphemeralStateService::SetState_args
- Concord::Thrift::MutableEphemeralStateService::SetState_result
- Concord::Thrift::PhysicalComputationLayout
- Concord::Thrift::PhysicalComputationMetadata
- Concord::Thrift::Record
- Concord::Thrift::RecordFlags
- Concord::Thrift::RecordMetadata
- Concord::Thrift::RichStream
- Concord::Thrift::SchedulerMetadata
- Concord::Thrift::Signal
- Concord::Thrift::StreamGrouping
- Concord::Thrift::StreamMetadata
- Concord::Thrift::TopologyMetadata
- Concord::Utils
Methods
- ::new — Concord::Metadata
- ::new — Concord::ComputationContext
- ::new — Concord::Computation
- ::serve — Concord::Computation
- #boltMetadata — Concord::Computation
- #boltMetadata — Concord::Thrift::ComputationService::Client
- #boltProcessRecords — Concord::Computation
- #boltProcessRecords — Concord::Thrift::ComputationService::Client
- #boltProcessTimer — Concord::Computation
- #boltProcessTimer — Concord::Thrift::ComputationService::Client
- #deployComputation — Concord::Thrift::BoltSchedulerService::Client
- #destroy — Concord::Computation
- #destroy — Concord::Thrift::ComputationService::Client
- #dispatchRecords — Concord::Thrift::BoltPipeService::Client
- #enrich_metadata — Concord::Computation
- #enrich_stream — Concord::Computation
- #gauge — Concord::Thrift::BoltMetricsService::Client
- #getComputationSlug — Concord::Thrift::BoltSchedulerService::Client
- #getState — Concord::Thrift::MutableEphemeralStateService::Client
- #get_state — Concord::ComputationContext
- #get_state — Concord::Computation
- #histogram — Concord::Thrift::BoltMetricsService::Client
- #init — Concord::Computation
- #init — Concord::Thrift::ComputationService::Client
- #killTask — Concord::Thrift::BoltSchedulerService::Client
- #log — Concord::Computation
- #log_failure — Concord::Computation
- #log_to_stderr — Concord::Utils
- #process_boltMetadata — Concord::Thrift::ComputationService::Processor
- #process_boltProcessRecords — Concord::Thrift::ComputationService::Processor
- #process_boltProcessTimer — Concord::Thrift::ComputationService::Processor
- #process_deployComputation — Concord::Thrift::BoltSchedulerService::Processor
- #process_destroy — Concord::Thrift::ComputationService::Processor
- #process_dispatchRecords — Concord::Thrift::BoltPipeService::Processor
- #process_gauge — Concord::Thrift::BoltMetricsService::Processor
- #process_getComputationSlug — Concord::Thrift::BoltSchedulerService::Processor
- #process_getState — Concord::Thrift::MutableEphemeralStateService::Processor
- #process_histogram — Concord::Thrift::BoltMetricsService::Processor
- #process_init — Concord::Thrift::ComputationService::Processor
- #process_killTask — Concord::Thrift::BoltSchedulerService::Processor
- #process_registerComputation — Concord::Thrift::BoltSchedulerService::Processor
- #process_registerWithScheduler — Concord::Thrift::BoltProxyService::Processor
- #process_scaleComputation — Concord::Thrift::BoltSchedulerService::Processor
- #process_setEnvironmentVar — Concord::Thrift::BoltManagerService::Processor
- #process_setState — Concord::Thrift::MutableEphemeralStateService::Processor
- #process_signal — Concord::Thrift::BoltManagerService::Processor
- #process_sum — Concord::Thrift::BoltMetricsService::Processor
- #process_timer — Concord::Thrift::BoltMetricsService::Processor
- #process_updateSchedulerAddress — Concord::Thrift::BoltProxyService::Processor
- #process_updateTopology — Concord::Thrift::BoltProxyService::Processor
- #produce_record — Concord::ComputationContext
- #proxy — Concord::Computation
- #recv_boltMetadata — Concord::Thrift::ComputationService::Client
- #recv_boltProcessRecords — Concord::Thrift::ComputationService::Client
- #recv_boltProcessTimer — Concord::Thrift::ComputationService::Client
- #recv_deployComputation — Concord::Thrift::BoltSchedulerService::Client
- #recv_destroy — Concord::Thrift::ComputationService::Client
- #recv_dispatchRecords — Concord::Thrift::BoltPipeService::Client
- #recv_gauge — Concord::Thrift::BoltMetricsService::Client
- #recv_getComputationSlug — Concord::Thrift::BoltSchedulerService::Client
- #recv_getState — Concord::Thrift::MutableEphemeralStateService::Client
- #recv_histogram — Concord::Thrift::BoltMetricsService::Client
- #recv_init — Concord::Thrift::ComputationService::Client
- #recv_killTask — Concord::Thrift::BoltSchedulerService::Client
- #recv_registerComputation — Concord::Thrift::BoltSchedulerService::Client
- #recv_scaleComputation — Concord::Thrift::BoltSchedulerService::Client
- #recv_setEnvironmentVar — Concord::Thrift::BoltManagerService::Client
- #recv_setState — Concord::Thrift::MutableEphemeralStateService::Client
- #recv_signal — Concord::Thrift::BoltManagerService::Client
- #recv_sum — Concord::Thrift::BoltMetricsService::Client
- #recv_timer — Concord::Thrift::BoltMetricsService::Client
- #recv_updateSchedulerAddress — Concord::Thrift::BoltProxyService::Client
- #recv_updateTopology — Concord::Thrift::BoltProxyService::Client
- #registerComputation — Concord::Thrift::BoltSchedulerService::Client
- #registerWithScheduler — Concord::Thrift::BoltProxyService::Client
- #register_with_scheduler — Concord::Computation
- #scaleComputation — Concord::Thrift::BoltSchedulerService::Client
- #send_boltMetadata — Concord::Thrift::ComputationService::Client
- #send_boltProcessRecords — Concord::Thrift::ComputationService::Client
- #send_boltProcessTimer — Concord::Thrift::ComputationService::Client
- #send_deployComputation — Concord::Thrift::BoltSchedulerService::Client
- #send_destroy — Concord::Thrift::ComputationService::Client
- #send_dispatchRecords — Concord::Thrift::BoltPipeService::Client
- #send_gauge — Concord::Thrift::BoltMetricsService::Client
- #send_getComputationSlug — Concord::Thrift::BoltSchedulerService::Client
- #send_getState — Concord::Thrift::MutableEphemeralStateService::Client
- #send_histogram — Concord::Thrift::BoltMetricsService::Client
- #send_init — Concord::Thrift::ComputationService::Client
- #send_killTask — Concord::Thrift::BoltSchedulerService::Client
- #send_registerComputation — Concord::Thrift::BoltSchedulerService::Client
- #send_registerWithScheduler — Concord::Thrift::BoltProxyService::Client
- #send_scaleComputation — Concord::Thrift::BoltSchedulerService::Client
- #send_setEnvironmentVar — Concord::Thrift::BoltManagerService::Client
- #send_setState — Concord::Thrift::MutableEphemeralStateService::Client
- #send_signal — Concord::Thrift::BoltManagerService::Client
- #send_sum — Concord::Thrift::BoltMetricsService::Client
- #send_timer — Concord::Thrift::BoltMetricsService::Client
- #send_updateSchedulerAddress — Concord::Thrift::BoltProxyService::Client
- #send_updateTopology — Concord::Thrift::BoltProxyService::Client
- #setEnvironmentVar — Concord::Thrift::BoltManagerService::Client
- #setState — Concord::Thrift::MutableEphemeralStateService::Client
- #set_state — Concord::ComputationContext
- #set_state — Concord::Computation
- #set_timer — Concord::ComputationContext
- #signal — Concord::Thrift::BoltManagerService::Client
- #struct_fields — Concord::Thrift::BoltManagerService::SetEnvironmentVar_args
- #struct_fields — Concord::Thrift::BoltManagerService::SetEnvironmentVar_result
- #struct_fields — Concord::Thrift::BoltManagerService::Signal_args
- #struct_fields — Concord::Thrift::BoltManagerService::Signal_result
- #struct_fields — Concord::Thrift::BoltMetricsService::Gauge_args
- #struct_fields — Concord::Thrift::BoltMetricsService::Gauge_result
- #struct_fields — Concord::Thrift::BoltMetricsService::Timer_args
- #struct_fields — Concord::Thrift::BoltMetricsService::Timer_result
- #struct_fields — Concord::Thrift::BoltMetricsService::Histogram_args
- #struct_fields — Concord::Thrift::BoltMetricsService::Histogram_result
- #struct_fields — Concord::Thrift::BoltMetricsService::Sum_args
- #struct_fields — Concord::Thrift::BoltMetricsService::Sum_result
- #struct_fields — Concord::Thrift::BoltPipeService::DispatchRecords_args
- #struct_fields — Concord::Thrift::BoltPipeService::DispatchRecords_result
- #struct_fields — Concord::Thrift::BoltProxyService::UpdateTopology_args
- #struct_fields — Concord::Thrift::BoltProxyService::UpdateTopology_result
- #struct_fields — Concord::Thrift::BoltProxyService::UpdateSchedulerAddress_args
- #struct_fields — Concord::Thrift::BoltProxyService::UpdateSchedulerAddress_result
- #struct_fields — Concord::Thrift::BoltProxyService::RegisterWithScheduler_args
- #struct_fields — Concord::Thrift::BoltProxyService::RegisterWithScheduler_result
- #struct_fields — Concord::Thrift::BoltSchedulerService::DeployComputation_args
- #struct_fields — Concord::Thrift::BoltSchedulerService::DeployComputation_result
- #struct_fields — Concord::Thrift::BoltSchedulerService::GetComputationSlug_args
- #struct_fields — Concord::Thrift::BoltSchedulerService::GetComputationSlug_result
- #struct_fields — Concord::Thrift::BoltSchedulerService::RegisterComputation_args
- #struct_fields — Concord::Thrift::BoltSchedulerService::RegisterComputation_result
- #struct_fields — Concord::Thrift::BoltSchedulerService::ScaleComputation_args
- #struct_fields — Concord::Thrift::BoltSchedulerService::ScaleComputation_result
- #struct_fields — Concord::Thrift::BoltSchedulerService::KillTask_args
- #struct_fields — Concord::Thrift::BoltSchedulerService::KillTask_result
- #struct_fields — Concord::Thrift::BoltError
- #struct_fields — Concord::Thrift::Endpoint
- #struct_fields — Concord::Thrift::StreamMetadata
- #struct_fields — Concord::Thrift::ComputationMetadata
- #struct_fields — Concord::Thrift::ExecutorTaskInfoHelper
- #struct_fields — Concord::Thrift::PhysicalComputationMetadata
- #struct_fields — Concord::Thrift::PhysicalComputationLayout
- #struct_fields — Concord::Thrift::SchedulerMetadata
- #struct_fields — Concord::Thrift::TopologyMetadata
- #struct_fields — Concord::Thrift::RecordMetadata
- #struct_fields — Concord::Thrift::Record
- #struct_fields — Concord::Thrift::ComputationTx
- #struct_fields — Concord::Thrift::RichStream
- #struct_fields — Concord::Thrift::BoltComputationRequest
- #struct_fields — Concord::Thrift::ComputationService::Init_args
- #struct_fields — Concord::Thrift::ComputationService::Init_result
- #struct_fields — Concord::Thrift::ComputationService::Destroy_args
- #struct_fields — Concord::Thrift::ComputationService::Destroy_result
- #struct_fields — Concord::Thrift::ComputationService::BoltProcessRecords_args
- #struct_fields — Concord::Thrift::ComputationService::BoltProcessRecords_result
- #struct_fields — Concord::Thrift::ComputationService::BoltProcessTimer_args
- #struct_fields — Concord::Thrift::ComputationService::BoltProcessTimer_result
- #struct_fields — Concord::Thrift::ComputationService::BoltMetadata_args
- #struct_fields — Concord::Thrift::ComputationService::BoltMetadata_result
- #struct_fields — Concord::Thrift::MutableEphemeralStateService::SetState_args
- #struct_fields — Concord::Thrift::MutableEphemeralStateService::SetState_result
- #struct_fields — Concord::Thrift::MutableEphemeralStateService::GetState_args
- #struct_fields — Concord::Thrift::MutableEphemeralStateService::GetState_result
- #sum — Concord::Thrift::BoltMetricsService::Client
- #time_millis — Concord::Utils
- #timer — Concord::Thrift::BoltMetricsService::Client
- #updateSchedulerAddress — Concord::Thrift::BoltProxyService::Client
- #updateTopology — Concord::Thrift::BoltProxyService::Client
- #validate — Concord::Thrift::BoltManagerService::SetEnvironmentVar_args
- #validate — Concord::Thrift::BoltManagerService::SetEnvironmentVar_result
- #validate — Concord::Thrift::BoltManagerService::Signal_args
- #validate — Concord::Thrift::BoltManagerService::Signal_result
- #validate — Concord::Thrift::BoltMetricsService::Gauge_args
- #validate — Concord::Thrift::BoltMetricsService::Gauge_result
- #validate — Concord::Thrift::BoltMetricsService::Timer_args
- #validate — Concord::Thrift::BoltMetricsService::Timer_result
- #validate — Concord::Thrift::BoltMetricsService::Histogram_args
- #validate — Concord::Thrift::BoltMetricsService::Histogram_result
- #validate — Concord::Thrift::BoltMetricsService::Sum_args
- #validate — Concord::Thrift::BoltMetricsService::Sum_result
- #validate — Concord::Thrift::BoltPipeService::DispatchRecords_args
- #validate — Concord::Thrift::BoltPipeService::DispatchRecords_result
- #validate — Concord::Thrift::BoltProxyService::UpdateTopology_args
- #validate — Concord::Thrift::BoltProxyService::UpdateTopology_result
- #validate — Concord::Thrift::BoltProxyService::UpdateSchedulerAddress_args
- #validate — Concord::Thrift::BoltProxyService::UpdateSchedulerAddress_result
- #validate — Concord::Thrift::BoltProxyService::RegisterWithScheduler_args
- #validate — Concord::Thrift::BoltProxyService::RegisterWithScheduler_result
- #validate — Concord::Thrift::BoltSchedulerService::DeployComputation_args
- #validate — Concord::Thrift::BoltSchedulerService::DeployComputation_result
- #validate — Concord::Thrift::BoltSchedulerService::GetComputationSlug_args
- #validate — Concord::Thrift::BoltSchedulerService::GetComputationSlug_result
- #validate — Concord::Thrift::BoltSchedulerService::RegisterComputation_args
- #validate — Concord::Thrift::BoltSchedulerService::RegisterComputation_result
- #validate — Concord::Thrift::BoltSchedulerService::ScaleComputation_args
- #validate — Concord::Thrift::BoltSchedulerService::ScaleComputation_result
- #validate — Concord::Thrift::BoltSchedulerService::KillTask_args
- #validate — Concord::Thrift::BoltSchedulerService::KillTask_result
- #validate — Concord::Thrift::BoltError
- #validate — Concord::Thrift::Endpoint
- #validate — Concord::Thrift::StreamMetadata
- #validate — Concord::Thrift::ComputationMetadata
- #validate — Concord::Thrift::ExecutorTaskInfoHelper
- #validate — Concord::Thrift::PhysicalComputationMetadata
- #validate — Concord::Thrift::PhysicalComputationLayout
- #validate — Concord::Thrift::SchedulerMetadata
- #validate — Concord::Thrift::TopologyMetadata
- #validate — Concord::Thrift::RecordMetadata
- #validate — Concord::Thrift::Record
- #validate — Concord::Thrift::ComputationTx
- #validate — Concord::Thrift::RichStream
- #validate — Concord::Thrift::BoltComputationRequest
- #validate — Concord::Thrift::ComputationService::Init_args
- #validate — Concord::Thrift::ComputationService::Init_result
- #validate — Concord::Thrift::ComputationService::Destroy_args
- #validate — Concord::Thrift::ComputationService::Destroy_result
- #validate — Concord::Thrift::ComputationService::BoltProcessRecords_args
- #validate — Concord::Thrift::ComputationService::BoltProcessRecords_result
- #validate — Concord::Thrift::ComputationService::BoltProcessTimer_args
- #validate — Concord::Thrift::ComputationService::BoltProcessTimer_result
- #validate — Concord::Thrift::ComputationService::BoltMetadata_args
- #validate — Concord::Thrift::ComputationService::BoltMetadata_result
- #validate — Concord::Thrift::MutableEphemeralStateService::SetState_args
- #validate — Concord::Thrift::MutableEphemeralStateService::SetState_result
- #validate — Concord::Thrift::MutableEphemeralStateService::GetState_args
- #validate — Concord::Thrift::MutableEphemeralStateService::GetState_result