mirrors/krata
1
0
Fork 0
mirror of https://github.com/edera-dev/krata.git synced 2025-08-03 05:10:55 +00:00
Code Issues Packages Projects Releases Wiki Activity

krata: move api proto to /proto and version api

Browse Source
This commit is contained in:
Alex Zenla
2024-03-24 05:52:25 +00:00
parent cb6839b0f6
commit 655b8029cb
26 changed files with 41 additions and 36 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
crates/krata/build.rs
View File

@ -4,11 +4,15 @@ fn main() -> Result<()> {
let mut config = prost_build::Config::new();
prost_reflect_build::Builder::new()
.descriptor_pool("crate::DESCRIPTOR_POOL")
.configure(&mut config, &["proto/krata/control.proto"], &["proto/"])?;
.configure(
&mut config,
&["../../proto/krata/v1/control.proto"],
&["../../proto/"],
)?;
tonic_build::configure().compile_with_config(
config,
&["proto/krata/control.proto"],
&["proto/"],
&["../../proto/krata/v1/control.proto"],
&["../../proto/"],
)?;
Ok(())
}

67
crates/krata/proto/krata/common.proto
View File

@ -1,67 +0,0 @@
syntax = "proto3";
package krata.common;
option java_multiple_files = true;
option java_package = "dev.krata.proto.common";
option java_outer_classname = "CommonProto";
message Guest {
string id = 1;
GuestSpec spec = 2;
GuestState state = 3;
}
message GuestSpec {
string name = 1;
GuestImageSpec image = 2;
uint32 vcpus = 3;
uint64 mem = 4;
repeated GuestEnvVar env = 5;
repeated string run = 6;
}
message GuestImageSpec {
oneof image {
GuestOciImageSpec oci = 1;
}
}
message GuestOciImageSpec {
string image = 1;
}
message GuestEnvVar {
string key = 1;
string value = 2;
}
message GuestState {
GuestStatus status = 1;
GuestNetworkState network = 2;
GuestExitInfo exit_info = 3;
GuestErrorInfo error_info = 4;
}
enum GuestStatus {
GUEST_STATUS_UNKNOWN = 0;
GUEST_STATUS_STARTING = 1;
GUEST_STATUS_STARTED = 2;
GUEST_STATUS_EXITED = 3;
GUEST_STATUS_DESTROYING = 4;
GUEST_STATUS_DESTROYED = 5;
GUEST_STATUS_FAILED = 6;
}
message GuestNetworkState {
string ipv4 = 1;
string ipv6 = 2;
}
message GuestExitInfo {
int32 code = 1;
}
message GuestErrorInfo {
string message = 1;
}

67
crates/krata/proto/krata/control.proto
View File

@ -1,67 +0,0 @@
syntax = "proto3";
package krata.control;
option java_multiple_files = true;
option java_package = "dev.krata.proto.control";
option java_outer_classname = "ControlProto";
import "krata/common.proto";
service ControlService {
rpc CreateGuest(CreateGuestRequest) returns (CreateGuestReply);
rpc DestroyGuest(DestroyGuestRequest) returns (DestroyGuestReply);
rpc ResolveGuest(ResolveGuestRequest) returns (ResolveGuestReply);
rpc ListGuests(ListGuestsRequest) returns (ListGuestsReply);
rpc ConsoleData(stream ConsoleDataRequest) returns (stream ConsoleDataReply);
rpc WatchEvents(WatchEventsRequest) returns (stream WatchEventsReply);
}
message CreateGuestRequest {
krata.common.GuestSpec spec = 1;
}
message CreateGuestReply {
string guest_id = 1;
}
message DestroyGuestRequest {
string guest_id = 1;
}
message DestroyGuestReply {}
message ResolveGuestRequest {
string name = 1;
}
message ResolveGuestReply {
krata.common.Guest guest = 1;
}
message ListGuestsRequest {}
message ListGuestsReply {
repeated krata.common.Guest guests = 1;
}
message ConsoleDataRequest {
string guest_id = 1;
bytes data = 2;
}
message ConsoleDataReply {
bytes data = 1;
}
message WatchEventsRequest {}
message WatchEventsReply {
oneof event {
GuestChangedEvent guest_changed = 1;
}
}
message GuestChangedEvent {
krata.common.Guest guest = 1;
}

