`eventstoredb.client.subscribe_to_persistent_subscription_to_stream.grpc`#

Module Contents#

`get_original_event_id`(event)
`create_read_request`(stream_name, group_name, options)
`create_ack_request`(events)
`create_nack_request`(action, reason, events)
`convert_read_response`(message)
`convert_read_response_event`(message)
`convert_read_response_recorded_event`(message)
`convert_read_response_confirmation`(message)

eventstoredb.client.subscribe_to_persistent_subscription_to_stream.grpc.get_original_event_id(event)[source]#

Parameters:: event (eventstoredb.events.PersistentSubscriptionEvent) –
Return type:: uuid.UUID | None

eventstoredb.client.subscribe_to_persistent_subscription_to_stream.grpc.create_read_request(stream_name, group_name, options)[source]#

Parameters:

stream_name (str) –
group_name (str) –
options (eventstoredb.client.subscribe_to_persistent_subscription_to_stream.types.SubscribeToPersistentSubscriptionToStreamOptions) –

Return type:

eventstoredb.client.subscribe_to_persistent_subscription_to_stream.grpc.create_ack_request(events)[source]#

Parameters:: events (eventstoredb.events.PersistentSubscriptionEvent | list[eventstoredb.events.PersistentSubscriptionEvent]) –
Return type:: eventstoredb.generated.event_store.client.persistent_subscriptions.ReadReq

eventstoredb.client.subscribe_to_persistent_subscription_to_stream.grpc.create_nack_request(action, reason, events)[source]#

Parameters:

action (eventstoredb.client.subscribe_to_persistent_subscription_to_stream.types.NackAction) –
reason (str) –
events (eventstoredb.events.PersistentSubscriptionEvent | list[eventstoredb.events.PersistentSubscriptionEvent]) –

Return type:

eventstoredb.client.subscribe_to_persistent_subscription_to_stream.grpc.convert_read_response(message)[source]#

Parameters:: message (eventstoredb.generated.event_store.client.persistent_subscriptions.ReadResp) –
Return type:: eventstoredb.client.subscribe_to_persistent_subscription_to_stream.types.PersistentSubscriptionConfirmation | eventstoredb.events.PersistentSubscriptionEvent

eventstoredb.client.subscribe_to_persistent_subscription_to_stream.grpc.convert_read_response_event(message)[source]#

Parameters:: message (eventstoredb.generated.event_store.client.persistent_subscriptions.ReadRespReadEvent) –
Return type:: eventstoredb.events.PersistentSubscriptionEvent

eventstoredb.client.subscribe_to_persistent_subscription_to_stream.grpc.convert_read_response_recorded_event(message)[source]#

Parameters:: message (eventstoredb.generated.event_store.client.persistent_subscriptions.ReadRespReadEventRecordedEvent) –
Return type:: eventstoredb.events.JsonRecordedEvent | eventstoredb.events.BinaryRecordedEvent

eventstoredb.client.subscribe_to_persistent_subscription_to_stream.grpc.convert_read_response_confirmation(message)[source]#

Parameters:: message (eventstoredb.generated.event_store.client.persistent_subscriptions.ReadRespSubscriptionConfirmation) –
Return type:: eventstoredb.client.subscribe_to_persistent_subscription_to_stream.types.PersistentSubscriptionConfirmation