eventstoredb.generated.event_store.client.streams#

Package Contents#

Classes#

ReadReqOptionsReadDirection

The base class for protobuf enumerations, all generated enumerations will inherit

ReadReq

The base class for protobuf messages, all generated messages will inherit from

ReadReqOptions

The base class for protobuf messages, all generated messages will inherit from

ReadReqOptionsStreamOptions

The base class for protobuf messages, all generated messages will inherit from

ReadReqOptionsAllOptions

The base class for protobuf messages, all generated messages will inherit from

ReadReqOptionsSubscriptionOptions

The base class for protobuf messages, all generated messages will inherit from

ReadReqOptionsPosition

The base class for protobuf messages, all generated messages will inherit from

ReadReqOptionsFilterOptions

The base class for protobuf messages, all generated messages will inherit from

ReadReqOptionsFilterOptionsExpression

The base class for protobuf messages, all generated messages will inherit from

ReadReqOptionsUuidOption

The base class for protobuf messages, all generated messages will inherit from

ReadReqOptionsControlOption

The base class for protobuf messages, all generated messages will inherit from

ReadResp

The base class for protobuf messages, all generated messages will inherit from

ReadRespCaughtUp

The base class for protobuf messages, all generated messages will inherit from

ReadRespFellBehind

The base class for protobuf messages, all generated messages will inherit from

ReadRespReadEvent

The base class for protobuf messages, all generated messages will inherit from

ReadRespReadEventRecordedEvent

The base class for protobuf messages, all generated messages will inherit from

ReadRespSubscriptionConfirmation

The base class for protobuf messages, all generated messages will inherit from

ReadRespCheckpoint

The base class for protobuf messages, all generated messages will inherit from

ReadRespStreamNotFound

The base class for protobuf messages, all generated messages will inherit from

AppendReq

The base class for protobuf messages, all generated messages will inherit from

AppendReqOptions

The base class for protobuf messages, all generated messages will inherit from

AppendReqProposedMessage

The base class for protobuf messages, all generated messages will inherit from

AppendResp

The base class for protobuf messages, all generated messages will inherit from

AppendRespPosition

The base class for protobuf messages, all generated messages will inherit from

AppendRespSuccess

The base class for protobuf messages, all generated messages will inherit from

AppendRespWrongExpectedVersion

The base class for protobuf messages, all generated messages will inherit from

BatchAppendReq

The base class for protobuf messages, all generated messages will inherit from

BatchAppendReqOptions

The base class for protobuf messages, all generated messages will inherit from

BatchAppendReqProposedMessage

The base class for protobuf messages, all generated messages will inherit from

BatchAppendResp

The base class for protobuf messages, all generated messages will inherit from

BatchAppendRespSuccess

The base class for protobuf messages, all generated messages will inherit from

DeleteReq

The base class for protobuf messages, all generated messages will inherit from

DeleteReqOptions

The base class for protobuf messages, all generated messages will inherit from

DeleteResp

The base class for protobuf messages, all generated messages will inherit from

DeleteRespPosition

The base class for protobuf messages, all generated messages will inherit from

TombstoneReq

The base class for protobuf messages, all generated messages will inherit from

TombstoneReqOptions

The base class for protobuf messages, all generated messages will inherit from

TombstoneResp

The base class for protobuf messages, all generated messages will inherit from

TombstoneRespPosition

The base class for protobuf messages, all generated messages will inherit from

StreamsStub

Base class for async gRPC clients.

StreamsBase

Base class for async gRPC servers.

class eventstoredb.generated.event_store.client.streams.ReadReqOptionsReadDirection[source]#

Bases: betterproto.Enum

The base class for protobuf enumerations, all generated enumerations will inherit from this. Bases enum.IntEnum.

Forwards = 0#
Backwards = 1#
class eventstoredb.generated.event_store.client.streams.ReadReq[source]#

Bases: betterproto.Message

The base class for protobuf messages, all generated messages will inherit from this. This class registers the message fields which are used by the serializers and parsers to go between the Python, binary and JSON representations of the message.

bytes(x)

Calls __bytes__().

bool(x)

Calls __bool__().

options: ReadReqOptions#
class eventstoredb.generated.event_store.client.streams.ReadReqOptions[source]#

Bases: betterproto.Message

The base class for protobuf messages, all generated messages will inherit from this. This class registers the message fields which are used by the serializers and parsers to go between the Python, binary and JSON representations of the message.

bytes(x)

Calls __bytes__().

bool(x)

Calls __bool__().

