eventstoredb.generated.event_store.client.persistent_subscriptions

Package Contents

Classes

ReadReqNackAction	The base class for protobuf enumerations, all generated enumerations will inherit
CreateReqConsumerStrategy	The base class for protobuf enumerations, all generated enumerations will inherit
UpdateReqConsumerStrategy	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
ReadReqOptionsUuidOption	The base class for protobuf messages, all generated messages will inherit from
ReadReqAck	The base class for protobuf messages, all generated messages will inherit from
ReadReqNack	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
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
CreateReq	The base class for protobuf messages, all generated messages will inherit from
CreateReqOptions	The base class for protobuf messages, all generated messages will inherit from
CreateReqStreamOptions	The base class for protobuf messages, all generated messages will inherit from
CreateReqAllOptions	The base class for protobuf messages, all generated messages will inherit from
CreateReqAllOptionsFilterOptions	The base class for protobuf messages, all generated messages will inherit from
CreateReqAllOptionsFilterOptionsExpression	The base class for protobuf messages, all generated messages will inherit from
CreateReqPosition	The base class for protobuf messages, all generated messages will inherit from
CreateReqSettings	The base class for protobuf messages, all generated messages will inherit from
CreateResp	The base class for protobuf messages, all generated messages will inherit from
UpdateReq	The base class for protobuf messages, all generated messages will inherit from
UpdateReqOptions	The base class for protobuf messages, all generated messages will inherit from
UpdateReqStreamOptions	The base class for protobuf messages, all generated messages will inherit from
UpdateReqAllOptions	The base class for protobuf messages, all generated messages will inherit from
UpdateReqPosition	The base class for protobuf messages, all generated messages will inherit from
UpdateReqSettings	The base class for protobuf messages, all generated messages will inherit from
UpdateResp	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
GetInfoReq	The base class for protobuf messages, all generated messages will inherit from
GetInfoReqOptions	The base class for protobuf messages, all generated messages will inherit from
GetInfoResp	The base class for protobuf messages, all generated messages will inherit from
SubscriptionInfo	The base class for protobuf messages, all generated messages will inherit from
SubscriptionInfoConnectionInfo	The base class for protobuf messages, all generated messages will inherit from
SubscriptionInfoMeasurement	The base class for protobuf messages, all generated messages will inherit from
ReplayParkedReq	The base class for protobuf messages, all generated messages will inherit from
ReplayParkedReqOptions	The base class for protobuf messages, all generated messages will inherit from
ReplayParkedResp	The base class for protobuf messages, all generated messages will inherit from
ListReq	The base class for protobuf messages, all generated messages will inherit from
ListReqOptions	The base class for protobuf messages, all generated messages will inherit from
ListReqStreamOption	The base class for protobuf messages, all generated messages will inherit from
ListResp	The base class for protobuf messages, all generated messages will inherit from
PersistentSubscriptionsStub	Base class for async gRPC clients.
PersistentSubscriptionsBase	Base class for async gRPC servers.

class eventstoredb.generated.event_store.client.persistent_subscriptions.ReadReqNackAction

Bases: betterproto.Enum

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

Unknown = 0

Park = 1

Retry = 2

Skip = 3

Stop = 4

class eventstoredb.generated.event_store.client.persistent_subscriptions.CreateReqConsumerStrategy

Bases: betterproto.Enum

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

DispatchToSingle = 0

RoundRobin = 1

Pinned = 2

class eventstoredb.generated.event_store.client.persistent_subscriptions.UpdateReqConsumerStrategy

Bases: betterproto.Enum

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

DispatchToSingle = 0

RoundRobin = 1

Pinned = 2

class eventstoredb.generated.event_store.client.persistent_subscriptions.ReadReq

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

ack: ReadReqAck

nack: ReadReqNack

class eventstoredb.generated.event_store.client.persistent_subscriptions.ReadReqOptions

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

all: eventstoredb.generated.event_store.client.Empty

group_name: str

buffer_size: int

uuid_option: ReadReqOptionsUuidOption

class eventstoredb.generated.event_store.client.persistent_subscriptions.ReadReqOptionsUuidOption

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.persistent_subscriptions.ReadReqAck

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: bytes

ids: List[eventstoredb.generated.event_store.client.Uuid]

class eventstoredb.generated.event_store.client.persistent_subscriptions.ReadReqNack

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: bytes

ids: List[eventstoredb.generated.event_store.client.Uuid]

action: ReadReqNackAction

reason: str

class eventstoredb.generated.event_store.client.persistent_subscriptions.ReadResp

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

subscription_confirmation: ReadRespSubscriptionConfirmation

class eventstoredb.generated.event_store.client.persistent_subscriptions.ReadRespReadEvent

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

link: ReadRespReadEventRecordedEvent

commit_position: int

no_position: eventstoredb.generated.event_store.client.Empty

retry_count: int

no_retry_count: eventstoredb.generated.event_store.client.Empty

