NAME
Myriad::RPC::Implementation::Memory - microservice RPC in-memory implementation.
DESCRIPTION
METHODS
start
Start waiting for new requests to fill in the internal requests queue.
process_stream_messages
Process and emit received messages, while making sure we respond to them.
create_from_sink
Register and RPC call and save a reference to its Ryu::Sink.
stop
Gracefully stop the RPC processing.
reply_success
Reply to the requester with a success message.
In this implementation it's done by resolving the Future calling done.
reply_error
Reply to the requester with a failure message.
In this implementation it's done by resolving the Future calling fail.
drop
Drop the request because we can't reply to the requester.
stream_name
Get the stream name of the service the current template is
service.$service_name.rpc/$method
it takes:
INHERITED METHODS
- IO::Async::Notifier
-
add_child, adopt_future, adopted_futures, can_event, children, configure_unknown, debug_printf, get_loop, invoke_error, invoke_event, loop, make_event_cb, maybe_invoke_event, maybe_make_event_cb, notifier_name, parent, remove_child, remove_from_parent
- Object::Pad::UNIVERSAL
AUTHOR
Deriv Group Services Ltd. DERIV@cpan.org.
See "CONTRIBUTORS" in Myriad for full details.
LICENSE
Copyright Deriv Group Services Ltd 2020-2022. Licensed under the same terms as Perl itself.