Skip to content

Commit bd7a024

Browse files
authored
Get/set oplog index host functions (#250)
* Extended Golem WIT and unified oplog index to be u64 everywhere * Fix tests * Format * Get/set oplog index implementation and test * Fix worker leak * Fixed log entry gathering in tests * Fixes * Removed debug prints * Updated golem-wit submodule * Update OpenAPI * Update golem-wit * Renamed Marker to NoOp * Refactorings, keeping deleted regions in worker status record, recomputing from oplog when needed * Clippy * Updated jump test * Renames and log improvements * Fixes * Performance fix * Fix * Rebuild
1 parent a750028 commit bd7a024

File tree

62 files changed

+2732
-643
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

62 files changed

+2732
-643
lines changed

Cargo.lock

Lines changed: 21 additions & 2 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

golem-api-grpc/proto/golem/worker/complete_parameters.proto

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,6 +4,6 @@ package golem.worker;
44

55

66
message CompleteParameters {
7-
int32 oplog_idx = 1;
7+
uint64 oplog_idx = 1;
88
bytes data = 2;
99
}

golem-api-grpc/proto/golem/worker/promise_id.proto

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,5 +6,5 @@ import "golem/worker/worker_id.proto";
66

77
message PromiseId {
88
WorkerId worker_id = 1;
9-
int32 oplog_idx = 2;
9+
uint64 oplog_idx = 2;
1010
}

golem-common/Cargo.toml

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -29,6 +29,7 @@ poem-openapi = { workspace = true }
2929
prometheus = { workspace = true }
3030
prost = { workspace = true }
3131
rand = "0.8.5"
32+
range-set-blaze = "0.1.16"
3233
serde = { workspace = true }
3334
serde_json = { workspace = true }
3435
tokio = { workspace = true }

0 commit comments

Comments
 (0)