eventstoredb.generated.event_store.cluster

Package Contents

Classes

MemberInfoVNodeState	The base class for protobuf enumerations, all generated enumerations will inherit
GossipRequest	The base class for protobuf messages, all generated messages will inherit from
ViewChangeRequest	The base class for protobuf messages, all generated messages will inherit from
ViewChangeProofRequest	The base class for protobuf messages, all generated messages will inherit from
PrepareRequest	The base class for protobuf messages, all generated messages will inherit from
PrepareOkRequest	The base class for protobuf messages, all generated messages will inherit from
ProposalRequest	The base class for protobuf messages, all generated messages will inherit from
AcceptRequest	The base class for protobuf messages, all generated messages will inherit from
LeaderIsResigningRequest	The base class for protobuf messages, all generated messages will inherit from
LeaderIsResigningOkRequest	The base class for protobuf messages, all generated messages will inherit from
ClusterInfo	The base class for protobuf messages, all generated messages will inherit from
EndPoint	The base class for protobuf messages, all generated messages will inherit from
MemberInfo	The base class for protobuf messages, all generated messages will inherit from
ReplicaLogWrite	The base class for protobuf messages, all generated messages will inherit from
ReplicatedTo	The base class for protobuf messages, all generated messages will inherit from
Epoch	The base class for protobuf messages, all generated messages will inherit from
SubscribeReplica	The base class for protobuf messages, all generated messages will inherit from
ReplicaSubscriptionRetry	The base class for protobuf messages, all generated messages will inherit from
ReplicaSubscribed	The base class for protobuf messages, all generated messages will inherit from
ReplicaLogPositionAck	The base class for protobuf messages, all generated messages will inherit from
CreateChunk	The base class for protobuf messages, all generated messages will inherit from
RawChunkBulk	The base class for protobuf messages, all generated messages will inherit from
DataChunkBulk	The base class for protobuf messages, all generated messages will inherit from
FollowerAssignment	The base class for protobuf messages, all generated messages will inherit from
CloneAssignment	The base class for protobuf messages, all generated messages will inherit from
DropSubscription	The base class for protobuf messages, all generated messages will inherit from
GossipStub	Base class for async gRPC clients.
ElectionsStub	Base class for async gRPC clients.
GossipBase	Base class for async gRPC servers.
ElectionsBase	Base class for async gRPC servers.

class eventstoredb.generated.event_store.cluster.MemberInfoVNodeState

Bases: betterproto.Enum

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

Initializing = 0

DiscoverLeader = 1

Unknown = 2

PreReplica = 3

CatchingUp = 4

Clone = 5

Follower = 6

PreLeader = 7

Leader = 8

Manager = 9

ShuttingDown = 10

Shutdown = 11

ReadOnlyLeaderless = 12

PreReadOnlyReplica = 13

ReadOnlyReplica = 14

ResigningLeader = 15

class eventstoredb.generated.event_store.cluster.GossipRequest

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

info: ClusterInfo

server: EndPoint

class eventstoredb.generated.event_store.cluster.ViewChangeRequest

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

server_id: eventstoredb.generated.event_store.client.Uuid

server_http: EndPoint

attempted_view: int

class eventstoredb.generated.event_store.cluster.ViewChangeProofRequest

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

server_id: eventstoredb.generated.event_store.client.Uuid

server_http: EndPoint

installed_view: int

class eventstoredb.generated.event_store.cluster.PrepareRequest

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

server_id: eventstoredb.generated.event_store.client.Uuid

server_http: EndPoint

view: int

class eventstoredb.generated.event_store.cluster.PrepareOkRequest

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

view: int

server_id: eventstoredb.generated.event_store.client.Uuid

server_http: EndPoint

epoch_number: int

epoch_position: int

epoch_id: eventstoredb.generated.event_store.client.Uuid

epoch_leader_instance_id: eventstoredb.generated.event_store.client.Uuid

last_commit_position: int

writer_checkpoint: int

chaser_checkpoint: int

node_priority: int

cluster_info: ClusterInfo

class eventstoredb.generated.event_store.cluster.ProposalRequest

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

server_id: eventstoredb.generated.event_store.client.Uuid

server_http: EndPoint

leader_id: eventstoredb.generated.event_store.client.Uuid

