eventstoredb.generated.event_store.client.gossip#

Package Contents#

Classes#

MemberInfoVNodeState

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

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

GossipStub

Base class for async gRPC clients.

GossipBase

Base class for async gRPC servers.
class eventstoredb.generated.event_store.client.gossip.MemberInfoVNodeState[source]#

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.client.gossip.ClusterInfo[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__().

members: List[MemberInfo]#
class eventstoredb.generated.event_store.client.gossip.EndPoint[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__().

address: str#
port: int#
class eventstoredb.generated.event_store.client.gossip.MemberInfo[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__().

instance_id: eventstoredb.generated.event_store.client.Uuid#
time_stamp: int#
state: MemberInfoVNodeState#
is_alive: bool#
http_end_point: EndPoint#
class eventstoredb.generated.event_store.client.gossip.GossipStub(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(client_empty, *, timeout=None, deadline=None, metadata=None)[source]#
Parameters:
Return type:

ClusterInfo

class eventstoredb.generated.event_store.client.gossip.GossipBase[source]#

Bases: betterproto.grpc.grpclib_server.ServiceBase

Base class for async gRPC servers.

async read(client_empty)[source]#
Parameters:

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

Return type:

ClusterInfo

__mapping__()[source]#
Return type:

Dict[str, grpclib.const.Handler]