stream: ReadReqOptionsStreamOptions#
all: ReadReqOptionsAllOptions#
read_direction: ReadReqOptionsReadDirection#
count: int#
subscription: ReadReqOptionsSubscriptionOptions#
filter: ReadReqOptionsFilterOptions#
no_filter: eventstoredb.generated.event_store.client.Empty#
uuid_option: ReadReqOptionsUuidOption#
control_option: ReadReqOptionsControlOption#
class eventstoredb.generated.event_store.client.streams.ReadReqOptionsStreamOptions[source]#

Bases: betterproto.Message

The base class for protobuf messages, all generated messages will inherit from this. This class registers the message fields which are used by the serializers and parsers to go between the Python, binary and JSON representations of the message.

bytes(x)

Calls __bytes__().

bool(x)

Calls __bool__().

stream_identifier: eventstoredb.generated.event_store.client.StreamIdentifier#
revision: int#
start: eventstoredb.generated.event_store.client.Empty#
end: eventstoredb.generated.event_store.client.Empty#
class eventstoredb.generated.event_store.client.streams.ReadReqOptionsAllOptions[source]#

Bases: betterproto.Message

The base class for protobuf messages, all generated messages will inherit from this. This class registers the message fields which are used by the serializers and parsers to go between the Python, binary and JSON representations of the message.

bytes(x)

Calls __bytes__().

bool(x)

Calls __bool__().

position: ReadReqOptionsPosition#
start: eventstoredb.generated.event_store.client.Empty#
end: eventstoredb.generated.event_store.client.Empty#
class eventstoredb.generated.event_store.client.streams.ReadReqOptionsSubscriptionOptions[source]#

Bases: betterproto.Message

The base class for protobuf messages, all generated messages will inherit from this. This class registers the message fields which are used by the serializers and parsers to go between the Python, binary and JSON representations of the message.

bytes(x)

Calls __bytes__().

bool(x)

Calls __bool__().

class eventstoredb.generated.event_store.client.streams.ReadReqOptionsPosition[source]#

Bases: betterproto.Message

The base class for protobuf messages, all generated messages will inherit from this. This class registers the message fields which are used by the serializers and parsers to go between the Python, binary and JSON representations of the message.

bytes(x)

Calls __bytes__().

bool(x)

Calls __bool__().

commit_position: int#
prepare_position: int#
class eventstoredb.generated.event_store.client.streams.ReadReqOptionsFilterOptions[source]#

Bases: betterproto.Message

The base class for protobuf messages, all generated messages will inherit from this. This class registers the message fields which are used by the serializers and parsers to go between the Python, binary and JSON representations of the message.

bytes(x)

Calls __bytes__().

bool(x)

Calls __bool__().

stream_identifier: ReadReqOptionsFilterOptionsExpression#
event_type: ReadReqOptionsFilterOptionsExpression#
max: int#
count: eventstoredb.generated.event_store.client.Empty#
checkpoint_interval_multiplier: int#
class eventstoredb.generated.event_store.client.streams.ReadReqOptionsFilterOptionsExpression[source]#

Bases: betterproto.Message

The base class for protobuf messages, all generated messages will inherit from this. This class registers the message fields which are used by the serializers and parsers to go between the Python, binary and JSON representations of the message.

bytes(x)

Calls __bytes__().

bool(x)

Calls __bool__().

regex: str#
prefix: List[str]#
class eventstoredb.generated.event_store.client.streams.ReadReqOptionsUuidOption[source]#

Bases: betterproto.Message

The base class for protobuf messages, all generated messages will inherit from this. This class registers the message fields which are used by the serializers and parsers to go between the Python, binary and JSON representations of the message.

bytes(x)

Calls __bytes__().

bool(x)

Calls __bool__().

structured: eventstoredb.generated.event_store.client.Empty#
string: eventstoredb.generated.event_store.client.Empty#
class eventstoredb.generated.event_store.client.streams.ReadReqOptionsControlOption[source]#

Bases: betterproto.Message

The base class for protobuf messages, all generated messages will inherit from this. This class registers the message fields which are used by the serializers and parsers to go between the Python, binary and JSON representations of the message.

bytes(x)

Calls __bytes__().

bool(x)

Calls __bool__().

compatibility: int#
class eventstoredb.generated.event_store.client.streams.ReadResp[source]#

Bases: betterproto.Message

The base class for protobuf messages, all generated messages will inherit from this. This class registers the message fields which are used by the serializers and parsers to go between the Python, binary and JSON representations of the message.

