eventstoredb.generated.event_store.client.redaction#

Package Contents#

Classes#

GetEventPositionReq

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

GetEventPositionResp

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

EventPosition

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

ChunkInfo

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

SwitchChunkReq

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

SwitchChunkResp

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

RedactionStub

Base class for async gRPC clients.

RedactionBase

Base class for async gRPC servers.
class eventstoredb.generated.event_store.client.redaction.GetEventPositionReq[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_revision: int#
class eventstoredb.generated.event_store.client.redaction.GetEventPositionResp[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_positions: List[EventPosition]#
class eventstoredb.generated.event_store.client.redaction.EventPosition[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__().

log_position: int#
chunk_info: ChunkInfo#
class eventstoredb.generated.event_store.client.redaction.ChunkInfo[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__().

file_name: str#
version: int#
is_complete: bool#
event_offset: int#
class eventstoredb.generated.event_store.client.redaction.SwitchChunkReq[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__().

target_chunk_file: str#
new_chunk_file: str#
class eventstoredb.generated.event_store.client.redaction.SwitchChunkResp[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.redaction.RedactionStub(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 get_event_positions(get_event_position_req_iterator, *, timeout=None, deadline=None, metadata=None)[source]#
Parameters:

  • get_event_position_req_iterator (Union[AsyncIterable[GetEventPositionReq], Iterable[GetEventPositionReq]]) –

  • timeout (Optional[float]) –

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

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

Return type:

AsyncIterator[GetEventPositionResp]

async switch_chunks(switch_chunk_req_iterator, *, timeout=None, deadline=None, metadata=None)[source]#
Parameters:

  • switch_chunk_req_iterator (Union[AsyncIterable[SwitchChunkReq], Iterable[SwitchChunkReq]]) –

  • timeout (Optional[float]) –

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

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

Return type:

AsyncIterator[SwitchChunkResp]

class eventstoredb.generated.event_store.client.redaction.RedactionBase[source]#

Bases: betterproto.grpc.grpclib_server.ServiceBase

Base class for async gRPC servers.

async get_event_positions(get_event_position_req_iterator)[source]#
Parameters:

get_event_position_req_iterator (AsyncIterator[GetEventPositionReq]) –

Return type:

AsyncIterator[GetEventPositionResp]

async switch_chunks(switch_chunk_req_iterator)[source]#
Parameters:

switch_chunk_req_iterator (AsyncIterator[SwitchChunkReq]) –

Return type:

AsyncIterator[SwitchChunkResp]

__mapping__()[source]#
Return type:

Dict[str, grpclib.const.Handler]