from defence360agent.contracts.hook_events import HookEvent from defence360agent.contracts.plugins import ( MessageSink, MessageSource, expect, ) from defence360agent.hooks.execute import execute_hooks EVENTS = ( HookEvent.AgentStarted, HookEvent.AgentMisconfig, HookEvent.LicenseExpired, HookEvent.LicenseExpiring, HookEvent.LicenseRenewed, ) class EventHookExecutor(MessageSink, MessageSource): PROCESSING_ORDER = MessageSink.ProcessingOrder.EVENT_HOOK async def create_sink(self, loop): self._loop = loop async def create_source(self, loop, sink): self._loop = loop self._sink = sink @expect(*EVENTS) async def receive_event(self, event): self._loop.create_task(execute_hooks(event))
Name | Type | Size | Permission | Actions |
---|---|---|---|---|
__pycache__ | Folder | 0755 |
|
|
__init__.py | File | 0 B | 0644 |
|
accumulate.py | File | 3.53 KB | 0644 |
|
backup_info_sender.py | File | 3.06 KB | 0644 |
|
check_license.py | File | 7.58 KB | 0644 |
|
checkpoint.py | File | 1.23 KB | 0644 |
|
client.py | File | 9.43 KB | 0644 |
|
config_merger.py | File | 828 B | 0644 |
|
config_watcher.py | File | 1.89 KB | 0644 |
|
event_hook_executor.py | File | 777 B | 0644 |
|
event_monitor.py | File | 3.32 KB | 0644 |
|
event_monitor_message_processor.py | File | 6.33 KB | 0644 |
|
files_recurring_update.py | File | 1.09 KB | 0644 |
|
icontact_sender.py | File | 4.36 KB | 0644 |
|
idle_time_out.py | File | 1.21 KB | 0644 |
|
lve_utils_install.py | File | 1.58 KB | 0644 |
|
myimunify.py | File | 1.43 KB | 0644 |
|
ping.py | File | 536 B | 0644 |
|
send_domain_list.py | File | 2.79 KB | 0644 |
|
send_server_config.py | File | 10.1 KB | 0644 |
|