NAME

Myriad::Subscription - microservice subscription abstraction

SYNOPSIS

my $storage = $myriad->subscription;

DESCRIPTION

Implementation

Note that this is defined as a rôle, so it does not provide a concrete implementation - instead, see classes such as:

• Myriad::Subscription::Implementation::Redis

• Myriad::Subscription::Implementation::Memory

METHODS

create_from_sink

Register a new Receiver to notify it when there is new data.

it takes a hash as an argument that should have the following

• sink - a Ryu::Sink that the subscription will emit new messages to.

• channel - The events channel name where the Emitter will emit the new events.

• client - The name that this Receiver should use while fetching new events.

create_from_sink

Register a new Emitter to receive events from.

it takes a hash as an argument that should have the following

• source - a Ryu::Source where the messages will be emitted to.

• channel - The name of the events channel that should be used to send the messages to.

start

Start processing the subscriptions.

stop

Stop processing the subscriptions.

AUTHOR

Deriv Group Services Ltd. DERIV@cpan.org.

See "CONTRIBUTORS" in Myriad for full details.

LICENSE

Copyright Deriv Group Services Ltd 2020-2021. Licensed under the same terms as Perl itself.