php-ec

Fix up handling of Cron rules when running in batch mode

Fix regression with looking up the first and last events

Micro optimisation for checking if various queues have values or now
Bug fix for Cron events triggering timeout
Attempt to save application state in the event that we are unable to encode as JSON

Fix up an race condition where on Alpine linux waitpid() shows the process as still running when the stdout of the process has been closed.
Bug fix for accessing a nonexistent array key when attempting to load a source function that is not defined

Give Rules the ability to request the Scheduler to run an additional input process to gather more data

Support defining code based input sources and actions.

• Input Source functions are defined via extending the SourceFunction class
• Action functions
• Loop is initialised in the Scheduler constructors instead of delaying till run()
• Input and Action processes can be defined using an array of parameters rather than an escaped string
• Improved startup recovery and system state table
• Reduced memory and cycles by using spl_object_id instead of spl_object_hash
• Logs and exit if a rule throws
• Support setting process names for child processes

Correctly detect if error recovery was successful
Constructor for Event objects can now accept a DateTimeInterface or a unixtime int for setting datetime

Full Changelog: https://github.com/lucasnetau/php-ec/compare/v0.5.7...v0.5.8

Improve Signal handling
Improve save state failures
Improve admin console

• can defined a HOST and PORT via ENV
• JIT statistics now displayed

State may be bigger than the default 64K for JSON decoding. Increase the buffer to 10MB

Small bug fixes

Add AllowDynamicProperties attribute to Event class to silence PHP8.2 deprecation notice
Various small improvements

Replaced React\Filesystem with a Child Process based offload for save state saving, a huge reduction in CPU time and reduced external dependancies
Opcache statistics are now visible in the administration interface

Allow heartbeat to have a delayed startup.

Add a configurable realtime heartbeat event to be injected into a running engine

Implement failed action recovery on restart by replaying actions before starting up any input processes. This could be failed actions due to engine failure (killed by OOM or hardware failure) or due to a misconfiguration or resource unavailability (eg database offline)

Add in additional metrics for tracking how long it takes to do the async save time and size of the save state file, exposed via the management server.

Add $essential flag to input processes to shutdown the engine if the process fails to start or shutdowns cleanly

Full Changelog: https://github.com/lucasnetau/php-ec/compare/v0.4.4...v0.5

Add a PSR3 compatible logging facility for processes to log back centrally to the scheduler

Adds a Cron like rule to execute actions or generate events based on a cron expression schedule, or engine startup or shutdown.
Add in logic to restart failed input processes

Remove debug text from SysInfo

Use additional inputs of physical/vm memory and cgroups limits in calculating the amount of memory available to the scheduler.

Add in support for onComplete(), onTimeout(), onProgress() called by fire(), makes for cleaner rules.
Also split acceptEvent into acceptInitialEvent() and acceptSubsequentEvent() to remove boilerplate for setting up and crosschecking context.