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) AggregationExample (class in kafkaaggregator.example)

AggregationTopic (class in kafkaaggregator.topics) Aggregator (class in kafkaaggregator.aggregator) 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() (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

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

F

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

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

G

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

get_schema() (kafkaaggregator.topics.AggregationTopic 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.AggregationTopic 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) make_record() (in module kafkaaggregator.models)

max_messages (kafkaaggregator.config.Configuration attribute) MAX_NFIELDS (kafkaaggregator.example.AggregationExample attribute) MAX_NTOPICS (kafkaaggregator.example.AggregationExample attribute) min_sample_size (kafkaaggregator.config.Configuration attribute)

N

names() (kafkaaggregator.topics.SourceTopic static method)

nfields (kafkaaggregator.config.Configuration attribute) ntopics (kafkaaggregator.config.Configuration 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.AggregationTopic 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.Configuration 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) topic_rename_format (kafkaaggregator.config.Configuration attribute)

U

UnexpectedNumberOfTopicsError

W

window_expires (kafkaaggregator.config.Configuration attribute) window_size (kafkaaggregator.config.Configuration attribute)

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