Struct GroupReadStreamParts 

pub struct GroupReadStreamParts {
    pub placement: ShardPlacement,
    pub offset: u64,
    pub next_offset: u64,
    pub content_type: String,
    pub up_to_date: bool,
    pub closed: bool,
    pub body: GroupReadStreamBody,
}

Fields

placement: ShardPlacement

offset: u64

next_offset: u64

content_type: String

up_to_date: bool

closed: bool

body: GroupReadStreamBody

Implementations

impl GroupReadStreamParts

pub fn from_response(response: ReadStreamResponse) -> Self

pub fn from_plan( placement: ShardPlacement, stream_id: BucketStreamId, plan: StreamReadPlan, cold_store: Option<ColdStoreHandle>, ) -> Self

pub async fn into_response(self) -> Result<ReadStreamResponse, GroupEngineError>