Skip to content

Commit

Permalink
Fix build after main branch merge
Browse files Browse the repository at this point in the history
  • Loading branch information
imotov committed Aug 14, 2023
1 parent b1dc6e5 commit 90540f9
Show file tree
Hide file tree
Showing 2 changed files with 5 additions and 6 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -35,6 +35,7 @@ use quickwit_metastore::{IndexMetadata, ListSplitsQuery, Metastore};
use quickwit_proto::cache_storage::{
CacheStorageServiceClient, NotifySplitsChangeRequest, SplitsChangeNotification,
};
use quickwit_proto::control_plane::ControlPlaneResult;
use quickwit_proto::IndexUid;
use serde::Serialize;
use tokio::sync::RwLock;
Expand Down Expand Up @@ -195,7 +196,7 @@ pub struct CacheUpdateRequest {}

#[async_trait]
impl Handler<CacheUpdateRequest> for CacheStorageController {
type Reply = quickwit_proto::control_plane::Result<()>;
type Reply = ControlPlaneResult<()>;

async fn handle(
&mut self,
Expand Down
8 changes: 3 additions & 5 deletions quickwit/quickwit-control-plane/src/control_plane.rs
Original file line number Diff line number Diff line change
Expand Up @@ -21,11 +21,9 @@ use anyhow::Context;
use async_trait::async_trait;
use quickwit_actors::{Actor, ActorContext, ActorExitStatus, Handler, Mailbox};
use quickwit_proto::control_plane::{

CloseShardsRequest, CloseShardsResponse, ControlPlaneResult, GetOpenShardsRequest,
GetOpenShardsResponse, NotifyIndexChangeRequest, NotifyIndexChangeResponse, NotifySplitsChangeRequest,
NotifySplitsChangeResponse,
,
GetOpenShardsResponse, NotifyIndexChangeRequest, NotifyIndexChangeResponse,
NotifySplitsChangeRequest, NotifySplitsChangeResponse,
};
use tracing::debug;

Expand Down Expand Up @@ -85,7 +83,7 @@ impl Handler<NotifyIndexChangeRequest> for ControlPlane {

#[async_trait]
impl Handler<NotifySplitsChangeRequest> for ControlPlane {
type Reply = quickwit_proto::control_plane::Result<NotifySplitsChangeResponse>;
type Reply = ControlPlaneResult<NotifySplitsChangeResponse>;

async fn handle(
&mut self,
Expand Down

0 comments on commit 90540f9

Please sign in to comment.