lake_connection (lake v0.2.6)

View Source

Summary

Functions

connect(Host, Port, User, Password, Vhost, Options)
consumer_update_response(Connection, CorrelationId, ResponseCode, OffsetSpecification)
create(Connection, Stream, Arguments)
credit_async(Connection, SubscriptionId, Credit)
declare_publisher(Connection, Stream, PublisherId, PublisherReference)
delete(Connection, Stream)
delete_publisher(Connection, PublisherId)
handle_call(Call, From, State0)
handle_cast(Cast, State)
handle_info(_, State)
init(_)
metadata(Connection, Streams)
partitions(Connection, SuperStream)
publish_async(Connection, PublisherId, Messages)
publish_sync(Connection, PublisherId, Messages)
query_offset(Connection, PublisherReference, Stream)
query_publisher_sequence(Connection, PublisherReference, Stream)
route(Connection, RoutingKey, SuperStream)
stop(Connection)
store_offset(Connection, PublisherReference, Stream, Offset)
stream_stats(Connection, SuperStream)
subscribe(Connection, Stream, SubscriptionId, OffsetDefinition, Credit, Properties)
terminate(Reason, State)
tls_connect(Host, Port, User, Password, Vhost, Options)
unsubscribe(Connection, SubscriptionId)

Functions

connect(Host, Port, User, Password, Vhost, Options)

consumer_update_response(Connection, CorrelationId, ResponseCode, OffsetSpecification)

create(Connection, Stream, Arguments)

credit_async(Connection, SubscriptionId, Credit)

declare_publisher(Connection, Stream, PublisherId, PublisherReference)

delete(Connection, Stream)

delete_publisher(Connection, PublisherId)

handle_call(Call, From, State0)

handle_cast(Cast, State)

handle_info(_, State)

init(_)

metadata(Connection, Streams)

partitions(Connection, SuperStream)

publish_async(Connection, PublisherId, Messages)

publish_sync(Connection, PublisherId, Messages)

query_offset(Connection, PublisherReference, Stream)

query_publisher_sequence(Connection, PublisherReference, Stream)

route(Connection, RoutingKey, SuperStream)

stop(Connection)

store_offset(Connection, PublisherReference, Stream, Offset)

stream_stats(Connection, SuperStream)

subscribe(Connection, Stream, SubscriptionId, OffsetDefinition, Credit, Properties)

terminate(Reason, State)

tls_connect(Host, Port, User, Password, Vhost, Options)

unsubscribe(Connection, SubscriptionId)