eventstoredb.generated.event_store.client.operations

Package Contents

Classes

ScavengeRespScavengeResult	The base class for protobuf enumerations, all generated enumerations will inherit
StartScavengeReq	The base class for protobuf messages, all generated messages will inherit from
StartScavengeReqOptions	The base class for protobuf messages, all generated messages will inherit from
StopScavengeReq	The base class for protobuf messages, all generated messages will inherit from
StopScavengeReqOptions	The base class for protobuf messages, all generated messages will inherit from
ScavengeResp	The base class for protobuf messages, all generated messages will inherit from
SetNodePriorityReq	The base class for protobuf messages, all generated messages will inherit from
OperationsStub	Base class for async gRPC clients.
OperationsBase	Base class for async gRPC servers.

class eventstoredb.generated.event_store.client.operations.ScavengeRespScavengeResult

Bases: betterproto.Enum

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

Started = 0

InProgress = 1

Stopped = 2

class eventstoredb.generated.event_store.client.operations.StartScavengeReq

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

class eventstoredb.generated.event_store.client.operations.StartScavengeReqOptions

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

thread_count: int

start_from_chunk: int

class eventstoredb.generated.event_store.client.operations.StopScavengeReq

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

class eventstoredb.generated.event_store.client.operations.StopScavengeReqOptions

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

scavenge_id: str

class eventstoredb.generated.event_store.client.operations.ScavengeResp

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

scavenge_id: str

scavenge_result: ScavengeRespScavengeResult

class eventstoredb.generated.event_store.client.operations.SetNodePriorityReq

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

priority: int

class eventstoredb.generated.event_store.client.operations.OperationsStub(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 start_scavenge(start_scavenge_req, *, timeout=None, deadline=None, metadata=None)

Parameters:

• start_scavenge_req (StartScavengeReq) –

• timeout (Optional[float]) –

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

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

Return type:

ScavengeResp

async stop_scavenge(stop_scavenge_req, *, timeout=None, deadline=None, metadata=None)

Parameters:

• stop_scavenge_req (StopScavengeReq) –

• timeout (Optional[float]) –

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

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

Return type:

ScavengeResp

async shutdown(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

async merge_indexes(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

async resign_node(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

async set_node_priority(set_node_priority_req, *, timeout=None, deadline=None, metadata=None)

Parameters:

• set_node_priority_req (SetNodePriorityReq) –

• timeout (Optional[float]) –

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

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

Return type:

eventstoredb.generated.event_store.client.Empty

async restart_persistent_subscriptions(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.operations.OperationsBase

Bases: betterproto.grpc.grpclib_server.ServiceBase

Base class for async gRPC servers.

async start_scavenge(start_scavenge_req)

Parameters:

start_scavenge_req (StartScavengeReq) –

Return type:

ScavengeResp

async stop_scavenge(stop_scavenge_req)

Parameters:

stop_scavenge_req (StopScavengeReq) –

Return type:

ScavengeResp

async shutdown(client_empty)

Parameters:

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

Return type:

eventstoredb.generated.event_store.client.Empty

async merge_indexes(client_empty)

Parameters:

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

Return type:

eventstoredb.generated.event_store.client.Empty

async resign_node(client_empty)

Parameters:

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

Return type:

eventstoredb.generated.event_store.client.Empty

async set_node_priority(set_node_priority_req)

Parameters:

set_node_priority_req (SetNodePriorityReq) –

Return type:

eventstoredb.generated.event_store.client.Empty

async restart_persistent_subscriptions(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]