Index

_

__call__() (kafkaaggregator.cli.init_example method) (kafkaaggregator.cli.produce method)

A

abbreviate_fqdn() (kafkaaggregator.cli.init_example method) (kafkaaggregator.cli.produce method) abstract (kafkaaggregator.cli.init_example attribute) (kafkaaggregator.cli.produce attribute) agent_template_file (kafkaaggregator.config.Configuration attribute) AgentGenerator (class in kafkaaggregator.generator) agents_output_dir (kafkaaggregator.config.Configuration attribute) AggregatedTopic (class in kafkaaggregator.topics) AggregationExample (class in kafkaaggregator.example)

Aggregator (class in kafkaaggregator.aggregator) aggregator_config_file (kafkaaggregator.config.Configuration attribute) as_click_command() (kafkaaggregator.cli.init_example class method) (kafkaaggregator.cli.produce class method) as_service() (kafkaaggregator.cli.init_example method) (kafkaaggregator.cli.produce method) asdict() (kafkaaggregator.fields.Field method) astuple() (kafkaaggregator.fields.Field method) async_create_record() (kafkaaggregator.aggregator.Aggregator method)

B

blocking_timeout (kafkaaggregator.cli.init_example attribute) (kafkaaggregator.cli.produce attribute) bold() (kafkaaggregator.cli.init_example method) (kafkaaggregator.cli.produce method)

bold_tail() (kafkaaggregator.cli.init_example method) (kafkaaggregator.cli.produce method) broker (kafkaaggregator.config.Configuration attribute) builtin_options (kafkaaggregator.cli.init_example attribute) (kafkaaggregator.cli.produce attribute)

C

carp() (kafkaaggregator.cli.init_example method) (kafkaaggregator.cli.produce method) color() (kafkaaggregator.cli.init_example method) (kafkaaggregator.cli.produce method) compute() (kafkaaggregator.aggregator.Aggregator method) Configuration (class in kafkaaggregator.config)

console_port (kafkaaggregator.cli.init_example attribute) (kafkaaggregator.cli.produce attribute) create_app() (in module kafkaaggregator.app) create_record() (in module kafkaaggregator.models) (kafkaaggregator.aggregator.Aggregator method) (kafkaaggregator.example.AggregationExample method)

D

daemon (kafkaaggregator.cli.init_example attribute) (kafkaaggregator.cli.produce attribute) dark() (kafkaaggregator.cli.init_example method) (kafkaaggregator.cli.produce method)

dumps() (kafkaaggregator.cli.init_example method) (kafkaaggregator.cli.produce method)

E

ExampleConfiguration (class in kafkaaggregator.config)

execute() (kafkaaggregator.cli.init_example method) (kafkaaggregator.cli.produce method)

F

Field (class in kafkaaggregator.fields) frequency (kafkaaggregator.config.ExampleConfiguration attribute)

from_handler() (kafkaaggregator.cli.init_example class method) (kafkaaggregator.cli.produce class method)

G

get_fields() (kafkaaggregator.topics.AggregatedTopic method) (kafkaaggregator.topics.SourceTopic method) (kafkaaggregator.topics.Topic method)

get_schema() (kafkaaggregator.topics.AggregatedTopic method) (kafkaaggregator.topics.SourceTopic method) (kafkaaggregator.topics.Topic method)

I

import_relative_to_app() (kafkaaggregator.cli.init_example method) (kafkaaggregator.cli.produce method)

init_example (class in kafkaaggregator.cli) initialize() (kafkaaggregator.example.AggregationExample method) internal_registry_url (kafkaaggregator.config.Configuration attribute)

K

kafkaaggregator.aggregator module kafkaaggregator.app module kafkaaggregator.cli module kafkaaggregator.config module kafkaaggregator.example module

kafkaaggregator.fields module kafkaaggregator.generator module kafkaaggregator.models module kafkaaggregator.topics module

L

