Module: Concord::Thrift

Defined in:

lib/gen-rb/bolt_types.rb,
lib/gen-rb/bolt_constants.rb,
lib/gen-rb/bolt_pipe_service.rb,
lib/gen-rb/bolt_proxy_service.rb,
lib/gen-rb/computation_service.rb,
lib/gen-rb/bolt_manager_service.rb,
lib/gen-rb/bolt_metrics_service.rb,
lib/gen-rb/bolt_scheduler_service.rb,
lib/gen-rb/mutable_ephemeral_state_service.rb

Defined Under Namespace

Modules: BackPressure, BoltManagerService, BoltMetricsService, BoltPipeService, BoltProxyService, BoltSchedulerService, ComputationService, MutableEphemeralStateService, RecordFlags, Signal, StreamGrouping Classes: BoltComputationRequest, BoltError, ComputationMetadata, ComputationTx, Endpoint, ExecutorTaskInfoHelper, PhysicalComputationLayout, PhysicalComputationMetadata, Record, RecordMetadata, RichStream, SchedulerMetadata, StreamMetadata, TopologyMetadata

Constant Summary

KBoltEnvKeyBasePath =

%q"BOLT_BASE_PATH"

KBoltDefaultEnvBasePath =

%q"/tmp/"

KBoltEnvKeyPathPrefix =

%q"BOLT"

KDefaultThriftServiceIOThreads =

2

KConcordEnvKeyClientListenAddr =

%q"CONCORD_client_listen_address"

KConcordEnvKeyClientProxyAddr =

%q"CONCORD_client_proxy_address"

KDatabasePath =

%q"/tmp"

KDefaultBatchSize =

2048

KDefaultTraceSampleEveryN =

1024

KPrincipalMonitoringName =

%q"principal"

KDispatcherMonitoringName =

%q"dispatcher"

KPrincipalComputationName =

%q"principal_computation"

KIncomingMessageQueueTopic =

%q"incoming"

KPrincipalTimerQueueTopic =

%q"principal_timers"

KOutgoingMessageQueueTopic =

%q"outgoing"

KQueueStreamNameToIdMapTopic =

%q"stream_map"

KMessageQueueWatermarkTopic =

%q"watermarks"

KMessageQueueBatchSize =

1024

KMessageQueueTTL =

21600