Struct InProcessContext 

pub struct InProcessContext<'a> { /* private fields */ }

Implementations

impl<'a> InProcessContext<'a>

pub fn new(host: &'a mut (dyn HostContext + 'a), operator: OperatorId) -> Self

pub fn take_diffs(&mut self) -> Vec<Diff>

Trait Implementations

impl GuestContext for InProcessContext<'_>

type InsertEmit<'a> = InProcessInsertEmit<'a> where Self: 'a

type UpdateEmit<'a> = InProcessUpdateEmit<'a> where Self: 'a

type RemoveEmit<'a> = InProcessRemoveEmit<'a> where Self: 'a

fn operator_id(&self) -> OperatorId

fn written_at(&self) -> DateTime

fn state(&mut self) -> impl GuestState + '_

fn dictionary(&mut self) -> impl GuestDictionary + '_

fn intern_groups( &mut self, groups: &[EncodedKey], ) -> SdkResult<Vec<(GroupId, bool)>>

fn lookup_groups( &mut self, groups: &[EncodedKey], ) -> SdkResult<Vec<Option<GroupId>>>

fn arm_timer( &mut self, due: DateTime, kind: TimerKind, key: &EncodedKey, ) -> SdkResult<()>

fn disarm_timer( &mut self, due: DateTime, kind: TimerKind, key: &EncodedKey, ) -> SdkResult<()>

fn flow_watermark(&mut self) -> SdkResult<Option<DateTime>>

fn get_or_create_row_numbers( &mut self, group: GroupId, keys: &[EncodedKey], ) -> SdkResult<Vec<(RowNumber, bool)>>

fn get_or_create_row_numbers_for_pairs( &mut self, pairs: &[(GroupId, EncodedKey)], ) -> SdkResult<Vec<(RowNumber, bool)>>

fn remove_row_number( &mut self, group: GroupId, key: &EncodedKey, ) -> SdkResult<()>

fn remove_row_numbers_below( &mut self, group: GroupId, upper: &EncodedKey, ) -> SdkResult<Vec<RowNumber>>

fn reclaim_group_identity( &mut self, group: GroupId, limit: usize, ) -> SdkResult<ReclaimOutcome>

fn insert_emit<R: Row>( &mut self, _row_capacity: usize, ) -> SdkResult<InProcessInsertEmit<'_>>

fn update_emit<R: Row>( &mut self, _row_capacity: usize, ) -> SdkResult<InProcessUpdateEmit<'_>>

fn remove_emit<R: Row>( &mut self, _row_capacity: usize, ) -> SdkResult<InProcessRemoveEmit<'_>>

fn emit_insert<R>( &mut self, rows: &[R], row_numbers: &[RowNumber], ) -> Result<(), SdkError>

where R: Row,

fn emit_update<R>( &mut self, pre: &[R], post: &[R], row_numbers: &[RowNumber], ) -> Result<(), SdkError>

where R: Row,

fn emit_remove<R>( &mut self, rows: &[R], row_numbers: &[RowNumber], ) -> Result<(), SdkError>

where R: Row,