logger (kafkaaggregator.aggregator.Aggregator attribute) (kafkaaggregator.generator.AgentGenerator attribute) (kafkaaggregator.topics.AggregatedTopic attribute) (kafkaaggregator.topics.SourceTopic attribute) (kafkaaggregator.topics.Topic attribute)

loglevel (kafkaaggregator.cli.init_example attribute) (kafkaaggregator.cli.produce attribute)

M

main() (in module kafkaaggregator.cli) make_fields() (kafkaaggregator.example.AggregationExample method) max_messages (kafkaaggregator.config.ExampleConfiguration attribute) MAX_NFIELDS (kafkaaggregator.example.AggregationExample attribute) MAX_NTOPICS (kafkaaggregator.example.AggregationExample attribute) min_sample_size (kafkaaggregator.config.Configuration attribute) module kafkaaggregator.aggregator kafkaaggregator.app kafkaaggregator.cli kafkaaggregator.config kafkaaggregator.example kafkaaggregator.fields kafkaaggregator.generator kafkaaggregator.models kafkaaggregator.topics

N

nfields (kafkaaggregator.config.ExampleConfiguration attribute)

ntopics (kafkaaggregator.config.ExampleConfiguration attribute)

O

on_stop() (kafkaaggregator.cli.init_example method) (kafkaaggregator.cli.produce method) on_worker_created() (kafkaaggregator.cli.init_example method) (kafkaaggregator.cli.produce method)

options (kafkaaggregator.cli.init_example attribute) (kafkaaggregator.cli.produce attribute)

P

parse() (kafkaaggregator.cli.init_example class method) (kafkaaggregator.cli.produce class method) produce (class in kafkaaggregator.cli)

produce() (kafkaaggregator.example.AggregationExample method) prog_name (kafkaaggregator.cli.init_example attribute) (kafkaaggregator.cli.produce attribute)

R

redirect_stdouts (kafkaaggregator.cli.init_example attribute) (kafkaaggregator.cli.produce attribute) redirect_stdouts_level (kafkaaggregator.cli.init_example attribute) (kafkaaggregator.cli.produce attribute) register() (kafkaaggregator.topics.AggregatedTopic method) (kafkaaggregator.topics.SourceTopic method) (kafkaaggregator.topics.Topic method)

registry_url (kafkaaggregator.config.Configuration attribute) require_app (kafkaaggregator.cli.init_example attribute) (kafkaaggregator.cli.produce attribute) run() (kafkaaggregator.cli.init_example method) (kafkaaggregator.cli.produce method) (kafkaaggregator.generator.AgentGenerator method) run_using_worker() (kafkaaggregator.cli.init_example method) (kafkaaggregator.cli.produce method)

S

say() (kafkaaggregator.cli.init_example method) (kafkaaggregator.cli.produce method) SchemaException

source_topic_name_prefix (kafkaaggregator.config.ExampleConfiguration attribute) SourceTopic (class in kafkaaggregator.topics) store (kafkaaggregator.config.Configuration attribute)

T

table() (kafkaaggregator.cli.init_example method) (kafkaaggregator.cli.produce method) tabulate() (kafkaaggregator.cli.init_example method) (kafkaaggregator.cli.produce method) template (kafkaaggregator.generator.AgentGenerator attribute) to_key() (kafkaaggregator.cli.init_example method) (kafkaaggregator.cli.produce method) to_model() (kafkaaggregator.cli.init_example method) (kafkaaggregator.cli.produce method)

to_topic() (kafkaaggregator.cli.init_example method) (kafkaaggregator.cli.produce method) to_value() (kafkaaggregator.cli.init_example method) (kafkaaggregator.cli.produce method) Topic (class in kafkaaggregator.topics) topic_partitions (kafkaaggregator.config.Configuration attribute) topic_regex (kafkaaggregator.config.Configuration attribute)

U

UnexpectedNumberOfTopicsError

W

worker_for_service() (kafkaaggregator.cli.init_example method) (kafkaaggregator.cli.produce method)