Skip to content

Commit

Permalink
chore: pub -> pub (crate)
Browse files Browse the repository at this point in the history
  • Loading branch information
KKould committed Jul 17, 2024
1 parent 69b5cd2 commit 3e82063
Show file tree
Hide file tree
Showing 4 changed files with 10 additions and 5 deletions.
2 changes: 1 addition & 1 deletion Cargo.toml
Original file line number Diff line number Diff line change
Expand Up @@ -11,7 +11,7 @@ tokio = ["dep:tokio"]
arrow = "52"
async-lock = "3"
crossbeam-skiplist = "0.1"
flume = { version = "0.11.0", features = ["async"] }
flume = { version = "0.11", features = ["async"] }
futures-core = "0.3"
futures-io = "0.3"
futures-util = "0.3"
Expand Down
2 changes: 1 addition & 1 deletion src/fs/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@ use ulid::Ulid;

pub(crate) type FileId = Ulid;

pub enum FileType {
pub(crate) enum FileType {
WAL,
PARQUET,
LOG,
Expand Down
9 changes: 7 additions & 2 deletions src/ondisk/scan.rs
Original file line number Diff line number Diff line change
Expand Up @@ -4,6 +4,7 @@ use std::{
};

use futures_core::{ready, Stream};
use futures_io::{AsyncRead, AsyncSeek, AsyncWrite};
use parquet::arrow::async_reader::ParquetRecordBatchStream;
use pin_project_lite::pin_project;
use tokio_util::compat::Compat;
Expand All @@ -19,13 +20,17 @@ pin_project! {
pub struct SsTableScan<R>
{
#[pin]
stream: ParquetRecordBatchStream<Compat<Box<dyn AsyncFile>>>,
stream: ParquetRecordBatchStream<Compat<Box<dyn AsyncRead + AsyncWrite + AsyncSeek + Unpin>>>,
iter: Option<RecordBatchIterator<R>>,
}
}

impl<R> SsTableScan<R> {
pub fn new(stream: ParquetRecordBatchStream<Compat<Box<dyn AsyncFile>>>) -> Self {
pub fn new(
stream: ParquetRecordBatchStream<
Compat<Box<dyn AsyncRead + AsyncWrite + AsyncSeek + Unpin>>,
>,
) -> Self {
SsTableScan { stream, iter: None }
}
}
Expand Down
2 changes: 1 addition & 1 deletion src/scope.rs
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,7 @@ use crate::{
};

#[derive(Debug, Eq, PartialEq)]
pub struct Scope<K> {
pub(crate) struct Scope<K> {
pub(crate) min: K,
pub(crate) max: K,
pub(crate) gen: FileId,
Expand Down

0 comments on commit 3e82063

Please sign in to comment.