bytes(x)

Calls __bytes__().

bool(x)

Calls __bool__().

event: ReadRespReadEvent#
confirmation: ReadRespSubscriptionConfirmation#
checkpoint: ReadRespCheckpoint#
stream_not_found: ReadRespStreamNotFound#
first_stream_position: int#
last_stream_position: int#
last_all_stream_position: eventstoredb.generated.event_store.client.AllStreamPosition#
caught_up: ReadRespCaughtUp#
fell_behind: ReadRespFellBehind#
class eventstoredb.generated.event_store.client.streams.ReadRespCaughtUp[source]#

Bases: betterproto.Message

The base class for protobuf messages, all generated messages will inherit from this. This class registers the message fields which are used by the serializers and parsers to go between the Python, binary and JSON representations of the message.

bytes(x)

Calls __bytes__().

bool(x)

Calls __bool__().

class eventstoredb.generated.event_store.client.streams.ReadRespFellBehind[source]#

Bases: betterproto.Message

The base class for protobuf messages, all generated messages will inherit from this. This class registers the message fields which are used by the serializers and parsers to go between the Python, binary and JSON representations of the message.

bytes(x)

Calls __bytes__().

bool(x)

Calls __bool__().

class eventstoredb.generated.event_store.client.streams.ReadRespReadEvent[source]#

Bases: betterproto.Message

The base class for protobuf messages, all generated messages will inherit from this. This class registers the message fields which are used by the serializers and parsers to go between the Python, binary and JSON representations of the message.

bytes(x)

Calls __bytes__().

bool(x)

Calls __bool__().

event: ReadRespReadEventRecordedEvent#
commit_position: int#
no_position: eventstoredb.generated.event_store.client.Empty#
class eventstoredb.generated.event_store.client.streams.ReadRespReadEventRecordedEvent[source]#

Bases: betterproto.Message

The base class for protobuf messages, all generated messages will inherit from this. This class registers the message fields which are used by the serializers and parsers to go between the Python, binary and JSON representations of the message.

bytes(x)

Calls __bytes__().

bool(x)

Calls __bool__().

id: eventstoredb.generated.event_store.client.Uuid#
stream_identifier: eventstoredb.generated.event_store.client.StreamIdentifier#
stream_revision: int#
prepare_position: int#
commit_position: int#
metadata: Dict[str, str]#
custom_metadata: bytes#
data: bytes#
class eventstoredb.generated.event_store.client.streams.ReadRespSubscriptionConfirmation[source]#

Bases: betterproto.Message

The base class for protobuf messages, all generated messages will inherit from this. This class registers the message fields which are used by the serializers and parsers to go between the Python, binary and JSON representations of the message.

bytes(x)

Calls __bytes__().

bool(x)

Calls __bool__().

subscription_id: str#
class eventstoredb.generated.event_store.client.streams.ReadRespCheckpoint[source]#

Bases: betterproto.Message

The base class for protobuf messages, all generated messages will inherit from this. This class registers the message fields which are used by the serializers and parsers to go between the Python, binary and JSON representations of the message.

bytes(x)

Calls __bytes__().

bool(x)

Calls __bool__().

commit_position: int#
prepare_position: int#
class eventstoredb.generated.event_store.client.streams.ReadRespStreamNotFound[source]#

Bases: betterproto.Message

The base class for protobuf messages, all generated messages will inherit from this. This class registers the message fields which are used by the serializers and parsers to go between the Python, binary and JSON representations of the message.

bytes(x)

Calls __bytes__().

bool(x)

Calls __bool__().

stream_identifier: eventstoredb.generated.event_store.client.StreamIdentifier#
class eventstoredb.generated.event_store.client.streams.AppendReq[source]#

Bases: betterproto.Message

The base class for protobuf messages, all generated messages will inherit from this. This class registers the message fields which are used by the serializers and parsers to go between the Python, binary and JSON representations of the message.

bytes(x)

Calls __bytes__().

bool(x)

Calls __bool__().

options: AppendReqOptions#
proposed_message: AppendReqProposedMessage#
class eventstoredb.generated.event_store.client.streams.AppendReqOptions[source]#

Bases: betterproto.Message

The base class for protobuf messages, all generated messages will inherit from this. This class registers the message fields which are used by the serializers and parsers to go between the Python, binary and JSON representations of the message.

bytes(x)

Calls __bytes__().

bool(x)

Calls __bool__().

