kjuulh/nodata
1
0
Fork 0
Code Issues 1 Pull Requests 2 Actions Packages Projects Releases Wiki Activity

feat: cleanup

Browse Source 
Signed-off-by: kjuulh <contact@kjuulh.io>
This commit is contained in:
Kasper Juul Hermansen 2024-11-09 11:51:03 +01:00
parent a327cdb02e
commit 6dfd7d7011
No known key found for this signature in database
4 changed files with 3 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
crates/nodata/src/dagger_engine.rs
View File

@ -1,7 +1,7 @@
use std::sync::Arc; use std::sync::Arc;
use anyhow::Context; use anyhow::Context;
use dagger_sdk::{PortForward, ServiceEndpointOpts, ServiceUpOpts}; use dagger_sdk::{PortForward, ServiceUpOpts};
use tokio::net::TcpListener; use tokio::net::TcpListener;
use tokio_util::sync::CancellationToken; use tokio_util::sync::CancellationToken;

2
crates/nodata/src/main.rs
View File

@ -92,8 +92,6 @@ async fn main() -> anyhow::Result<()> {
ClientCommands::PublishEvent { topic, value } => { ClientCommands::PublishEvent { topic, value } => {
let mut client = create_client(grpc_host).await?; let mut client = create_client(grpc_host).await?;
let timestamp = chrono::Utc::now();
let _ = client let _ = client
.publish_event(PublishEventRequest { .publish_event(PublishEventRequest {
topic, topic,

2
crates/nodata/src/services/handler.rs
View File

@ -1,7 +1,7 @@
use crate::state::SharedState; use crate::state::SharedState;
use super::{ use super::{
consumers::{Consumer, PartitionKey, Topic, TopicOffset}, consumers::{Consumer, Topic, TopicOffset},
staging::Staging, staging::Staging,
}; };

2
crates/nodata/src/services/staging.rs
View File

@ -4,7 +4,7 @@ use tokio::sync::RwLock;
use crate::state::SharedState; use crate::state::SharedState;
use super::consumers::{PartitionKey, Topic, TopicOffset}; use super::consumers::{Topic, TopicOffset};
#[derive(Clone, Debug, PartialEq, Eq)] #[derive(Clone, Debug, PartialEq, Eq)]
pub struct StagingEvent { pub struct StagingEvent {