pub enum Request {
NodeNotification(NodeInfo),
RequestReconnect(RequestReconnect),
PauseEventProcessor(EventProcessorReference),
StartEventProcessor(EventProcessorReference),
ReleaseSegment(EventProcessorSegmentReference),
RequestEventProcessorInfo(EventProcessorReference),
SplitEventProcessorSegment(EventProcessorSegmentReference),
MergeEventProcessorSegment(EventProcessorSegmentReference),
Heartbeat(Heartbeat),
Ack(InstructionAck),
}
Expand description
The actual instruction or information
Variants§
NodeNotification(NodeInfo)
Information provided by AxonServer which provides information about the AxonServer node the application is connected with
RequestReconnect(RequestReconnect)
A request from AxonServer to the Application to migrate its connection to another node. Clients SHOULD honor this request by closing their current connection, and using the GetPlatformServer RPC to request a new destination.
PauseEventProcessor(EventProcessorReference)
Instruction from AxonServer to Pause a Tracking Event Processor.
StartEventProcessor(EventProcessorReference)
Instruction from AxonServer to Start a Tracking Event Processor.
ReleaseSegment(EventProcessorSegmentReference)
Instruction from AxonServer to Release a specific segment in a Tracking Event Processor
RequestEventProcessorInfo(EventProcessorReference)
A request from AxonServer for status information of a specific Tracking Event Processor
SplitEventProcessorSegment(EventProcessorSegmentReference)
Instruction to split a Segment in a Tracking Event Processor
MergeEventProcessorSegment(EventProcessorSegmentReference)
Instruction to merge two Segments in a Tracking Event Processor
Heartbeat(Heartbeat)
This heartbeat is used by AxonFramework in order to check if the connection is still alive
Ack(InstructionAck)
Acknowledgement of previously sent instruction via inbound stream
Implementations§
source§impl Request
impl Request
sourcepub fn merge<B>(
field: &mut Option<Request>,
tag: u32,
wire_type: WireType,
buf: &mut B,
ctx: DecodeContext
) -> Result<(), DecodeError>where
B: Buf,
pub fn merge<B>(
field: &mut Option<Request>,
tag: u32,
wire_type: WireType,
buf: &mut B,
ctx: DecodeContext
) -> Result<(), DecodeError>where
B: Buf,
Decodes an instance of the message from a buffer, and merges it into self.
sourcepub fn encoded_len(&self) -> usize
pub fn encoded_len(&self) -> usize
Returns the encoded length of the message without a length delimiter.
Trait Implementations§
source§impl<'de> Deserialize<'de> for Request
impl<'de> Deserialize<'de> for Request
source§fn deserialize<__D>(
__deserializer: __D
) -> Result<Request, <__D as Deserializer<'de>>::Error>where
__D: Deserializer<'de>,
fn deserialize<__D>(
__deserializer: __D
) -> Result<Request, <__D as Deserializer<'de>>::Error>where
__D: Deserializer<'de>,
source§impl PartialEq for Request
impl PartialEq for Request
source§impl Serialize for Request
impl Serialize for Request
source§fn serialize<__S>(
&self,
__serializer: __S
) -> Result<<__S as Serializer>::Ok, <__S as Serializer>::Error>where
__S: Serializer,
fn serialize<__S>(
&self,
__serializer: __S
) -> Result<<__S as Serializer>::Ok, <__S as Serializer>::Error>where
__S: Serializer,
impl StructuralPartialEq for Request
Auto Trait Implementations§
impl RefUnwindSafe for Request
impl Send for Request
impl Sync for Request
impl Unpin for Request
impl UnwindSafe for Request
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
source§impl<T> FromBase64 for Twhere
T: for<'de> Deserialize<'de>,
impl<T> FromBase64 for Twhere
T: for<'de> Deserialize<'de>,
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
T
in a tonic::Request