Skip to content

Commit

Permalink
merge
Browse files Browse the repository at this point in the history
  • Loading branch information
gatesn committed May 10, 2024
1 parent 2070196 commit ce5cc55
Showing 1 changed file with 8 additions and 5 deletions.
13 changes: 8 additions & 5 deletions vortex-ipc/src/messages.rs
Original file line number Diff line number Diff line change
Expand Up @@ -10,16 +10,19 @@ use crate::flatbuffers::ipc as fb;
use crate::flatbuffers::ipc::Compression;
use crate::{missing, ALIGNMENT};

pub enum IPCMessage<'a> {
pub(crate) enum IPCMessage<'a> {
Context(IPCContext<'a>),
Schema(IPCSchema<'a>),
Chunk(IPCChunk<'a>),
}

pub struct IPCContext<'a>(pub &'a ViewContext);
pub struct IPCSchema<'a>(pub &'a DType);
pub struct IPCChunk<'a>(pub &'a ViewContext, pub &'a ArrayData);
pub struct IPCArray<'a>(pub &'a ViewContext, pub &'a ArrayData);
pub(crate) struct IPCContext<'a>(pub &'a ViewContext);

pub(crate) struct IPCSchema<'a>(pub &'a DType);

pub(crate) struct IPCChunk<'a>(pub &'a ViewContext, pub &'a ArrayData);

pub(crate) struct IPCArray<'a>(pub &'a ViewContext, pub &'a ArrayData);

impl FlatBufferRoot for IPCMessage<'_> {}

Expand Down

0 comments on commit ce5cc55

Please sign in to comment.