Index _ | A | B | C | D | E | F | G | H | I | K | L | M | N | P | R | S | T | U _ __enter__() (saf.pipeline.Pipeline method) __exit__() (saf.pipeline.Pipeline method) __repr__() (saf.plugins.PluginsList method) __virtual__() (in module saf.saltext.engines.analytics) A add_event_to_shared_cache (saf.forward.test.TestForwardConfig attribute) alphabet (saf.process.shannon_mask.ShannonMaskProcessConfig attribute) args (saf.collect.salt_exec.SaltExecConfig attribute) await_stopped() (saf.manager.Manager method) B backfill (saf.collect.file.CollectedLineEvent attribute) (saf.collect.file.FileCollectConfig attribute) beacon (saf.collect.beacons.BeaconCollectedEvent attribute) beacons (saf.collect.beacons.BeaconsConfig attribute) C cache (saf.models.PipelineRunContext attribute) catch_entry_points_exception() (in module saf.plugins) child_events_count (saf.process.test.TestProcessConfig attribute) collect (saf.models.PipelineConfig attribute) collect() (in module saf.collect.beacons) (in module saf.collect.file) (in module saf.collect.salt_exec) (in module saf.collect.test) CollectedLineData (class in saf.collect.file) collectors (saf.models.AnalyticsConfig attribute) config (saf.models.PipelineRunContext attribute) count (saf.collect.test.TestCollectConfig attribute) D data (saf.collect.file.CollectedLineEvent attribute) (saf.models.CollectedEvent attribute) (saf.models.SaltEvent attribute) delay (saf.process.test.TestProcessConfig attribute) delay_range (saf.process.test.TestProcessConfig attribute) DelayRange (class in saf.process.test) delimeter (saf.process.shannon_mask.ShannonMaskProcessConfig attribute) dump_event (saf.forward.test.TestForwardConfig attribute) E enabled (saf.models.PipelineConfig attribute) F filename (saf.forward.disk.DiskConfig attribute) fn (saf.collect.salt_exec.SaltExecConfig attribute) forward (saf.models.PipelineConfig attribute) forward() (in module saf.forward.disk) (in module saf.forward.noop) (in module saf.forward.test) forwarders (saf.models.AnalyticsConfig attribute) G get_config_dict() (in module saf.saltext.engines.analytics) get_config_schema() (in module saf.collect.beacons) (in module saf.collect.file) (in module saf.collect.salt_exec) (in module saf.collect.test) (in module saf.forward.disk) (in module saf.forward.noop) (in module saf.forward.test) (in module saf.process.regex_mask) (in module saf.process.shannon_mask) (in module saf.process.test) H h_threshold (saf.process.shannon_mask.ShannonMaskProcessConfig attribute) I instance() (saf.plugins.PluginsList static method) interval (saf.collect.salt_exec.SaltExecConfig attribute) (saf.collect.test.TestCollectConfig attribute) iter_events() (in module saf.utils.eventbus) K kwargs (saf.collect.salt_exec.SaltExecConfig attribute) L length_threshold (saf.process.shannon_mask.ShannonMaskProcessConfig attribute) line (saf.collect.file.CollectedLineData attribute) load_plugins() (saf.plugins.PluginsList method) loaded_plugin (saf.models.CollectConfigBase property) (saf.models.ForwardConfigBase property) (saf.models.PluginConfigMixin property) (saf.models.ProcessConfigBase property) M Manager (class in saf.manager) mask_char (saf.process.regex_mask.RegexMaskProcessConfig attribute) (saf.process.shannon_mask.ShannonMaskProcessConfig attribute) mask_prefix (saf.process.regex_mask.RegexMaskProcessConfig attribute) (saf.process.shannon_mask.ShannonMaskProcessConfig attribute) mask_str (saf.process.shannon_mask.ShannonMaskProcessConfig attribute) mask_suffix (saf.process.regex_mask.RegexMaskProcessConfig attribute) (saf.process.shannon_mask.ShannonMaskProcessConfig attribute) maximum (saf.process.test.DelayRange attribute) message (saf.forward.test.TestForwardConfig attribute) minimum (saf.process.test.DelayRange attribute) module saf saf.collect saf.collect.beacons saf.collect.file saf.collect.salt_exec saf.collect.test saf.forward saf.forward.disk saf.forward.noop saf.forward.test saf.manager saf.models saf.pipeline saf.plugins saf.process saf.process.regex_mask saf.process.shannon_mask saf.process.test saf.saltext saf.saltext.engines saf.saltext.engines.analytics saf.utils saf.utils.dt saf.utils.eventbus saf.version N name (saf.models.PipelineConfig property) (saf.models.PluginConfigMixin property) P parent (saf.models.NonMutableConfig property) path (saf.forward.disk.DiskConfig attribute) (saf.forward.test.TestForwardConfig attribute) paths (saf.collect.file.FileCollectConfig attribute) Pipeline (class in saf.pipeline) pipeline_config (saf.models.PipelineRunContext property) pipelines (saf.models.AnalyticsConfig attribute) plugin (saf.models.CollectConfigBase attribute) (saf.models.ForwardConfigBase attribute) (saf.models.PluginConfigMixin attribute) (saf.models.ProcessConfigBase attribute) PluginsList (class in saf.plugins) pretty_print (saf.forward.disk.DiskConfig attribute) process (saf.models.PipelineConfig attribute) process() (in module saf.process.regex_mask) (in module saf.process.shannon_mask) (in module saf.process.test) processors (saf.models.AnalyticsConfig attribute) R raw_data (saf.collect.beacons.BeaconCollectedEvent attribute) (saf.models.SaltEvent attribute) restart (saf.models.PipelineConfig attribute) rules (saf.process.regex_mask.RegexMaskProcessConfig attribute) run() (saf.manager.Manager method) (saf.pipeline.Pipeline method) S saf module saf.collect module saf.collect.beacons module saf.collect.file module saf.collect.salt_exec module saf.collect.test module saf.forward module saf.forward.disk module saf.forward.noop module saf.forward.test module saf.manager module saf.models module saf.pipeline module saf.plugins module saf.process module saf.process.regex_mask module saf.process.shannon_mask module saf.process.test module saf.saltext module saf.saltext.engines module saf.saltext.engines.analytics module saf.utils module saf.utils.dt module saf.utils.eventbus module saf.version module salt_config (saf.models.AnalyticsConfig attribute) (saf.models.PipelineRunContext property) shared_cache (saf.models.PipelineRunContext attribute) sleep (saf.forward.test.TestForwardConfig attribute) source (saf.collect.file.CollectedLineData attribute) stamp (saf.collect.beacons.BeaconCollectedEvent attribute) (saf.models.SaltEvent attribute) start() (in module saf.saltext.engines.analytics) start_pipeline() (saf.manager.Manager method) start_pipelines() (saf.manager.Manager method) stop_pipeline() (saf.manager.Manager method) stop_pipelines() (saf.manager.Manager method) T tag (saf.collect.beacons.BeaconCollectedEvent attribute) (saf.models.SaltEvent attribute) timestamp (saf.models.CollectedEvent attribute) U utcnow() (in module saf.utils.dt)