Struct mixnet::reply_manager::ReplyManager

pub struct ReplyManager { /* private fields */ }

Reply manager state.

Implementations

impl ReplyManager

pub fn new(config: Config) -> Self

Create a new ReplyManager with the given configuration.

pub fn insert<X>( &mut self, message: RequestMessage, mixnet: &mut Mixnet<X>, ) -> Option<(ReplyContext, Vec<u8>)>

Attempt to insert a request.

If the request is already present, posts the reply if necessary, and returns None. The caller does not need to do anything more.

If Some is returned, the caller should handle the request and then call either abandon or complete with the ReplyContext. The Vec<u8> contains the request message data.

pub fn abandon(&mut self, reply_context: ReplyContext)

Abandon a request. This should be called if you do not wish to reply at this time. If insert is called again with a matching message (same ID), it will return Some, and you will have another chance to handle the request.

pub fn complete<X>( &mut self, reply_context: ReplyContext, data: Vec<u8>, mixnet: &mut Mixnet<X>, )

Complete a request. This will post the reply and cache it for repeat requests.