lake_connection_state (lake v0.2.6)

View Source

Summary

Functions

add_publisher(PublisherId, Publisher, Stream, State)
add_subscription(SubscriptionId, Subscriber, Stream, State)
inc_correlation_id(State)
new(Socket, CorrelationId, Heartbeat)
publisher_from_publisher_id(PublisherId, State)
publisher_ids_from_stream(Stream, State)
register_pending_request(Corr, From, Extra, State)
remove_pending_request(Corr, State)
remove_publisher(PublisherId, State)
remove_subscription(SubscriptionId, State)
requestor_from_correlation_id(Corr, State)
stream_publishers(Stream, State)
stream_subscriptions(Stream, State)
subscriber_from_subscription_id(SubscriptionId, State)
subscription_ids_from_stream(Stream, State)

Functions

add_publisher(PublisherId, Publisher, Stream, State)

add_subscription(SubscriptionId, Subscriber, Stream, State)

inc_correlation_id(State)

new(Socket, CorrelationId, Heartbeat)

publisher_from_publisher_id(PublisherId, State)

publisher_ids_from_stream(Stream, State)

register_pending_request(Corr, From, Extra, State)

remove_pending_request(Corr, State)

remove_publisher(PublisherId, State)

remove_subscription(SubscriptionId, State)

requestor_from_correlation_id(Corr, State)

stream_publishers(Stream, State)

stream_subscriptions(Stream, State)

subscriber_from_subscription_id(SubscriptionId, State)

subscription_ids_from_stream(Stream, State)