leader_http: EndPoint

view: int

epoch_number: int

epoch_position: int

epoch_id: eventstoredb.generated.event_store.client.Uuid

epoch_leader_instance_id: eventstoredb.generated.event_store.client.Uuid

last_commit_position: int

writer_checkpoint: int

chaser_checkpoint: int

node_priority: int

class eventstoredb.generated.event_store.cluster.AcceptRequest

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

server_id: eventstoredb.generated.event_store.client.Uuid

server_http: EndPoint

leader_id: eventstoredb.generated.event_store.client.Uuid

leader_http: EndPoint

view: int

class eventstoredb.generated.event_store.cluster.LeaderIsResigningRequest

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

leader_id: eventstoredb.generated.event_store.client.Uuid

leader_http: EndPoint

class eventstoredb.generated.event_store.cluster.LeaderIsResigningOkRequest

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

leader_id: eventstoredb.generated.event_store.client.Uuid

leader_http: EndPoint

server_id: eventstoredb.generated.event_store.client.Uuid

server_http: EndPoint

class eventstoredb.generated.event_store.cluster.ClusterInfo

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

members: List[MemberInfo]

class eventstoredb.generated.event_store.cluster.EndPoint

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

address: str

port: int

class eventstoredb.generated.event_store.cluster.MemberInfo

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

instance_id: eventstoredb.generated.event_store.client.Uuid

time_stamp: int

state: MemberInfoVNodeState

is_alive: bool

http_end_point: EndPoint

internal_tcp: EndPoint

external_tcp: EndPoint

internal_tcp_uses_tls: bool

external_tcp_uses_tls: bool

last_commit_position: int

writer_checkpoint: int

chaser_checkpoint: int

epoch_position: int

epoch_number: int

epoch_id: eventstoredb.generated.event_store.client.Uuid

node_priority: int

is_read_only_replica: bool

advertise_host_to_client_as: str

advertise_http_port_to_client_as: int

advertise_tcp_port_to_client_as: int

es_version: str

class eventstoredb.generated.event_store.cluster.ReplicaLogWrite

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

replica_id: bytes

class eventstoredb.generated.event_store.cluster.ReplicatedTo

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

class eventstoredb.generated.event_store.cluster.Epoch

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

epoch_position: int

epoch_number: int

epoch_id: bytes

class eventstoredb.generated.event_store.cluster.SubscribeReplica

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

last_epochs: List[Epoch]

ip: bytes

port: int

leader_id: bytes

subscription_id: bytes

is_promotable: bool

version: int

class eventstoredb.generated.event_store.cluster.ReplicaSubscriptionRetry

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

leader_id: bytes

subscription_id: bytes

class eventstoredb.generated.event_store.cluster.ReplicaSubscribed

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

leader_id: bytes

subscription_id: bytes

subscription_position: int

class eventstoredb.generated.event_store.cluster.ReplicaLogPositionAck

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

replication_log_position: int

writer_log_position: int

class eventstoredb.generated.event_store.cluster.CreateChunk

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

leader_id: bytes

subscription_id: bytes

chunk_header_bytes: bytes

file_size: int

is_completed_chunk: bool

class eventstoredb.generated.event_store.cluster.RawChunkBulk

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

leader_id: bytes

subscription_id: bytes

chunk_start_number: int

chunk_end_number: int

raw_position: int

raw_bytes: bytes

complete_chunk: bool

class eventstoredb.generated.event_store.cluster.DataChunkBulk

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

leader_id: bytes

subscription_id: bytes

chunk_start_number: int

chunk_end_number: int

subscription_position: int

data_bytes: bytes

complete_chunk: bool

class eventstoredb.generated.event_store.cluster.FollowerAssignment

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

leader_id: bytes

subscription_id: bytes

class eventstoredb.generated.event_store.cluster.CloneAssignment

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

leader_id: bytes

subscription_id: bytes

class eventstoredb.generated.event_store.cluster.DropSubscription

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

leader_id: bytes

subscription_id: bytes

