Skip to content

List

List projections.

list_continuous_projections(stub, **kwargs)

Lists continuous projections.

Source code in src/eventstore_grpc/projections/list.py 
 8
 9
10
11
12
13
14
15
16
17
def list_continuous_projections(
    stub: projections_pb2_grpc.ProjectionsStub, **kwargs
) -> Iterable[projections_pb2.StatisticsResp]:
    """Lists continuous projections."""
    request = projections_pb2.StatisticsReq()
    options = projections_pb2.StatisticsReq.Options()
    options.continuous.CopyFrom(shared_pb2.Empty())
    request.options.CopyFrom(options)
    response = stub.Statistics(request, **kwargs)
    return response

list_one_time_projections(stub, **kwargs)

Lists one time projections.

Source code in src/eventstore_grpc/projections/list.py 
20
21
22
23
24
25
26
27
28
29
def list_one_time_projections(
    stub: projections_pb2_grpc.ProjectionsStub, **kwargs
) -> Iterable[projections_pb2.StatisticsResp]:
    """Lists one time projections."""
    request = projections_pb2.StatisticsReq()
    options = projections_pb2.StatisticsReq.Options()
    options.one_time.CopyFrom(shared_pb2.Empty())
    request.options.CopyFrom(options)
    response = stub.Statistics(request, **kwargs)
    return response

list_transient_projections(stub, **kwargs)

Lists transient projections.

Source code in src/eventstore_grpc/projections/list.py 
32
33
34
35
36
37
38
39
40
41
def list_transient_projections(
    stub: projections_pb2_grpc.ProjectionsStub, **kwargs
) -> Iterable[projections_pb2.StatisticsResp]:
    """Lists transient projections."""
    request = projections_pb2.StatisticsReq()
    options = projections_pb2.StatisticsReq.Options()
    options.transient.CopyFrom(shared_pb2.Empty())
    request.options.CopyFrom(options)
    response = stub.Statistics(request, **kwargs)
    return response