stream_identifier: eventstoredb.generated.event_store.client.StreamIdentifier#
revision: int#
no_stream: eventstoredb.generated.event_store.client.Empty#
any: eventstoredb.generated.event_store.client.Empty#
stream_exists: eventstoredb.generated.event_store.client.Empty#
class eventstoredb.generated.event_store.client.streams.AppendReqProposedMessage[source]#

Bases: betterproto.Message

The base class for protobuf messages, all generated messages will inherit from this. This class registers the message fields which are used by the serializers and parsers to go between the Python, binary and JSON representations of the message.

bytes(x)

Calls __bytes__().

bool(x)

Calls __bool__().

id: eventstoredb.generated.event_store.client.Uuid#
metadata: Dict[str, str]#
custom_metadata: bytes#
data: bytes#
class eventstoredb.generated.event_store.client.streams.AppendResp[source]#

Bases: betterproto.Message

The base class for protobuf messages, all generated messages will inherit from this. This class registers the message fields which are used by the serializers and parsers to go between the Python, binary and JSON representations of the message.

bytes(x)

Calls __bytes__().

bool(x)

Calls __bool__().

success: AppendRespSuccess#
wrong_expected_version: AppendRespWrongExpectedVersion#
class eventstoredb.generated.event_store.client.streams.AppendRespPosition[source]#

Bases: betterproto.Message

The base class for protobuf messages, all generated messages will inherit from this. This class registers the message fields which are used by the serializers and parsers to go between the Python, binary and JSON representations of the message.

bytes(x)

Calls __bytes__().

bool(x)

Calls __bool__().

commit_position: int#
prepare_position: int#
class eventstoredb.generated.event_store.client.streams.AppendRespSuccess[source]#

Bases: betterproto.Message

The base class for protobuf messages, all generated messages will inherit from this. This class registers the message fields which are used by the serializers and parsers to go between the Python, binary and JSON representations of the message.

bytes(x)

Calls __bytes__().

bool(x)

Calls __bool__().

current_revision: int#
no_stream: eventstoredb.generated.event_store.client.Empty#
position: AppendRespPosition#
no_position: eventstoredb.generated.event_store.client.Empty#
class eventstoredb.generated.event_store.client.streams.AppendRespWrongExpectedVersion[source]#

Bases: betterproto.Message

The base class for protobuf messages, all generated messages will inherit from this. This class registers the message fields which are used by the serializers and parsers to go between the Python, binary and JSON representations of the message.

bytes(x)

Calls __bytes__().

bool(x)

Calls __bool__().

current_revision_20_6_0: int#
no_stream_20_6_0: eventstoredb.generated.event_store.client.Empty#
expected_revision_20_6_0: int#
any_20_6_0: eventstoredb.generated.event_store.client.Empty#
stream_exists_20_6_0: eventstoredb.generated.event_store.client.Empty#
current_revision: int#
current_no_stream: eventstoredb.generated.event_store.client.Empty#
expected_revision: int#
expected_any: eventstoredb.generated.event_store.client.Empty#
expected_stream_exists: eventstoredb.generated.event_store.client.Empty#
expected_no_stream: eventstoredb.generated.event_store.client.Empty#
class eventstoredb.generated.event_store.client.streams.BatchAppendReq[source]#

Bases: betterproto.Message

The base class for protobuf messages, all generated messages will inherit from this. This class registers the message fields which are used by the serializers and parsers to go between the Python, binary and JSON representations of the message.

bytes(x)

Calls __bytes__().

bool(x)

Calls __bool__().

correlation_id: eventstoredb.generated.event_store.client.Uuid#
options: BatchAppendReqOptions#
proposed_messages: List[BatchAppendReqProposedMessage]#
is_final: bool#
class eventstoredb.generated.event_store.client.streams.BatchAppendReqOptions[source]#

Bases: betterproto.Message

The base class for protobuf messages, all generated messages will inherit from this. This class registers the message fields which are used by the serializers and parsers to go between the Python, binary and JSON representations of the message.

bytes(x)

Calls __bytes__().

bool(x)

Calls __bool__().

stream_identifier: eventstoredb.generated.event_store.client.StreamIdentifier#
stream_position: int#
no_stream: betterproto.lib.google.protobuf.Empty#
any: betterproto.lib.google.protobuf.Empty#
stream_exists: betterproto.lib.google.protobuf.Empty#
deadline_21_10_0: datetime.datetime#
deadline: datetime.timedelta#
class eventstoredb.generated.event_store.client.streams.BatchAppendReqProposedMessage[source]#

Bases: betterproto.Message