class eventstoredb.generated.event_store.cluster.GossipStub(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 update(gossip_request, *, timeout=None, deadline=None, metadata=None)

Parameters:

• gossip_request (GossipRequest) –

• timeout (Optional[float]) –

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

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

Return type:

ClusterInfo

async read(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:

ClusterInfo

class eventstoredb.generated.event_store.cluster.ElectionsStub(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 view_change(view_change_request, *, timeout=None, deadline=None, metadata=None)

Parameters:

• view_change_request (ViewChangeRequest) –

• timeout (Optional[float]) –

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

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

Return type:

eventstoredb.generated.event_store.client.Empty

async view_change_proof(view_change_proof_request, *, timeout=None, deadline=None, metadata=None)

Parameters:

• view_change_proof_request (ViewChangeProofRequest) –

• timeout (Optional[float]) –

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

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

Return type:

eventstoredb.generated.event_store.client.Empty

async prepare(prepare_request, *, timeout=None, deadline=None, metadata=None)

Parameters:

• prepare_request (PrepareRequest) –

• timeout (Optional[float]) –

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

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

Return type:

eventstoredb.generated.event_store.client.Empty

async prepare_ok(prepare_ok_request, *, timeout=None, deadline=None, metadata=None)

Parameters:

• prepare_ok_request (PrepareOkRequest) –

• timeout (Optional[float]) –

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

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

Return type:

eventstoredb.generated.event_store.client.Empty

async proposal(proposal_request, *, timeout=None, deadline=None, metadata=None)

Parameters:

• proposal_request (ProposalRequest) –

• timeout (Optional[float]) –

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

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

Return type:

eventstoredb.generated.event_store.client.Empty

async accept(accept_request, *, timeout=None, deadline=None, metadata=None)

Parameters:

• accept_request (AcceptRequest) –

• timeout (Optional[float]) –

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

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

Return type:

eventstoredb.generated.event_store.client.Empty

async leader_is_resigning(leader_is_resigning_request, *, timeout=None, deadline=None, metadata=None)

Parameters:

• leader_is_resigning_request (LeaderIsResigningRequest) –

• timeout (Optional[float]) –

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

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

Return type:

eventstoredb.generated.event_store.client.Empty

async leader_is_resigning_ok(leader_is_resigning_ok_request, *, timeout=None, deadline=None, metadata=None)

Parameters:

• leader_is_resigning_ok_request (LeaderIsResigningOkRequest) –

• 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.cluster.GossipBase

Bases: betterproto.grpc.grpclib_server.ServiceBase

Base class for async gRPC servers.

async update(gossip_request)

Parameters:

gossip_request (GossipRequest) –

Return type:

ClusterInfo

async read(client_empty)

Parameters:

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

Return type:

ClusterInfo

__mapping__()

Return type:

Dict[str, grpclib.const.Handler]

class eventstoredb.generated.event_store.cluster.ElectionsBase

Bases: betterproto.grpc.grpclib_server.ServiceBase

Base class for async gRPC servers.

async view_change(view_change_request)

Parameters:

view_change_request (ViewChangeRequest) –

Return type:

eventstoredb.generated.event_store.client.Empty

async view_change_proof(view_change_proof_request)

Parameters:

view_change_proof_request (ViewChangeProofRequest) –

Return type:

eventstoredb.generated.event_store.client.Empty

async prepare(prepare_request)

Parameters:

prepare_request (PrepareRequest) –

Return type:

eventstoredb.generated.event_store.client.Empty

async prepare_ok(prepare_ok_request)

Parameters:

prepare_ok_request (PrepareOkRequest) –

Return type:

eventstoredb.generated.event_store.client.Empty

async proposal(proposal_request)

Parameters:

proposal_request (ProposalRequest) –

Return type:

eventstoredb.generated.event_store.client.Empty

async accept(accept_request)

Parameters:

accept_request (AcceptRequest) –

Return type:

eventstoredb.generated.event_store.client.Empty

async leader_is_resigning(leader_is_resigning_request)

Parameters:

leader_is_resigning_request (LeaderIsResigningRequest) –

Return type:

eventstoredb.generated.event_store.client.Empty

async leader_is_resigning_ok(leader_is_resigning_ok_request)

Parameters:

leader_is_resigning_ok_request (LeaderIsResigningOkRequest) –

Return type:

eventstoredb.generated.event_store.client.Empty

__mapping__()

Return type:

Dict[str, grpclib.const.Handler]