Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

feat: changes to client side of connection #11

Open
wants to merge 9 commits into
base: master
Choose a base branch
from
Open

feat: changes to client side of connection #11

Changes from 1 commit
Commits
Show all changes
9 commits
Select commit Hold shift + click to select a range
923035b
changes to client side connection
montekki Dec 2, 2024
c095b03
uses enum for request
montekki Dec 3, 2024
7872ead
uuids on worker tasks (#12)
nikkolasg Dec 3, 2024
dc8ee80
reply bytes
nikkolasg Dec 4, 2024
f613dfe
add a ready proof reply to client
montekki Dec 6, 2024
e441897
duration instead of timestamp
montekki Dec 10, 2024
1963e35
removes reply_string field
montekki Dec 12, 2024
62d359d
adds stake_requested field on the client side
montekki Jan 17, 2025
ec3584a
adds task priority
montekki Jan 21, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
25 changes: 21 additions & 4 deletions proto/lagrange.proto
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -2,6 +2,8 @@ syntax = "proto3";

package lagrange;

import "google/protobuf/timestamp.proto";

message WorkerToGwResponse {
oneof response {
string todo = 1;
Expand Down Expand Up @@ -37,19 +39,34 @@ message WorkerDone {
}
}

message UUID {
bytes id = 1;
}

message SubmitTaskRequest {
oneof request {
string task = 1;
}
bytes task_bytes = 1;
// friendly name of a task for logging and tracing
string user_task_id = 2;
google.protobuf.Timestamp timeout = 3;
bytes price_requested = 4;
string class = 5;
}

message SubmitTaskResponse {
oneof reply {
string reply_string = 1;
}
UUID task_uuid = 2;
}

message ProofChannelRequest {
repeated UUID acked_messages = 1;
repeated UUID subscribe_to_messages = 2;
montekki marked this conversation as resolved.
Show resolved Hide resolved
}

message ProofChannelResponse {}

service ClientsService {
rpc ClientToGw(stream SubmitTaskRequest) returns (stream SubmitTaskResponse) {}
rpc SubmitTask(SubmitTaskRequest) returns (SubmitTaskResponse) {}
rpc ProofChannel(stream ProofChannelRequest) returns (stream ProofChannelResponse) {}
}
Loading