This is an automated email from the ASF dual-hosted git repository.
hgruszecki pushed a change to branch io_uring_tpc_task_registry
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 2d512e70 remove builders and fix tests
add 815fe947 revert removal of builder and make API closure based,
implement fsync on shutdown
No new revisions were added by this update.
Summary of changes:
core/server/src/http/http_server.rs | 10 +-
core/server/src/shard/mod.rs | 108 +++++-------
core/server/src/shard/task_registry/builders.rs | 19 ++
.../src/shard/task_registry/builders/continuous.rs | 98 +++++++++++
.../src/shard/task_registry/builders/oneshot.rs | 108 ++++++++++++
.../src/shard/task_registry/builders/periodic.rs | 123 +++++++++++++
core/server/src/shard/task_registry/mod.rs | 5 +-
core/server/src/shard/task_registry/registry.rs | 196 ++++++++++++---------
core/server/src/shard/task_registry/specs.rs | 65 -------
.../src/shard/tasks/continuous/http_server.rs | 56 ++----
.../src/shard/tasks/continuous/message_pump.rs | 102 ++++-------
core/server/src/shard/tasks/continuous/mod.rs | 8 +-
.../src/shard/tasks/continuous/quic_server.rs | 53 ++----
.../src/shard/tasks/continuous/tcp_server.rs | 53 ++----
.../src/shard/tasks/periodic/clear_jwt_tokens.rs | 94 ++++------
.../tasks/periodic/clear_personal_access_tokens.rs | 117 +++++-------
core/server/src/shard/tasks/periodic/mod.rs | 10 +-
.../src/shard/tasks/periodic/print_sysinfo.rs | 79 +++------
.../src/shard/tasks/periodic/save_messages.rs | 168 +++++++++---------
.../src/shard/tasks/periodic/verify_heartbeats.rs | 147 ++++++----------
core/server/src/slab/streams.rs | 109 +++++++++---
core/server/src/streaming/utils/head_tail_buf.rs | 55 ------
core/server/src/streaming/utils/mod.rs | 1 -
23 files changed, 914 insertions(+), 870 deletions(-)
create mode 100644 core/server/src/shard/task_registry/builders.rs
create mode 100644 core/server/src/shard/task_registry/builders/continuous.rs
create mode 100644 core/server/src/shard/task_registry/builders/oneshot.rs
create mode 100644 core/server/src/shard/task_registry/builders/periodic.rs
delete mode 100644 core/server/src/shard/task_registry/specs.rs
delete mode 100644 core/server/src/streaming/utils/head_tail_buf.rs
