lake_messages (lake v0.2.6)

View Source

Summary

Functions

chunk_to_messages(Other)
close(CorrelationId, ResponseCode, Reason)
close_response(CorrelationId, ResponseCode)
command_versions()
consumer_update_response(CorrelationId, ResponseCode, OffsetSpecification)
create(CorrelationId, Stream, Arguments0)
credit(SubscriptionId, Credit)
declare_publisher(CorrelationId, Stream, PublisherId, PublisherReference)
delete(CorrelationId, Stream)
delete_publisher(CorrelationId, PublisherId)
exchange_command_versions(CorrelationId)
heartbeat()
message_to_correlation_id(Other)
metadata(CorrelationId, Streams)
open(CorrelationId, Vhost)
parse(Unknown)
partitions(CorrelationId, SuperStream)
peer_properties(CorrelationId, Properties)
publish(PublisherId, Messages)
query_offset(CorrelationId, PublisherReference, Stream)
query_publisher_sequence(CorrelationId, PublisherReference, Stream)
route(CorrelationId, RoutingKey, SuperStream)
sasl_authenticate(CorrelationId, Mechanism, User, Password)
sasl_handshake(CorrelationId)
store_offset(PublisherReference, Stream, Offset)
stream_stats(CorrelationId, Stream)
subscribe(CorrelationId, Stream, SubscriptionId, OffsetSpecification, Credit, Properties)
tune(FrameMax, Heartbeat)
unsubscribe(CorrelationId, SubscriptionId)

Functions

chunk_to_messages(Other)

close(CorrelationId, ResponseCode, Reason)

close_response(CorrelationId, ResponseCode)

command_versions()

consumer_update_response(CorrelationId, ResponseCode, OffsetSpecification)

create(CorrelationId, Stream, Arguments0)

credit(SubscriptionId, Credit)

declare_publisher(CorrelationId, Stream, PublisherId, PublisherReference)

delete(CorrelationId, Stream)

delete_publisher(CorrelationId, PublisherId)

exchange_command_versions(CorrelationId)

heartbeat()

message_to_correlation_id(Other)

metadata(CorrelationId, Streams)

open(CorrelationId, Vhost)

parse(Unknown)

partitions(CorrelationId, SuperStream)

peer_properties(CorrelationId, Properties)

publish(PublisherId, Messages)

query_offset(CorrelationId, PublisherReference, Stream)

query_publisher_sequence(CorrelationId, PublisherReference, Stream)

route(CorrelationId, RoutingKey, SuperStream)

sasl_authenticate(CorrelationId, Mechanism, User, Password)

sasl_handshake(CorrelationId)

store_offset(PublisherReference, Stream, Offset)

stream_stats(CorrelationId, Stream)

subscribe(CorrelationId, Stream, SubscriptionId, OffsetSpecification, Credit, Properties)

tune(FrameMax, Heartbeat)

unsubscribe(CorrelationId, SubscriptionId)