class eventstoredb.generated.event_store.client.persistent_subscriptions.ReadRespReadEventRecordedEvent

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.persistent_subscriptions.ReadRespSubscriptionConfirmation

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.persistent_subscriptions.CreateReq

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: CreateReqOptions

class eventstoredb.generated.event_store.client.persistent_subscriptions.CreateReqOptions

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: CreateReqStreamOptions

all: CreateReqAllOptions

stream_identifier: eventstoredb.generated.event_store.client.StreamIdentifier

group_name: str

settings: CreateReqSettings

__post_init__()

Return type:

None

class eventstoredb.generated.event_store.client.persistent_subscriptions.CreateReqStreamOptions

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.persistent_subscriptions.CreateReqAllOptions

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: CreateReqPosition

start: eventstoredb.generated.event_store.client.Empty

end: eventstoredb.generated.event_store.client.Empty

filter: CreateReqAllOptionsFilterOptions

no_filter: eventstoredb.generated.event_store.client.Empty

class eventstoredb.generated.event_store.client.persistent_subscriptions.CreateReqAllOptionsFilterOptions

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: CreateReqAllOptionsFilterOptionsExpression

event_type: CreateReqAllOptionsFilterOptionsExpression

max: int

count: eventstoredb.generated.event_store.client.Empty

checkpoint_interval_multiplier: int

class eventstoredb.generated.event_store.client.persistent_subscriptions.CreateReqAllOptionsFilterOptionsExpression

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.persistent_subscriptions.CreateReqPosition

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.persistent_subscriptions.CreateReqSettings

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__().

resolve_links: bool

revision: int

extra_statistics: bool

max_retry_count: int

min_checkpoint_count: int

max_checkpoint_count: int

max_subscriber_count: int

live_buffer_size: int

read_batch_size: int

history_buffer_size: int

named_consumer_strategy: CreateReqConsumerStrategy

message_timeout_ticks: int

message_timeout_ms: int

checkpoint_after_ticks: int

checkpoint_after_ms: int

consumer_strategy: str

__post_init__()

Return type:

None

class eventstoredb.generated.event_store.client.persistent_subscriptions.CreateResp

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.persistent_subscriptions.UpdateReq

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: UpdateReqOptions

class eventstoredb.generated.event_store.client.persistent_subscriptions.UpdateReqOptions

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: UpdateReqStreamOptions

all: UpdateReqAllOptions

stream_identifier: eventstoredb.generated.event_store.client.StreamIdentifier

group_name: str

settings: UpdateReqSettings

__post_init__()

Return type:

None

class eventstoredb.generated.event_store.client.persistent_subscriptions.UpdateReqStreamOptions

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.persistent_subscriptions.UpdateReqAllOptions

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: UpdateReqPosition

start: eventstoredb.generated.event_store.client.Empty

end: eventstoredb.generated.event_store.client.Empty

class eventstoredb.generated.event_store.client.persistent_subscriptions.UpdateReqPosition

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.persistent_subscriptions.UpdateReqSettings

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__().

resolve_links: bool

revision: int

extra_statistics: bool

max_retry_count: int

min_checkpoint_count: int

max_checkpoint_count: int

max_subscriber_count: int

live_buffer_size: int

read_batch_size: int

history_buffer_size: int

named_consumer_strategy: UpdateReqConsumerStrategy

message_timeout_ticks: int

message_timeout_ms: int

checkpoint_after_ticks: int

checkpoint_after_ms: int

__post_init__()

Return type:

None

class eventstoredb.generated.event_store.client.persistent_subscriptions.UpdateResp

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.persistent_subscriptions.DeleteReq

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.persistent_subscriptions.DeleteReqOptions

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

all: eventstoredb.generated.event_store.client.Empty

group_name: str

class eventstoredb.generated.event_store.client.persistent_subscriptions.DeleteResp

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.persistent_subscriptions.GetInfoReq

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: GetInfoReqOptions

class eventstoredb.generated.event_store.client.persistent_subscriptions.GetInfoReqOptions

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

all: eventstoredb.generated.event_store.client.Empty

group_name: str

class eventstoredb.generated.event_store.client.persistent_subscriptions.GetInfoResp

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_info: SubscriptionInfo

class eventstoredb.generated.event_store.client.persistent_subscriptions.SubscriptionInfo

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_source: str

group_name: str

status: str

connections: List[SubscriptionInfoConnectionInfo]

average_per_second: int

total_items: int

count_since_last_measurement: int

last_checkpointed_event_position: str

last_known_event_position: str

resolve_link_tos: bool

start_from: str

message_timeout_milliseconds: int

extra_statistics: bool

max_retry_count: int

live_buffer_size: int

buffer_size: int

read_batch_size: int

check_point_after_milliseconds: int

min_check_point_count: int

max_check_point_count: int

read_buffer_count: int

live_buffer_count: int

retry_buffer_count: int

total_in_flight_messages: int

outstanding_messages_count: int

named_consumer_strategy: str

max_subscriber_count: int