The base class for protobuf messages, all generated messages will inherit from this. This class registers the message fields which are used by the serializers and parsers to go between the Python, binary and JSON representations of the message.

bytes(x)

Calls __bytes__().

bool(x)

Calls __bool__().

id: eventstoredb.generated.event_store.client.Uuid#
metadata: Dict[str, str]#
custom_metadata: bytes#
data: bytes#
class eventstoredb.generated.event_store.client.streams.BatchAppendResp[source]#

Bases: betterproto.Message

The base class for protobuf messages, all generated messages will inherit from this. This class registers the message fields which are used by the serializers and parsers to go between the Python, binary and JSON representations of the message.

bytes(x)

Calls __bytes__().

bool(x)

Calls __bool__().

correlation_id: eventstoredb.generated.event_store.client.Uuid#
error: eventstoredb.generated.google.rpc.Status#
success: BatchAppendRespSuccess#
stream_identifier: eventstoredb.generated.event_store.client.StreamIdentifier#
stream_position: int#
no_stream: betterproto.lib.google.protobuf.Empty#
any: betterproto.lib.google.protobuf.Empty#
stream_exists: betterproto.lib.google.protobuf.Empty#
class eventstoredb.generated.event_store.client.streams.BatchAppendRespSuccess[source]#

Bases: betterproto.Message

The base class for protobuf messages, all generated messages will inherit from this. This class registers the message fields which are used by the serializers and parsers to go between the Python, binary and JSON representations of the message.

bytes(x)

Calls __bytes__().

bool(x)

Calls __bool__().

current_revision: int#
no_stream: betterproto.lib.google.protobuf.Empty#
position: eventstoredb.generated.event_store.client.AllStreamPosition#
no_position: betterproto.lib.google.protobuf.Empty#
class eventstoredb.generated.event_store.client.streams.DeleteReq[source]#

Bases: betterproto.Message

The base class for protobuf messages, all generated messages will inherit from this. This class registers the message fields which are used by the serializers and parsers to go between the Python, binary and JSON representations of the message.

bytes(x)

Calls __bytes__().

bool(x)

Calls __bool__().

options: DeleteReqOptions#
class eventstoredb.generated.event_store.client.streams.DeleteReqOptions[source]#

Bases: betterproto.Message

The base class for protobuf messages, all generated messages will inherit from this. This class registers the message fields which are used by the serializers and parsers to go between the Python, binary and JSON representations of the message.

bytes(x)

Calls __bytes__().

bool(x)

Calls __bool__().

stream_identifier: eventstoredb.generated.event_store.client.StreamIdentifier#
revision: int#
no_stream: eventstoredb.generated.event_store.client.Empty#
any: eventstoredb.generated.event_store.client.Empty#
stream_exists: eventstoredb.generated.event_store.client.Empty#
class eventstoredb.generated.event_store.client.streams.DeleteResp[source]#

Bases: betterproto.Message

The base class for protobuf messages, all generated messages will inherit from this. This class registers the message fields which are used by the serializers and parsers to go between the Python, binary and JSON representations of the message.

bytes(x)

Calls __bytes__().

bool(x)

Calls __bool__().

position: DeleteRespPosition#
no_position: eventstoredb.generated.event_store.client.Empty#
class eventstoredb.generated.event_store.client.streams.DeleteRespPosition[source]#

Bases: betterproto.Message

The base class for protobuf messages, all generated messages will inherit from this. This class registers the message fields which are used by the serializers and parsers to go between the Python, binary and JSON representations of the message.

bytes(x)

Calls __bytes__().

bool(x)

Calls __bool__().

commit_position: int#
prepare_position: int#
class eventstoredb.generated.event_store.client.streams.TombstoneReq[source]#

Bases: betterproto.Message

The base class for protobuf messages, all generated messages will inherit from this. This class registers the message fields which are used by the serializers and parsers to go between the Python, binary and JSON representations of the message.

bytes(x)

Calls __bytes__().

bool(x)

Calls __bool__().

options: TombstoneReqOptions#
class eventstoredb.generated.event_store.client.streams.TombstoneReqOptions[source]#

Bases: betterproto.Message

The base class for protobuf messages, all generated messages will inherit from this. This class registers the message fields which are used by the serializers and parsers to go between the Python, binary and JSON representations of the message.

bytes(x)

Calls __bytes__().

bool(x)

Calls __bool__().

