(g)ULP!
Loading...
Searching...
No Matches
PluginBase Member List

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

__init__(self, str path, **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)PluginBaseprotected
_build_ingestion_chunk_for_ws(self, list[dict] docs, GulpIngestionFilter flt=None)PluginBaseprotected
_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)PluginBaseprotected
_finish_ingestion(self, str index, str|dict source, str req_id, int client_id, str ws_id, TmpIngestStats fs, GulpIngestionFilter flt=None)PluginBaseprotected
_flush_buffer(self, str index, TmpIngestStats fs, str ws_id, str req_id, GulpIngestionFilter flt=None, bool wait_for_refresh=False)PluginBaseprotected
_ingest_record(self, str index, GulpDocument|dict doc, TmpIngestStats fs, str ws_id, str req_id, GulpIngestionFilter flt=None, bool flush_enabled=True, **kwargs)PluginBaseprotected
_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)PluginBaseprotected
_parser_failed(self, TmpIngestStats fs, str|dict source, Exception|str ex)PluginBaseprotected
_process_plugin_params(self, GulpMapping custom_mapping, GulpPluginParams plugin_params=None)PluginBaseprotected
_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)PluginBaseprotected
_record_failed(self, TmpIngestStats fs, any entry, str|dict source, Exception|str ex)PluginBaseprotected
_type_checks(self, any v, str k, dict index_type_mapping)PluginBaseprotected
bufferPluginBase
cleanup(self)PluginBase
client_idPluginBase
contextPluginBase
depends_on(self)PluginBase
desc(self)PluginBase
event_type_field(self)PluginBase
get_unmapped_field_name(self, str field)PluginBase
indexPluginBase
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
name(self)PluginBase
operation_idPluginBase
options(self)PluginBase
pathPluginBase
pipeline(self, GulpPluginParams plugin_params=None, **kwargs)PluginBase
query(self, int operation_id, int client_id, int user_id, str username, str ws_id, str req_id, GulpPluginParams plugin_params, GulpQueryFilter flt, GulpQueryOptions options=None)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_idPluginBase
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_idPluginBase