eventstoredb.generated.event_store.client.projections#

Package Contents#

Classes#

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

CreateReqOptionsTransient

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

CreateReqOptionsContinuous

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

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

StatisticsReq

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

StatisticsReqOptions

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

StatisticsResp

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

StatisticsRespDetails

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

StateReq

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

StateReqOptions

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

StateResp

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

ResultReq

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

ResultReqOptions

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

ResultResp

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

ResetReq

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

ResetReqOptions

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

ResetResp

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

EnableReq

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

EnableReqOptions

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

EnableResp

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

DisableReq

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

DisableReqOptions

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

DisableResp

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

ProjectionsStub

Base class for async gRPC clients.

ProjectionsBase

Base class for async gRPC servers.

class eventstoredb.generated.event_store.client.projections.CreateReq[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__().

options: CreateReqOptions#
class eventstoredb.generated.event_store.client.projections.CreateReqOptions[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__().

one_time: eventstoredb.generated.event_store.client.Empty#
transient: CreateReqOptionsTransient#
continuous: CreateReqOptionsContinuous#
query: str#
class eventstoredb.generated.event_store.client.projections.CreateReqOptionsTransient[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__().

name: str#
class eventstoredb.generated.event_store.client.projections.CreateReqOptionsContinuous[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__().

name: str#
emit_enabled: bool#
track_emitted_streams: bool#
class eventstoredb.generated.event_store.client.projections.CreateResp[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.projections.UpdateReq[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__().

options: UpdateReqOptions#
class eventstoredb.generated.event_store.client.projections.UpdateReqOptions[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__().

name: str#
query: str#
emit_enabled: bool#
no_emit_options: eventstoredb.generated.event_store.client.Empty#
class eventstoredb.generated.event_store.client.projections.UpdateResp[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.projections.DeleteReq[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__().

options: DeleteReqOptions#
class eventstoredb.generated.event_store.client.projections.DeleteReqOptions[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__().

name: str#
delete_emitted_streams: bool#
delete_state_stream: bool#
delete_checkpoint_stream: bool#
class eventstoredb.generated.event_store.client.projections.DeleteResp[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.projections.StatisticsReq[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__().

options: StatisticsReqOptions#
class eventstoredb.generated.event_store.client.projections.StatisticsReqOptions[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__().

name: str#
all: eventstoredb.generated.event_store.client.Empty#
transient: eventstoredb.generated.event_store.client.Empty#
continuous: eventstoredb.generated.event_store.client.Empty#
one_time: eventstoredb.generated.event_store.client.Empty#
class eventstoredb.generated.event_store.client.projections.StatisticsResp[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__().

details: StatisticsRespDetails#
class eventstoredb.generated.event_store.client.projections.StatisticsRespDetails[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__().

core_processing_time: int#
version: int#
epoch: int#
effective_name: str#
writes_in_progress: int#
reads_in_progress: int#
partitions_cached: int#
status: str#
state_reason: str#
name: str#
mode: str#
position: str#
progress: float#
last_checkpoint: str#
events_processed_after_restart: int#
checkpoint_status: str#
buffered_events: int#
write_pending_events_before_checkpoint: int#
write_pending_events_after_checkpoint: int#
class eventstoredb.generated.event_store.client.projections.StateReq[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__().

options: StateReqOptions#
class eventstoredb.generated.event_store.client.projections.StateReqOptions[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__().

name: str#
partition: str#
class eventstoredb.generated.event_store.client.projections.StateResp[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__().

state: betterproto.lib.google.protobuf.Value#
class eventstoredb.generated.event_store.client.projections.ResultReq[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__().

options: ResultReqOptions#
class eventstoredb.generated.event_store.client.projections.ResultReqOptions[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__().

name: str#
partition: str#
class eventstoredb.generated.event_store.client.projections.ResultResp[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__().

result: betterproto.lib.google.protobuf.Value#
class eventstoredb.generated.event_store.client.projections.ResetReq[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__().

options: ResetReqOptions#
class eventstoredb.generated.event_store.client.projections.ResetReqOptions[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__().

name: str#
write_checkpoint: bool#
class eventstoredb.generated.event_store.client.projections.ResetResp[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.projections.EnableReq[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__().

options: EnableReqOptions#
class eventstoredb.generated.event_store.client.projections.EnableReqOptions[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__().

name: str#
class eventstoredb.generated.event_store.client.projections.EnableResp[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.projections.DisableReq[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__().

options: DisableReqOptions#
class eventstoredb.generated.event_store.client.projections.DisableReqOptions[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__().

name: str#
write_checkpoint: bool#
class eventstoredb.generated.event_store.client.projections.DisableResp[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.projections.ProjectionsStub(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 create(create_req, *, timeout=None, deadline=None, metadata=None)[source]#
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)[source]#
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)[source]#
Parameters:
  • delete_req (DeleteReq) –

  • timeout (Optional[float]) –

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

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

Return type:

DeleteResp

async statistics(statistics_req, *, timeout=None, deadline=None, metadata=None)[source]#
Parameters:
  • statistics_req (StatisticsReq) –

  • timeout (Optional[float]) –

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

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

Return type:

AsyncIterator[StatisticsResp]

async disable(disable_req, *, timeout=None, deadline=None, metadata=None)[source]#
Parameters:
  • disable_req (DisableReq) –

  • timeout (Optional[float]) –

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

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

Return type:

DisableResp

async enable(enable_req, *, timeout=None, deadline=None, metadata=None)[source]#
Parameters:
  • enable_req (EnableReq) –

  • timeout (Optional[float]) –

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

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

Return type:

EnableResp

async reset(reset_req, *, timeout=None, deadline=None, metadata=None)[source]#
Parameters:
  • reset_req (ResetReq) –

  • timeout (Optional[float]) –

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

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

Return type:

ResetResp

async state(state_req, *, timeout=None, deadline=None, metadata=None)[source]#
Parameters:
  • state_req (StateReq) –

  • timeout (Optional[float]) –

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

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

Return type:

StateResp

async result(result_req, *, timeout=None, deadline=None, metadata=None)[source]#
Parameters:
  • result_req (ResultReq) –

  • timeout (Optional[float]) –

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

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

Return type:

ResultResp

async restart_subsystem(client_empty, *, timeout=None, deadline=None, metadata=None)[source]#
Parameters:
Return type:

eventstoredb.generated.event_store.client.Empty

class eventstoredb.generated.event_store.client.projections.ProjectionsBase[source]#

Bases: betterproto.grpc.grpclib_server.ServiceBase

Base class for async gRPC servers.

async create(create_req)[source]#
Parameters:

create_req (CreateReq) –

Return type:

CreateResp

async update(update_req)[source]#
Parameters:

update_req (UpdateReq) –

Return type:

UpdateResp

async delete(delete_req)[source]#
Parameters:

delete_req (DeleteReq) –

Return type:

DeleteResp

async statistics(statistics_req)[source]#
Parameters:

statistics_req (StatisticsReq) –

Return type:

AsyncIterator[StatisticsResp]

async disable(disable_req)[source]#
Parameters:

disable_req (DisableReq) –

Return type:

DisableResp

async enable(enable_req)[source]#
Parameters:

enable_req (EnableReq) –

Return type:

EnableResp

async reset(reset_req)[source]#
Parameters:

reset_req (ResetReq) –

Return type:

ResetResp

async state(state_req)[source]#
Parameters:

state_req (StateReq) –

Return type:

StateResp

async result(result_req)[source]#
Parameters:

result_req (ResultReq) –

Return type:

ResultResp

async restart_subsystem(client_empty)[source]#
Parameters:

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

Return type:

eventstoredb.generated.event_store.client.Empty

__mapping__()[source]#
Return type:

Dict[str, grpclib.const.Handler]