eventstoredb.client.read_stream.grpc

Module Contents

Functions

create_read_request(stream_name, options)
convert_read_response(message)
convert_read_response_read_event(message)
convert_read_response_recorded_event(message)

eventstoredb.client.read_stream.grpc.create_read_request(stream_name, options)

Parameters:

• stream_name (str) –

• options (eventstoredb.client.read_stream.types.ReadStreamOptions) –

Return type:

eventstoredb.generated.event_store.client.streams.ReadReq

eventstoredb.client.read_stream.grpc.convert_read_response(message)

Parameters:

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

Return type:

eventstoredb.events.ReadEvent | eventstoredb.events.CaughtUp | eventstoredb.events.FellBehind

eventstoredb.client.read_stream.grpc.convert_read_response_read_event(message)

Parameters:

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

Return type:

eventstoredb.events.ReadEvent

eventstoredb.client.read_stream.grpc.convert_read_response_recorded_event(message)

Parameters:

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

Return type:

eventstoredb.events.JsonRecordedEvent | eventstoredb.events.BinaryRecordedEvent