parked_message_count: int

class eventstoredb.generated.event_store.client.persistent_subscriptions.SubscriptionInfoConnectionInfo

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__().

from_: str

username: str

average_items_per_second: int

total_items: int

count_since_last_measurement: int

observed_measurements: List[SubscriptionInfoMeasurement]

available_slots: int

in_flight_messages: int

connection_name: str

class eventstoredb.generated.event_store.client.persistent_subscriptions.SubscriptionInfoMeasurement

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__().

key: str

value: int

class eventstoredb.generated.event_store.client.persistent_subscriptions.ReplayParkedReq

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: ReplayParkedReqOptions

class eventstoredb.generated.event_store.client.persistent_subscriptions.ReplayParkedReqOptions

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__().

group_name: str

stream_identifier: eventstoredb.generated.event_store.client.StreamIdentifier

all: eventstoredb.generated.event_store.client.Empty

stop_at: int

no_limit: eventstoredb.generated.event_store.client.Empty

class eventstoredb.generated.event_store.client.persistent_subscriptions.ReplayParkedResp

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.persistent_subscriptions.ListReq

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: ListReqOptions

class eventstoredb.generated.event_store.client.persistent_subscriptions.ListReqOptions

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__().

list_all_subscriptions: eventstoredb.generated.event_store.client.Empty

list_for_stream: ListReqStreamOption

class eventstoredb.generated.event_store.client.persistent_subscriptions.ListReqStreamOption

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: eventstoredb.generated.event_store.client.StreamIdentifier

all: eventstoredb.generated.event_store.client.Empty

class eventstoredb.generated.event_store.client.persistent_subscriptions.ListResp

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__().

subscriptions: List[SubscriptionInfo]

class eventstoredb.generated.event_store.client.persistent_subscriptions.PersistentSubscriptionsStub(channel, *, timeout=None, deadline=None, metadata=None)

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 create(create_req, *, timeout=None, deadline=None, metadata=None)

Parameters:

• create_req (CreateReq) –

• timeout (Optional[float]) –

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

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

Return type:

CreateResp

async update(update_req, *, timeout=None, deadline=None, metadata=None)

Parameters:

• update_req (UpdateReq) –

• timeout (Optional[float]) –

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

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

Return type:

UpdateResp

async delete(delete_req, *, timeout=None, deadline=None, metadata=None)

Parameters:

• delete_req (DeleteReq) –

• timeout (Optional[float]) –

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

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

Return type:

DeleteResp

async read(read_req_iterator, *, timeout=None, deadline=None, metadata=None)

Parameters:

• read_req_iterator (Union[AsyncIterable[ReadReq], Iterable[ReadReq]]) –

• timeout (Optional[float]) –

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

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

Return type:

AsyncIterator[ReadResp]

async get_info(get_info_req, *, timeout=None, deadline=None, metadata=None)

Parameters:

• get_info_req (GetInfoReq) –

• timeout (Optional[float]) –

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

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

Return type:

GetInfoResp

async replay_parked(replay_parked_req, *, timeout=None, deadline=None, metadata=None)

Parameters:

• replay_parked_req (ReplayParkedReq) –

• timeout (Optional[float]) –

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

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

Return type:

ReplayParkedResp

async list(list_req, *, timeout=None, deadline=None, metadata=None)

Parameters:

• list_req (ListReq) –

• timeout (Optional[float]) –

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

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

Return type:

ListResp

async restart_subsystem(client_empty, *, timeout=None, deadline=None, metadata=None)

Parameters:

• client_empty (eventstoredb.generated.event_store.client.Empty) –

• timeout (Optional[float]) –

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

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

Return type:

eventstoredb.generated.event_store.client.Empty

class eventstoredb.generated.event_store.client.persistent_subscriptions.PersistentSubscriptionsBase

Bases: betterproto.grpc.grpclib_server.ServiceBase

Base class for async gRPC servers.

async create(create_req)

Parameters:

create_req (CreateReq) –

Return type:

CreateResp

async update(update_req)

Parameters:

update_req (UpdateReq) –

Return type:

UpdateResp

async delete(delete_req)

Parameters:

delete_req (DeleteReq) –

Return type:

DeleteResp

async read(read_req_iterator)

Parameters:

read_req_iterator (AsyncIterator[ReadReq]) –

Return type:

AsyncIterator[ReadResp]

async get_info(get_info_req)

Parameters:

get_info_req (GetInfoReq) –

Return type:

GetInfoResp

async replay_parked(replay_parked_req)

Parameters:

replay_parked_req (ReplayParkedReq) –

Return type:

ReplayParkedResp

async list(list_req)

Parameters:

list_req (ListReq) –

Return type:

ListResp

async restart_subsystem(client_empty)

Parameters:

client_empty (eventstoredb.generated.event_store.client.Empty) –

Return type:

eventstoredb.generated.event_store.client.Empty

__mapping__()

Return type:

Dict[str, grpclib.const.Handler]