Skip to content

Read

Persistent Subscriptions Operations.

options_request(stream, group_name, buffer_size=10)

Returns a persistent subscription options request.

Source code in src/eventstore_grpc/persistent/read.py 
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
def options_request(
    stream: str, group_name: str, buffer_size: int = 10
) -> persistent_pb2.ReadReq:
    """Returns a persistent subscription options request."""
    request = persistent_pb2.ReadReq()
    options = persistent_pb2.ReadReq.Options()
    identifier = shared_pb2.StreamIdentifier()
    identifier.stream_name = stream.encode()
    uuid_option = persistent_pb2.ReadReq.Options.UUIDOption()
    uuid_option.string.CopyFrom(shared_pb2.Empty())
    options.stream_identifier.CopyFrom(identifier)
    options.group_name = group_name
    options.buffer_size = buffer_size
    options.uuid_option.CopyFrom(uuid_option)
    request.options.CopyFrom(options)
    return request