stream_identifier: eventstoredb.generated.event_store.client.StreamIdentifier#
revision: int#
no_stream: eventstoredb.generated.event_store.client.Empty#
any: eventstoredb.generated.event_store.client.Empty#
stream_exists: eventstoredb.generated.event_store.client.Empty#
class eventstoredb.generated.event_store.client.streams.TombstoneResp[source]#

Bases: betterproto.Message

The base class for protobuf messages, all generated messages will inherit from this. This class registers the message fields which are used by the serializers and parsers to go between the Python, binary and JSON representations of the message.

bytes(x)

Calls __bytes__().

bool(x)

Calls __bool__().

position: TombstoneRespPosition#
no_position: eventstoredb.generated.event_store.client.Empty#
class eventstoredb.generated.event_store.client.streams.TombstoneRespPosition[source]#

Bases: betterproto.Message

The base class for protobuf messages, all generated messages will inherit from this. This class registers the message fields which are used by the serializers and parsers to go between the Python, binary and JSON representations of the message.

bytes(x)

Calls __bytes__().

bool(x)

Calls __bool__().

commit_position: int#
prepare_position: int#
class eventstoredb.generated.event_store.client.streams.StreamsStub(channel, *, timeout=None, deadline=None, metadata=None)[source]#

Bases: betterproto.ServiceStub

Base class for async gRPC clients.

Parameters:
  • channel (grpclib.client.Channel) –

  • timeout (Optional[float]) –

  • deadline (Optional[grpclib.metadata.Deadline]) –

  • metadata (Optional[MetadataLike]) –

async read(read_req, *, timeout=None, deadline=None, metadata=None)[source]#
Parameters:
  • read_req (ReadReq) –

  • timeout (Optional[float]) –

  • deadline (Optional[grpclib.metadata.Deadline]) –

  • metadata (Optional[betterproto.grpc.grpclib_client.MetadataLike]) –

Return type:

AsyncIterator[ReadResp]

async append(append_req_iterator, *, timeout=None, deadline=None, metadata=None)[source]#
Parameters:
  • append_req_iterator (Union[AsyncIterable[AppendReq], Iterable[AppendReq]]) –

  • timeout (Optional[float]) –

  • deadline (Optional[grpclib.metadata.Deadline]) –

  • metadata (Optional[betterproto.grpc.grpclib_client.MetadataLike]) –

Return type:

AppendResp

async delete(delete_req, *, timeout=None, deadline=None, metadata=None)[source]#
Parameters:
  • delete_req (DeleteReq) –

  • timeout (Optional[float]) –

  • deadline (Optional[grpclib.metadata.Deadline]) –

  • metadata (Optional[betterproto.grpc.grpclib_client.MetadataLike]) –

Return type:

DeleteResp

async tombstone(tombstone_req, *, timeout=None, deadline=None, metadata=None)[source]#
Parameters:
  • tombstone_req (TombstoneReq) –

  • timeout (Optional[float]) –

  • deadline (Optional[grpclib.metadata.Deadline]) –

  • metadata (Optional[betterproto.grpc.grpclib_client.MetadataLike]) –

Return type:

TombstoneResp

async batch_append(batch_append_req_iterator, *, timeout=None, deadline=None, metadata=None)[source]#
Parameters:
  • batch_append_req_iterator (Union[AsyncIterable[BatchAppendReq], Iterable[BatchAppendReq]]) –

  • timeout (Optional[float]) –

  • deadline (Optional[grpclib.metadata.Deadline]) –

  • metadata (Optional[betterproto.grpc.grpclib_client.MetadataLike]) –

Return type:

AsyncIterator[BatchAppendResp]

class eventstoredb.generated.event_store.client.streams.StreamsBase[source]#

Bases: betterproto.grpc.grpclib_server.ServiceBase

Base class for async gRPC servers.

async read(read_req)[source]#
Parameters:

read_req (ReadReq) –

Return type:

AsyncIterator[ReadResp]

async append(append_req_iterator)[source]#
Parameters:

append_req_iterator (AsyncIterator[AppendReq]) –

Return type:

AppendResp

async delete(delete_req)[source]#
Parameters:

delete_req (DeleteReq) –

Return type:

DeleteResp

async tombstone(tombstone_req)[source]#
Parameters:

tombstone_req (TombstoneReq) –

Return type:

TombstoneResp

async batch_append(batch_append_req_iterator)[source]#
Parameters:

batch_append_req_iterator (AsyncIterator[BatchAppendReq]) –

Return type:

AsyncIterator[BatchAppendResp]

__mapping__()[source]#
Return type:

Dict[str, grpclib.const.Handler]