Systems and/or methods for tailoring event processing in accordance with boundary conditions

A method for configuring a system to handle a stream of events, the method comprising:

• defining a plurality of event types;
• storing said event types in an event type registry;
• and
• enabling the system to execute in first and second modes, wherein:
• the stream of events is received, at least one of said events having boundary conditions attached thereto, the boundary conditions being maximum reaction times and/or priorities;
• queries are executed, via at least one processor of the system, on the events;
• for each said event having a maximum reaction time and/or a priority attached thereto:
• whether the event can be processed within the attached boundary condition is estimated,
• the queries are processed according to the first mode when the event can be processed within the attached boundary condition, and
• the queries are processed according to the second mode when the event cannot be processed within the attached boundary condition, wherein the second mode is practiced by at least temporarily suspending queries that do not consume events with attached boundary condition instead processing other queries;
• and
• the second mode is ended and processing is returned to the first mode when it is estimated that unconsumed events having attached boundary conditions can be processed within their attached boundary conditions.

A system configured to generate and process a stream of events, comprising:

• an event bus configured to receive the stream of events, at least one of said events having boundary conditions attached thereto, the boundary conditions being maximum reaction times and/or priorities;
• at least one processor configured to execute predefined queries on the events, the at least one processor being further configured to:
• for each said event having a maximum reaction time and/or a priority attached thereto:
• estimate whether the event can be processed within the attached boundary condition,
• process the predefined queries according to a first mode when the event can be processed within the attached boundary condition, and
• process the predefined queries according to a second mode when the event cannot be processed within the attached boundary condition, wherein the second mode is practiced by at least temporarily suspending queries that do not consume events with attached boundary condition instead processing other queries;
• and
• end the second mode return to processing according to the first mode when it is estimated that unconsumed events having attached boundary conditions can be processed within their attached boundary conditions.

A non-transitory computer readable storage medium tangibly storing instructions that, when executed by a processor of a system, performs functionality comprising:

• receiving the stream of events, at least one of said events having boundary conditions attached thereto, the boundary conditions being maximum reaction times and/or priorities;
• executing, via at least one processor of a computer system, predefined queries on the events;
• for each said event having a maximum reaction time and/or a priority attached thereto:
• estimating whether the event can be processed within the attached boundary condition,
• processing the predefined queries according to a first mode when the event can be processed within the attached boundary condition, and
• processing the predefined queries according to a second mode when the event cannot be processed within the attached boundary condition, wherein the second mode is practiced by at least temporarily suspending queries that do not consume events with attached boundary condition instead processing other queries;
• and
• ending the second mode returning to processing according to the first mode when it is estimated that unconsumed events having attached boundary conditions can be processed within their attached boundary conditions.

A system configured to generate and process a stream of events, comprising:

• a memory configured to store one or more instructions for generating and processing the stream of events;
• and
• at least one processor, operatively associated with the memory, and configured to at least:
• define a plurality of event types;
• store said event types in an event type registry;
• and
• enable the system to execute in first and second modes,
• wherein:
• the stream of events is received, at least one of said events having boundary conditions attached thereto, the boundary conditions being maximum reaction times and/or priorities;
• queries are executed, via at least one processor of the system, on the events;
• for each said event having a maximum reaction time and/or a priority attached thereto:
• whether the event can be processed within the attached boundary condition is estimated,
• the queries are processed according to the first mode when the event can be processed within the attached boundary condition, and
• the queries are processed according to the second mode when the event cannot be processed within the attached boundary condition, wherein the second mode is practiced by at least temporarily suspending queries that do not consume events with attached boundary condition instead processing other queries;
• and
• the second mode is ended and processing is returned to the first mode when it is estimated that unconsumed events having attached boundary conditions can be processed within their attached boundary conditions.

A non-transitory computer readable storage medium tangibly storing instructions that, when executed by a processor of a system, performs functionality comprising:

• defining a plurality of event types;
• storing said event types in an event type registry;
• and
• enabling the system to execute in first and second modes, wherein:
• the stream of events is received, at least one of said events having boundary conditions attached thereto, the boundary conditions being maximum reaction times and/or priorities;
• queries are executed, via at least one processor of the system, on the events;
• for each said event having a maximum reaction time and/or a priority attached thereto:
• whether the event can be processed within the attached boundary condition is estimated,
• the queries are processed according to the first mode when the event can be processed within the attached boundary condition, and
• the queries are processed according to the second mode when the event cannot be processed within the attached boundary condition, wherein the second mode is practiced by at least temporarily suspending queries that do not consume events with attached boundary condition instead processing other queries;
• and
• the second mode is ended and processing is returned to the first mode when it is estimated that unconsumed events having attached boundary conditions can be processed within their attached boundary conditions.