Skip to content
This repository was archived by the owner on May 13, 2022. It is now read-only.
This repository was archived by the owner on May 13, 2022. It is now read-only.

Implement input policies #4

@j-stephan

Description

@j-stephan

The user currently has the option to set an input limit on stages. Once this limit is reached thread execution is blocked until the internal buffer has room for more objects.

There are circumstances in which this behaviour might be undesirable. ddrf should therefore offer the following three policies:

  • block (default): The current behaviour. Block thread execution until there is room for another object.
  • discard: If the buffer is full, discard the current object.
  • overwrite: If the buffer is full, delete the oldest object and push the current object.

Metadata

Metadata

Assignees

Type

No type

Projects

No projects

Relationships

None yet

Development

No branches or pull requests

Issue actions