Index

_

__aenter__() (event_collector.queue.CollectorQueue method)

__aexit__() (event_collector.queue.CollectorQueue method)

A

add_logger() (event_collector.logger.LogRegistry method) AppLogger (in module event_collector.logger) arrival_rate (event_collector.queue.Metrics attribute)

autoscale (event_collector.queue.CollectorQueue attribute) avg_load (event_collector.queue.Metrics attribute) avg_load_interval (event_collector.queue.CollectorQueue attribute) AVG_LOAD_INTERVAL (in module event_collector.queue)

B

BROADCAST (event_collector.data.Delivery attribute)

busy (event_collector.queue.Metrics attribute)

C

Collector (class in event_collector.collector) collector_queue (event_collector.queue.InitializedQueue attribute) (event_collector.queue.ShutDownQueue attribute) CollectorDict (in module event_collector.collector) CollectorEvent (class in event_collector.publisher) CollectorList (in module event_collector.collector) CollectorQueue (class in event_collector.queue) collectors (event_collector.queue.CollectorQueue attribute) (event_collector.router.Router attribute) (event_collector.router.SimpleRouter attribute)

Command (class in event_collector.messagebus) ConfigError consumer_count() (event_collector.queue.CollectorQueue method) consumer_shutdown_timeout (event_collector.queue.CollectorQueue attribute) CONSUMER_SHUTDOWN_TIMEOUT (in module event_collector.queue) consumers (event_collector.queue.Metrics attribute) Context (class in event_collector.data) ctx (event_collector.collector.Collector attribute) current_load() (event_collector.queue.CollectorQueue method)

D

DEFAULT_LOG_LEVEL (in module event_collector.logger) DEFAULT_MAX_CONSUMERS (in module event_collector.queue) DEFAULT_MIN_CONSUMERS (in module event_collector.queue) default_priority (event_collector.queue.CollectorQueue attribute)

DEFAULT_PRIORITY (in module event_collector.publisher) Delivery (class in event_collector.data) delivery (event_collector.data.Payload attribute) departure_rate (event_collector.queue.Metrics attribute)

E

Error (class in event_collector.data) error() (event_collector.data.Error method) (event_collector.data.Ok method) event_collector.base.router module event_collector.collector module event_collector.data module event_collector.exceptions module event_collector.logger module

event_collector.messagebus module event_collector.publisher module event_collector.queue module event_count (event_collector.queue.Metrics attribute) event_service_data_window_size (event_collector.queue.CollectorQueue attribute) EVENT_SERVICE_DATA_WINDOW_SIZE (in module event_collector.queue) EventCollectorException EventPublisher (class in event_collector.publisher)

F

FIFO (event_collector.publisher.QueueType attribute)

first() (event_collector.data.ResultList method)

G

get_log_registry() (in module event_collector.logger) get_logger() (event_collector.logger.LogRegistry method) (in module event_collector.logger)

get_metrics() (event_collector.queue.CollectorQueue method) get_publisher() (event_collector.queue.CollectorQueue method) get_result() (event_collector.publisher.CollectorEvent method)

H

handle_event() (event_collector.router.Router method) (event_collector.router.SimpleRouter method)

I

init_queue() (event_collector.queue.CollectorQueue method)

InitializedQueue (class in event_collector.queue) iter() (event_collector.data.ResultList method)

K

key (event_collector.collector.Collector attribute)

KEY (event_collector.data.Delivery attribute) keys (event_collector.data.Payload attribute)

L

lifecycle (event_collector.collector.Collector attribute) LifecycleManager (in module event_collector.collector) LIFO (event_collector.publisher.QueueType attribute)

load (event_collector.queue.Metrics attribute) logging (event_collector.queue.CollectorQueue attribute) LogRegistry (class in event_collector.logger)

M

max_consumers (event_collector.queue.CollectorQueue attribute) Message (class in event_collector.messagebus) MessageBus (class in event_collector.messagebus) Metrics (class in event_collector.queue) metrics (event_collector.queue.ReportedMetrics attribute) metrics_collector_window_size (event_collector.queue.CollectorQueue attribute) METRICS_COLLECTOR_WINDOW_SIZE (in module event_collector.queue) metrics_warmup_interval (event_collector.queue.CollectorQueue attribute) METRICS_WARMUP_INTERVAL (in module event_collector.queue) min_consumers (event_collector.queue.CollectorQueue attribute) module event_collector.base.router event_collector.collector event_collector.data event_collector.exceptions event_collector.logger event_collector.messagebus event_collector.publisher event_collector.queue

monitor_interval (event_collector.queue.CollectorQueue attribute) MONITOR_INTERVAL (in module event_collector.queue) MonotonicTime (in module event_collector.queue)

N

NullLogger (class in event_collector.logger)

O

Ok (class in event_collector.data)

ok() (event_collector.data.Error method) (event_collector.data.Ok method)

P

Payload (class in event_collector.data) priority (event_collector.data.Payload attribute) PRIORITY (event_collector.publisher.QueueType attribute)

process() (event_collector.collector.Collector method) processor (event_collector.collector.Collector attribute) Processor (in module event_collector.collector)

Q

qsize (event_collector.queue.Metrics attribute)

queue_type (event_collector.queue.CollectorQueue attribute) QueueType (class in event_collector.publisher)

R

Record (in module event_collector.data) report_interval (event_collector.queue.CollectorQueue attribute) REPORT_INTERVAL (in module event_collector.queue) ReportedMetrics (class in event_collector.queue)

Result (in module event_collector.data) ResultList (class in event_collector.data) results (event_collector.data.ResultList property) Router (class in event_collector.router) router (event_collector.queue.CollectorQueue attribute)

S

send() (event_collector.publisher.EventPublisher method) service_time (event_collector.queue.Metrics attribute) service_time() (event_collector.publisher.CollectorEvent method) set_delivery() (event_collector.data.Payload method) set_log_registry() (in module event_collector.logger)

set_priority() (event_collector.data.Payload method) shut_down_queue() (event_collector.queue.CollectorQueue method) ShutDownQueue (class in event_collector.queue) SimpleRouter (class in event_collector.router) size() (event_collector.data.ResultList method)

T

timestamp (event_collector.queue.Metrics attribute) TOPIC (event_collector.data.Delivery attribute)

topics (event_collector.collector.Collector attribute) (event_collector.data.Payload attribute)

U

unwrap() (event_collector.data.Error method) (event_collector.data.Ok method)

V

value (event_collector.data.Payload attribute)

W

wait() (event_collector.publisher.CollectorEvent method) (event_collector.publisher.EventPublisher method) wait_time (event_collector.queue.Metrics attribute)

wait_time() (event_collector.publisher.CollectorEvent method) wip (event_collector.queue.Metrics attribute) wip_margin (event_collector.queue.CollectorQueue attribute) WIP_MARGIN (in module event_collector.queue)