View Source Spear.Records.Streams (Spear v1.4.1)

A record macro interface for interacting with the EventStoreDB Streams API

Summary

Functions

append_req(args \\ [])

append_req(record, args)

append_req_options(args \\ [])

append_req_options(record, args)

append_req_proposed_message(args \\ [])

append_req_proposed_message(record, args)

append_resp(args \\ [])

append_resp(record, args)

append_resp_position(args \\ [])

append_resp_position(record, args)

append_resp_success(args \\ [])

append_resp_success(record, args)

append_resp_wrong_expected_version(args \\ [])

append_resp_wrong_expected_version(record, args)

batch_append_req(args \\ [])

batch_append_req(record, args)

batch_append_req_options(args \\ [])

batch_append_req_options(record, args)

batch_append_req_proposed_message(args \\ [])

batch_append_req_proposed_message(record, args)

batch_append_resp(args \\ [])

batch_append_resp(record, args)

batch_append_resp_success(args \\ [])

batch_append_resp_success(record, args)

delete_req(args \\ [])

delete_req(record, args)

delete_req_options(args \\ [])

delete_req_options(record, args)

delete_resp(args \\ [])

delete_resp(record, args)

delete_resp_position(args \\ [])

delete_resp_position(record, args)

read_req(args \\ [])

read_req(record, args)

read_req_options(args \\ [])

read_req_options(record, args)

read_req_options_all_options(args \\ [])

read_req_options_all_options(record, args)

read_req_options_control_option(args \\ [])

read_req_options_control_option(record, args)

read_req_options_filter_options(args \\ [])

read_req_options_filter_options(record, args)

read_req_options_filter_options_expression(args \\ [])

read_req_options_filter_options_expression(record, args)

read_req_options_position(args \\ [])

read_req_options_position(record, args)

read_req_options_stream_options(args \\ [])

read_req_options_stream_options(record, args)

read_req_options_subscription_options(args \\ [])

read_req_options_subscription_options(record, args)

read_req_options_uuid_option(args \\ [])

read_req_options_uuid_option(record, args)

read_resp(args \\ [])

read_resp(record, args)

read_resp_caught_up(args \\ [])

read_resp_caught_up(record, args)

read_resp_checkpoint(args \\ [])

read_resp_checkpoint(record, args)

read_resp_fell_behind(args \\ [])

read_resp_fell_behind(record, args)

read_resp_read_event(args \\ [])

read_resp_read_event(record, args)

read_resp_read_event_recorded_event(args \\ [])

read_resp_read_event_recorded_event(record, args)

read_resp_stream_not_found(args \\ [])

read_resp_stream_not_found(record, args)

read_resp_subscription_confirmation(args \\ [])

read_resp_subscription_confirmation(record, args)

service()

Returns the gRPC service name for the API

service_module()

Returns the :gpb-generated service module

tombstone_req(args \\ [])

tombstone_req(record, args)

tombstone_req_options(args \\ [])

tombstone_req_options(record, args)

tombstone_resp(args \\ [])

tombstone_resp(record, args)

tombstone_resp_position(args \\ [])

tombstone_resp_position(record, args)

Functions

append_req(args \\ [])

(macro)

append_req(record, args)

(macro)

append_req_options(args \\ [])

(macro)

append_req_options(record, args)

(macro)

append_req_proposed_message(args \\ [])

(macro)

append_req_proposed_message(record, args)

(macro)

append_resp(args \\ [])

(macro)

append_resp(record, args)

(macro)

append_resp_position(args \\ [])

(macro)

append_resp_position(record, args)

(macro)

append_resp_success(args \\ [])

(macro)

append_resp_success(record, args)

(macro)

append_resp_wrong_expected_version(args \\ [])

(macro)

append_resp_wrong_expected_version(record, args)

(macro)

batch_append_req(args \\ [])

(macro)

batch_append_req(record, args)

(macro)

batch_append_req_options(args \\ [])

(macro)

batch_append_req_options(record, args)

(macro)

batch_append_req_proposed_message(args \\ [])

(macro)

batch_append_req_proposed_message(record, args)

(macro)

batch_append_resp(args \\ [])

(macro)

batch_append_resp(record, args)

(macro)

batch_append_resp_success(args \\ [])

(macro)

batch_append_resp_success(record, args)

(macro)

delete_req(args \\ [])

(macro)

delete_req(record, args)

(macro)

delete_req_options(args \\ [])

(macro)

delete_req_options(record, args)

(macro)

delete_resp(args \\ [])

(macro)

delete_resp(record, args)

(macro)

delete_resp_position(args \\ [])

(macro)

delete_resp_position(record, args)

(macro)

read_req(args \\ [])

(macro)

read_req(record, args)

(macro)

read_req_options(args \\ [])

(macro)

read_req_options(record, args)

(macro)

read_req_options_all_options(args \\ [])

(macro)

read_req_options_all_options(record, args)

(macro)

read_req_options_control_option(args \\ [])

(macro)

read_req_options_control_option(record, args)

(macro)

read_req_options_filter_options(args \\ [])

(macro)

read_req_options_filter_options(record, args)

(macro)

read_req_options_filter_options_expression(args \\ [])

(macro)

read_req_options_filter_options_expression(record, args)

(macro)

read_req_options_position(args \\ [])

(macro)

read_req_options_position(record, args)

(macro)

read_req_options_stream_options(args \\ [])

(macro)

read_req_options_stream_options(record, args)

(macro)

read_req_options_subscription_options(args \\ [])

(macro)

read_req_options_subscription_options(record, args)

(macro)

read_req_options_uuid_option(args \\ [])

(macro)

read_req_options_uuid_option(record, args)

(macro)

read_resp(args \\ [])

(macro)

read_resp(record, args)

(macro)

read_resp_caught_up(args \\ [])

(macro)

read_resp_caught_up(record, args)

(macro)

read_resp_checkpoint(args \\ [])

(macro)

read_resp_checkpoint(record, args)

(macro)

read_resp_fell_behind(args \\ [])

(macro)

read_resp_fell_behind(record, args)

(macro)

read_resp_read_event(args \\ [])

(macro)

read_resp_read_event(record, args)

(macro)

read_resp_read_event_recorded_event(args \\ [])

(macro)

read_resp_read_event_recorded_event(record, args)

(macro)

read_resp_stream_not_found(args \\ [])

(macro)

read_resp_stream_not_found(record, args)

(macro)

read_resp_subscription_confirmation(args \\ [])

(macro)

read_resp_subscription_confirmation(record, args)

(macro)

service()

Returns the gRPC service name for the API

service_module()

Returns the :gpb-generated service module

tombstone_req(args \\ [])

(macro)

tombstone_req(record, args)

(macro)

tombstone_req_options(args \\ [])

(macro)

tombstone_req_options(record, args)

(macro)

tombstone_resp(args \\ [])

(macro)

tombstone_resp(record, args)

(macro)

tombstone_resp_position(args \\ [])

(macro)

tombstone_resp_position(record, args)

(macro)