refactor brain message and daemon message

inspiring from snp proto
container contract message
register node message
This commit is contained in:
Noor 2025-01-29 17:30:02 +05:30
parent 9650183150
commit 3e783b11ba
Signed by: noormohammedb
GPG Key ID: D83EFB8B3B967146
2 changed files with 51 additions and 13 deletions

@ -42,31 +42,47 @@ message DeleteContainerRes {
string status = 2; string status = 2;
} }
service DaemonService {
rpc CreateContainer (shared.Container) returns (NewContainerRes);
rpc DeleteContainer (ContainerFilters) returns (DeleteContainerRes);
rpc ListContainers (ContainerFilters) returns (ContainerListResp);
rpc InspectContainer (shared.UUID) returns (ContainerInspectResp);
// rpc ContainerLog (shared.UUID) returns (stream LogResp);
message BrainMessage {
oneof Msg {
shared.Container new_container_req = 1;
ContainerFilters delete_container = 2;
ContainerFilters list_container = 3;
}
} }
message DaemonMessage {
oneof Msg {
shared.Pubkey pubkey = 1;
NewContainerRes new_vm_resp = 2;
DeleteContainerRes delete_vm_resp = 3;
}
}
// service DaemonService {
// rpc CreateContainer (shared.Container) returns (NewContainerRes);
// rpc DeleteContainer (ContainerFilters) returns (DeleteContainerRes);
// rpc ListContainers (ContainerFilters) returns (ContainerListResp);
// rpc InspectContainer (shared.UUID) returns (ContainerInspectResp);
// rpc ContainerLog (shared.UUID) returns (stream LogResp);
// }
service BrainSgxCli { service BrainSgxCli {
rpc CreateContainer (shared.Container) returns (NewContainerRes); rpc CreateContainer (shared.Container) returns (NewContainerRes);
rpc DeleteContainer (ContainerFilters) returns (DeleteContainerRes); rpc DeleteContainer (ContainerFilters) returns (DeleteContainerRes);
rpc ListContainers (ContainerFilters) returns (ContainerListResp); rpc ListContainers (ContainerFilters) returns (ContainerListResp);
rpc InspectContainer (shared.UUID) returns (ContainerInspectResp); // rpc InspectContainer (shared.UUID) returns (ContainerInspectResp);
// rpc ContainerLog (shared.UUID) returns (stream LogResp); // rpc ContainerLog (shared.UUID) returns (stream LogResp);
} }
service BrainSgxDaemon { service BrainSgxDaemon {
// rpc RegisterNode (RegisterNodeReq) returns (stream Contract); rpc RegisterNode (shared.RegisterNodeReq) returns
// rpc BrainMessages (Pubkey) returns (stream BrainMessage); (stream shared.ContainerContracts);
// rpc DaemonMessages (stream DaemonMessage) returns (Empty); rpc BrainMessages (shared.Pubkey) returns (stream BrainMessage);
rpc DaemonMessages (stream DaemonMessage) returns (shared.Empty);
rpc RegisterNode (shared.Empty) returns (stream shared.Empty);
rpc DaemonMessages (stream shared.Empty) returns (shared.Empty);
rpc BrainMessages (shared.Empty) returns (stream shared.Empty);
} }

@ -58,6 +58,15 @@ message MappedPort {
uint32 container_port = 2; uint32 container_port = 2;
} }
message ContainerContracts {
string uuid = 1;
string package_url = 2;
string admin_pubkey = 3;
string node_pubkey = 4;
repeated MappedPort exposed_ports = 5;
string created_at = 13;
}
message Container { message Container {
optional string package_url = 1; optional string package_url = 1;
@ -73,3 +82,16 @@ message Resource {
uint32 vcpu = 3; uint32 vcpu = 3;
repeated uint32 ports = 4; repeated uint32 ports = 4;
} }
message RegisterNodeReq {
string node_pubkey = 1;
string owner_pubkey = 2;
string main_ip = 3;
string country = 4;
string region = 5;
string city = 6;
}
message Pubkey {
string pubkey = 1;
}