PluginBase Member List

This is the complete list of members for PluginBase, including all inherited members.

__init__(self, str path, AsyncEngine collab=None, AsyncElasticsearch elastic=None, **kwargs)	PluginBase
_build_gulpdocuments(self, list[FieldMappingEntry] fme, int idx, int operation_id, str context, str plugin, int client_id, str raw_event, str original_id, str src_file, int timestamp=None, int timestamp_nsec=None, str event_code=None, list[str] cat=None, int duration_nsec=0, GulpLogLevel gulp_log_level=None, str original_log_level=None, bool remove_raw_event=False, **kwargs)	PluginBase	protected
_build_ingestion_chunk_for_ws(self, list[dict] docs, GulpIngestionFilter flt=None)	PluginBase	protected
_call_record_to_gulp_document_funcs(self, int operation_id, int client_id, str context, str source, TmpIngestStats fs, any record, int record_idx, GulpMapping custom_mapping=None, dict index_type_mapping=None, str plugin=None, GulpPluginParams plugin_params=None, Callable record_to_gulp_document_fun=None, **kwargs)	PluginBase	protected
_finish_ingestion(self, str index, str|dict source, str req_id, int client_id, str ws_id, TmpIngestStats fs, GulpIngestionFilter flt=None)	PluginBase	protected
_flush_buffer(self, str index, TmpIngestStats fs, str ws_id, str req_id, GulpIngestionFilter flt=None, bool wait_for_refresh=False)	PluginBase	protected
_ingest_record(self, str index, GulpDocument|dict doc, TmpIngestStats fs, str ws_id, str req_id, GulpIngestionFilter flt=None, bool flush_enabled=True, **kwargs)	PluginBase	protected
_map_source_key(self, GulpPluginParams plugin_params, GulpMapping custom_mapping, str source_key, Any v, dict index_type_mapping=None, bool ignore_custom_mapping=False, **kwargs)	PluginBase	protected
_parser_failed(self, TmpIngestStats fs, str|dict source, Exception|str ex)	PluginBase	protected
_process_plugin_params(self, GulpMapping custom_mapping, GulpPluginParams plugin_params=None)	PluginBase	protected
_process_record(self, str index, any record, int record_idx, Callable my_record_to_gulp_document_fun, str ws_id, str req_id, int operation_id, int client_id, str context, str source, TmpIngestStats fs, GulpMapping custom_mapping=None, dict index_type_mapping=None, str plugin=None, GulpPluginParams plugin_params=None, GulpIngestionFilter flt=None, **kwargs)	PluginBase	protected
_record_failed(self, TmpIngestStats fs, any entry, str|dict source, Exception|str ex)	PluginBase	protected
_type_checks(self, any v, str k, dict index_type_mapping)	PluginBase	protected
buffer	PluginBase
cleanup(self)	PluginBase
client_id	PluginBase
collab	PluginBase
context	PluginBase
depends_on(self)	PluginBase
desc(self)	PluginBase
elastic	PluginBase
event_type_field(self)	PluginBase
get_unmapped_field_name(self, str field)	PluginBase
index	PluginBase
ingest(self, str index, str req_id, int client_id, int operation_id, str context, str|list[dict] source, str ws_id, GulpPluginParams plugin_params=None, GulpIngestionFilter flt=None, **kwargs)	PluginBase
ingest_plugin_initialize(self, str index, str|dict source, bool skip_mapping=False, ProcessingPipeline pipeline=None, str mapping_file=None, str mapping_id=None, GulpPluginParams plugin_params=None)	PluginBase
internal(self)	PluginBase
logger(cls)	PluginBase
name(self)	PluginBase
operation_id	PluginBase
options(self)	PluginBase
path	PluginBase
pipeline(self, GulpPluginParams plugin_params=None, **kwargs)	PluginBase
record_to_gulp_document(self, int operation_id, int client_id, str context, str source, TmpIngestStats fs, any record, int record_idx, GulpMapping custom_mapping=None, dict index_type_mapping=None, str plugin=None, GulpPluginParams plugin_params=None, **kwargs)	PluginBase
req_id	PluginBase
run_command(self, GulpPluginParams p)	PluginBase
sigma_plugin_initialize(self, ProcessingPipeline pipeline=None, str mapping_file=None, str mapping_id=None, str product=None, GulpPluginParams plugin_params=None)	PluginBase
tags(self)	PluginBase
type(self)	PluginBase
version(self)	PluginBase
ws_id	PluginBase