Skip to content

Delete

Delete persisten subscription.

delete_persistent_subscription(stub, group, stream=None)

Deletes a persistent subscription.

Source code in src/eventstore_grpc/persistent/delete.py 
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
def delete_persistent_subscription(
    stub: persistent_pb2_grpc.PersistentSubscriptionsStub,
    group: str,
    stream: Optional[str] = None,
) -> persistent_pb2.DeleteResp:
    """Deletes a persistent subscription."""
    request = persistent_pb2.DeleteReq()
    options = persistent_pb2.DeleteReq.Options()
    if stream is not None:
        identifier = shared_pb2.StreamIdentifier()
        identifier.stream_name = stream.encode()
        options.stream_identifier.CopyFrom(identifier)
    else:  # $all
        options.all.CopyFrom(shared_pb2.Empty())
    options.group_name = group
    request.options.CopyFrom(options)
    response = stub.Delete(request)
    return response