eventstoredb.client.subscribe_to_all.grpc#

Module Contents#

Functions#

create_subscribe_to_all_request(options)

convert_subscribe_to_all_response(message)

convert_read_response_checkpoint(message)

eventstoredb.client.subscribe_to_all.grpc.create_subscribe_to_all_request(options)[source]#
Parameters:

options (eventstoredb.client.subscribe_to_all.types.SubscribeToAllOptions) –

Return type:

eventstoredb.generated.event_store.client.streams.ReadReq

eventstoredb.client.subscribe_to_all.grpc.convert_subscribe_to_all_response(message)[source]#
Parameters:

message (eventstoredb.generated.event_store.client.streams.ReadResp) –

Return type:

eventstoredb.events.ReadEvent | eventstoredb.events.CaughtUp | eventstoredb.events.FellBehind | eventstoredb.client.subscribe_to_stream.types.SubscriptionConfirmation | eventstoredb.client.subscribe_to_all.types.Checkpoint

eventstoredb.client.subscribe_to_all.grpc.convert_read_response_checkpoint(message)[source]#
Parameters:

message (eventstoredb.generated.event_store.client.streams.ReadRespCheckpoint) –

Return type:

eventstoredb.client.subscribe_to_all.types.Checkpoint