1
crates/krata/src/common.rs
View File

@ -1 +0,0 @@
tonic::include_proto!("krata.common");

1
crates/krata/src/control.rs
View File

@ -1 +0,0 @@
tonic::include_proto!("krata.control");

3
crates/krata/src/lib.rs
View File

@ -1,10 +1,9 @@
use once_cell::sync::Lazy;
use prost_reflect::DescriptorPool;
pub mod common;
pub mod control;
pub mod dial;
pub mod launchcfg;
pub mod v1;
#[cfg(target_os = "linux")]
pub mod ethtool;

1
crates/krata/src/v1/common.rs Normal file
View File

@ -0,0 +1 @@
tonic::include_proto!("krata.v1.common");

1
crates/krata/src/v1/control.rs Normal file
View File

@ -0,0 +1 @@
tonic::include_proto!("krata.v1.control");

2
crates/krata/src/v1/mod.rs Normal file
View File

@ -0,0 +1,2 @@
pub mod common;
pub mod control;

2
crates/kratactl/src/cli/attach.rs
View File

@ -1,6 +1,6 @@
use anyhow::Result;
use clap::Parser;
use krata::control::control_service_client::ControlServiceClient;
use krata::v1::control::control_service_client::ControlServiceClient;
use tokio::select;
use tonic::transport::Channel;

2
crates/kratactl/src/cli/destroy.rs
View File

