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

A record macro interface for interacting with the EventStoreDB Persistent Subscriptions API

Summary

Functions

create_req(args \\ [])

create_req(record, args)

create_req_all_options(args \\ [])

create_req_all_options(record, args)

create_req_all_options_filter_options(args \\ [])

create_req_all_options_filter_options(record, args)

create_req_all_options_filter_options_expression(args \\ [])

create_req_all_options_filter_options_expression(record, args)

create_req_options(args \\ [])

create_req_options(record, args)

create_req_position(args \\ [])

create_req_position(record, args)

create_req_settings(args \\ [])

create_req_settings(record, args)

create_req_stream_options(args \\ [])

create_req_stream_options(record, args)

create_resp(args \\ [])

create_resp(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)

get_info_req(args \\ [])

get_info_req(record, args)

get_info_req_options(args \\ [])

get_info_req_options(record, args)

get_info_resp(args \\ [])

get_info_resp(record, args)

list_req(args \\ [])

list_req(record, args)

list_req_options(args \\ [])

list_req_options(record, args)

list_req_stream_option(args \\ [])

list_req_stream_option(record, args)

list_resp(args \\ [])

list_resp(record, args)

read_req(args \\ [])

read_req(record, args)

read_req_ack(args \\ [])

read_req_ack(record, args)

read_req_nack(args \\ [])

read_req_nack(record, args)

read_req_options(args \\ [])

read_req_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_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_subscription_confirmation(args \\ [])

read_resp_subscription_confirmation(record, args)

replay_parked_req(args \\ [])

replay_parked_req(record, args)

replay_parked_req_options(args \\ [])

replay_parked_req_options(record, args)

replay_parked_resp(args \\ [])

replay_parked_resp(record, args)

service()

Returns the gRPC service name for the API

service_module()

Returns the :gpb-generated service module

subscription_info(args \\ [])

subscription_info(record, args)

subscription_info_connection_info(args \\ [])

subscription_info_connection_info(record, args)

subscription_info_measurement(args \\ [])

subscription_info_measurement(record, args)

update_req(args \\ [])

update_req(record, args)

update_req_all_options(args \\ [])

update_req_all_options(record, args)

update_req_options(args \\ [])

update_req_options(record, args)

update_req_position(args \\ [])

update_req_position(record, args)

update_req_settings(args \\ [])

update_req_settings(record, args)

update_req_stream_options(args \\ [])

update_req_stream_options(record, args)

update_resp(args \\ [])

update_resp(record, args)

Functions

create_req(args \\ [])

(macro)

create_req(record, args)

(macro)

create_req_all_options(args \\ [])

(macro)

create_req_all_options(record, args)

(macro)

create_req_all_options_filter_options(args \\ [])

(macro)

create_req_all_options_filter_options(record, args)

(macro)

create_req_all_options_filter_options_expression(args \\ [])

(macro)

create_req_all_options_filter_options_expression(record, args)

(macro)

create_req_options(args \\ [])

(macro)

create_req_options(record, args)

(macro)

create_req_position(args \\ [])

(macro)

create_req_position(record, args)

(macro)

create_req_settings(args \\ [])

(macro)

create_req_settings(record, args)

(macro)

create_req_stream_options(args \\ [])

(macro)

create_req_stream_options(record, args)

(macro)

create_resp(args \\ [])

(macro)

create_resp(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)

get_info_req(args \\ [])

(macro)

get_info_req(record, args)

(macro)

get_info_req_options(args \\ [])

(macro)

get_info_req_options(record, args)

(macro)

get_info_resp(args \\ [])

(macro)

get_info_resp(record, args)

(macro)

list_req(args \\ [])

(macro)

list_req(record, args)

(macro)

list_req_options(args \\ [])

(macro)

list_req_options(record, args)

(macro)

list_req_stream_option(args \\ [])

(macro)

list_req_stream_option(record, args)

(macro)

list_resp(args \\ [])

(macro)

list_resp(record, args)

(macro)

read_req(args \\ [])

(macro)

read_req(record, args)

(macro)

read_req_ack(args \\ [])

(macro)

read_req_ack(record, args)

(macro)

read_req_nack(args \\ [])

(macro)

read_req_nack(record, args)

(macro)

read_req_options(args \\ [])

(macro)

read_req_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_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_subscription_confirmation(args \\ [])

(macro)

read_resp_subscription_confirmation(record, args)

(macro)

replay_parked_req(args \\ [])

(macro)

replay_parked_req(record, args)

(macro)

replay_parked_req_options(args \\ [])

(macro)

replay_parked_req_options(record, args)

(macro)

replay_parked_resp(args \\ [])

(macro)

replay_parked_resp(record, args)

(macro)

service()

Returns the gRPC service name for the API

service_module()

Returns the :gpb-generated service module

subscription_info(args \\ [])

(macro)

subscription_info(record, args)

(macro)

subscription_info_connection_info(args \\ [])

(macro)

subscription_info_connection_info(record, args)

(macro)

subscription_info_measurement(args \\ [])

(macro)

subscription_info_measurement(record, args)

(macro)

update_req(args \\ [])

(macro)

update_req(record, args)

(macro)

update_req_all_options(args \\ [])

(macro)

update_req_all_options(record, args)

(macro)

update_req_options(args \\ [])

(macro)

update_req_options(record, args)

(macro)

update_req_position(args \\ [])

(macro)

update_req_position(record, args)

(macro)

update_req_settings(args \\ [])

(macro)

update_req_settings(record, args)

(macro)

update_req_stream_options(args \\ [])

(macro)

update_req_stream_options(record, args)

(macro)

update_resp(args \\ [])

(macro)

update_resp(record, args)

(macro)