eventstoredb.client.append_to_stream.grpc

Module Contents

Functions

create_append_header(stream_name, options)
create_append_request(event_data)
convert_append_response(stream_name, message)
convert_append_response_success(message)
convert_wrong_expected_version(stream_name, message)

eventstoredb.client.append_to_stream.grpc.create_append_header(stream_name, options)

Parameters:

• stream_name (str) –

• options (eventstoredb.client.append_to_stream.types.AppendToStreamOptions) –

Return type:

eventstoredb.generated.event_store.client.streams.AppendReq

eventstoredb.client.append_to_stream.grpc.create_append_request(event_data)

Parameters:

event_data (eventstoredb.events.EventData) –

Return type:

eventstoredb.generated.event_store.client.streams.AppendReq

eventstoredb.client.append_to_stream.grpc.convert_append_response(stream_name, message)

Parameters:

• stream_name (str) –

• message (eventstoredb.generated.event_store.client.streams.AppendResp) –

Return type:

eventstoredb.client.append_to_stream.types.AppendResult

eventstoredb.client.append_to_stream.grpc.convert_append_response_success(message)

Parameters:

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

Return type:

eventstoredb.client.append_to_stream.types.AppendResult

eventstoredb.client.append_to_stream.grpc.convert_wrong_expected_version(stream_name, message)

Parameters:

• stream_name (str) –

• message (eventstoredb.generated.event_store.client.streams.AppendRespWrongExpectedVersion) –

Return type:

eventstoredb.client.exceptions.StreamNotFoundError | eventstoredb.client.append_to_stream.exceptions.StreamAlreadyExistsError | eventstoredb.client.append_to_stream.exceptions.RevisionMismatchError