@ -1,6 +1,6 @@
use anyhow::Result;
use clap::Parser;
use krata::{
use krata::v1::{
common::GuestStatus,
control::{
control_service_client::ControlServiceClient, watch_events_reply::Event,

2
crates/kratactl/src/cli/launch.rs
View File

@ -2,7 +2,7 @@ use std::collections::HashMap;
use anyhow::Result;
use clap::Parser;
use krata::{
use krata::v1::{
common::{
guest_image_spec::Image, GuestEnvVar, GuestImageSpec, GuestOciImageSpec, GuestSpec,
GuestStatus,

2
crates/kratactl/src/cli/list.rs
View File

@ -1,7 +1,7 @@
use anyhow::{anyhow, Result};
use clap::{Parser, ValueEnum};
use cli_tables::Table;
use krata::{
use krata::v1::{
common::{guest_image_spec::Image, Guest},
control::{
control_service_client::ControlServiceClient, ListGuestsRequest, ResolveGuestRequest,

2
crates/kratactl/src/cli/mod.rs
View File

@ -7,7 +7,7 @@ pub mod watch;
use anyhow::{anyhow, Result};
use clap::{Parser, Subcommand};
use krata::control::{
use krata::v1::control::{
control_service_client::ControlServiceClient, ResolveGuestRequest, WatchEventsRequest,
};
use tonic::{transport::Channel, Request};

2
crates/kratactl/src/cli/resolve.rs
View File

@ -1,6 +1,6 @@
use anyhow::Result;
use clap::Parser;
use krata::control::{control_service_client::ControlServiceClient, ResolveGuestRequest};
use krata::v1::control::{control_service_client::ControlServiceClient, ResolveGuestRequest};
use tonic::{transport::Channel, Request};

2
crates/kratactl/src/cli/watch.rs
View File

@ -1,6 +1,6 @@
use anyhow::Result;
use clap::{Parser, ValueEnum};
use krata::{common::Guest, control::watch_events_reply::Event};
use krata::v1::{common::Guest, control::watch_events_reply::Event};
use prost_reflect::ReflectMessage;
use serde_json::Value;

2
crates/kratactl/src/client.rs
View File

@ -1,7 +1,7 @@
#[cfg(not(unix))]
use anyhow::anyhow;
use anyhow::Result;
use krata::{control::control_service_client::ControlServiceClient, dial::ControlDialAddress};
use krata::{dial::ControlDialAddress, v1::control::control_service_client::ControlServiceClient};
#[cfg(unix)]
use tokio::net::UnixStream;
#[cfg(unix)]

2
crates/kratactl/src/console.rs
View File

@ -4,7 +4,7 @@ use crossterm::{
terminal::{disable_raw_mode, enable_raw_mode, is_raw_mode_enabled},
tty::IsTty,
};
use krata::{
use krata::v1::{
common::GuestStatus,
control::{watch_events_reply::Event, ConsoleDataReply, ConsoleDataRequest},
};

2
crates/kratactl/src/events.rs
View File

@ -1,7 +1,7 @@
use std::sync::Arc;
use anyhow::Result;
use krata::control::{watch_events_reply::Event, WatchEventsReply};
use krata::v1::control::{watch_events_reply::Event, WatchEventsReply};
use log::trace;
use tokio::{sync::broadcast, task::JoinHandle};
use tokio_stream::StreamExt;

2
crates/kratactl/src/format.rs
View File

@ -1,7 +1,7 @@
use std::collections::HashMap;
use anyhow::Result;
use krata::common::{GuestState, GuestStatus};
use krata::v1::common::{GuestState, GuestStatus};
use prost_reflect::{DynamicMessage, ReflectMessage, Value};
pub fn proto2dynamic(proto: impl ReflectMessage) -> Result<DynamicMessage> {

4
crates/kratad/build.rs
View File

@ -2,7 +2,7 @@ use std::io::Result;
fn main() -> Result<()> {
prost_build::Config::new()
.extern_path(".krata.common", "::krata::common")
.compile_protos(&["proto/kratad/db.proto"], &["proto/", "../krata/proto"])?;
.extern_path(".krata.v1.common", "::krata::v1::common")
.compile_protos(&["proto/kratad/db.proto"], &["proto/", "../../proto"])?;
Ok(())
}

4
crates/kratad/proto/kratad/db.proto
View File

@ -2,9 +2,9 @@ syntax = "proto3";
package kratad.db;
import "krata/common.proto";
import "krata/v1/common.proto";
message GuestEntry {
string id = 1;
krata.common.Guest guest = 2;
krata.v1.common.Guest guest = 2;
}

2
crates/kratad/src/control.rs
View File

@ -2,7 +2,7 @@ use std::{io, pin::Pin, str::FromStr};
use async_stream::try_stream;
use futures::Stream;
use krata::{
use krata::v1::{
common::{Guest, GuestState, GuestStatus},
control::{
control_service_server::ControlService, ConsoleDataReply, ConsoleDataRequest,

4
crates/kratad/src/event.rs
View File

@ -5,7 +5,7 @@ use std::{
};
use anyhow::Result;
use krata::common::{GuestExitInfo, GuestState, GuestStatus};
use krata::v1::common::{GuestExitInfo, GuestState, GuestStatus};
use log::error;
use tokio::{
select,
@ -22,7 +22,7 @@ use kratart::Runtime;
use crate::db::GuestStore;
pub type DaemonEvent = krata::control::watch_events_reply::Event;
pub type DaemonEvent = krata::v1::control::watch_events_reply::Event;
const EVENT_CHANNEL_QUEUE_LEN: usize = 1000;
const EXIT_CODE_CHANNEL_QUEUE_LEN: usize = 1000;

2
crates/kratad/src/lib.rs
View File

@ -4,7 +4,7 @@ use anyhow::Result;
use control::RuntimeControlService;
use db::GuestStore;
use event::{DaemonEventContext, DaemonEventGenerator};
use krata::{control::control_service_server::ControlServiceServer, dial::ControlDialAddress};
use krata::{dial::ControlDialAddress, v1::control::control_service_server::ControlServiceServer};
use kratart::Runtime;
use log::info;
use reconcile::guest::GuestReconciler;

2
crates/kratad/src/reconcile/guest.rs
View File

@ -1,7 +1,7 @@
use std::{collections::HashMap, time::Duration};
use anyhow::{anyhow, Result};
use krata::{
use krata::v1::{
common::{
guest_image_spec::Image, Guest, GuestErrorInfo, GuestExitInfo, GuestNetworkState,
GuestState, GuestStatus,