Skip to content

Operations

Operations Mixins.

Operations

Bases: ClientBase

Handles Operations.

Source code in src/eventstore_grpc/client/operations.py 
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
class Operations(ClientBase):
    """Handles Operations."""

    def merge_indexes(self, **kwargs) -> shared_pb2.Empty:
        """Merges indexes."""
        stub = operations_pb2_grpc.OperationsStub(self.channel)
        result = operations.merge_indexes(stub, **kwargs)
        return result

    def resign_node(self, **kwargs) -> shared_pb2.Empty:
        """Resigns node."""
        stub = operations_pb2_grpc.OperationsStub(self.channel)
        result = operations.resign_node(stub, **kwargs)
        return result

    def restart_persistent_subscriptions(self, **kwargs) -> shared_pb2.Empty:
        """Restarts persistent subscriptions."""
        stub = operations_pb2_grpc.OperationsStub(self.channel)
        result = operations.restart_persistent_subscriptions(stub, **kwargs)
        return result

    def set_node_priority(self, priority: int, **kwargs) -> shared_pb2.Empty:
        """Sets node priority.

        Args:
            priority: the priority level for the node you're currently connected to.
        """
        stub = operations_pb2_grpc.OperationsStub(self.channel)
        result = operations.set_node_priority(stub, priority, **kwargs)
        return result

    def shutdown(self, **kwargs) -> shared_pb2.Empty:
        """Shuts the node down."""
        stub = operations_pb2_grpc.OperationsStub(self.channel)
        result = operations.shutdown(stub, **kwargs)
        return result

    def start_scavenge(
        self, thread_count: int, start_from_chunk: int, **kwargs
    ) -> operations_pb2.ScavengeResp:
        """Starts a scavenge operation."""
        stub = operations_pb2_grpc.OperationsStub(self.channel)
        result = operations.start_scavenge(
            stub, thread_count=thread_count, start_from_chunk=start_from_chunk, **kwargs
        )
        return result

    def stop_scavenge(self, scavenge_id: str, **kwargs) -> operations_pb2.ScavengeResp:
        """Stops a scavenge operation."""
        stub = operations_pb2_grpc.OperationsStub(self.channel)
        result = operations.stop_scavenge(stub, scavenge_id=scavenge_id, **kwargs)
        return result

merge_indexes(**kwargs)

Merges indexes.

Source code in src/eventstore_grpc/client/operations.py 
13
14
15
16
17
def merge_indexes(self, **kwargs) -> shared_pb2.Empty:
    """Merges indexes."""
    stub = operations_pb2_grpc.OperationsStub(self.channel)
    result = operations.merge_indexes(stub, **kwargs)
    return result

resign_node(**kwargs)

Resigns node.

Source code in src/eventstore_grpc/client/operations.py 
19
20
21
22
23
def resign_node(self, **kwargs) -> shared_pb2.Empty:
    """Resigns node."""
    stub = operations_pb2_grpc.OperationsStub(self.channel)
    result = operations.resign_node(stub, **kwargs)
    return result

restart_persistent_subscriptions(**kwargs)

Restarts persistent subscriptions.

Source code in src/eventstore_grpc/client/operations.py 
25
26
27
28
29
def restart_persistent_subscriptions(self, **kwargs) -> shared_pb2.Empty:
    """Restarts persistent subscriptions."""
    stub = operations_pb2_grpc.OperationsStub(self.channel)
    result = operations.restart_persistent_subscriptions(stub, **kwargs)
    return result

set_node_priority(priority, **kwargs)

Sets node priority.

Parameters:

Name Type Description Default
priority int

the priority level for the node you're currently connected to.

 required
Source code in src/eventstore_grpc/client/operations.py 
31
32
33
34
35
36
37
38
39
def set_node_priority(self, priority: int, **kwargs) -> shared_pb2.Empty:
    """Sets node priority.

    Args:
        priority: the priority level for the node you're currently connected to.
    """
    stub = operations_pb2_grpc.OperationsStub(self.channel)
    result = operations.set_node_priority(stub, priority, **kwargs)
    return result

shutdown(**kwargs)

Shuts the node down.

Source code in src/eventstore_grpc/client/operations.py 
41
42
43
44
45
def shutdown(self, **kwargs) -> shared_pb2.Empty:
    """Shuts the node down."""
    stub = operations_pb2_grpc.OperationsStub(self.channel)
    result = operations.shutdown(stub, **kwargs)
    return result

start_scavenge(thread_count, start_from_chunk, **kwargs)

Starts a scavenge operation.

Source code in src/eventstore_grpc/client/operations.py 
47
48
49
50
51
52
53
54
55
def start_scavenge(
    self, thread_count: int, start_from_chunk: int, **kwargs
) -> operations_pb2.ScavengeResp:
    """Starts a scavenge operation."""
    stub = operations_pb2_grpc.OperationsStub(self.channel)
    result = operations.start_scavenge(
        stub, thread_count=thread_count, start_from_chunk=start_from_chunk, **kwargs
    )
    return result

stop_scavenge(scavenge_id, **kwargs)

Stops a scavenge operation.

Source code in src/eventstore_grpc/client/operations.py 
57
58
59
60
61
def stop_scavenge(self, scavenge_id: str, **kwargs) -> operations_pb2.ScavengeResp:
    """Stops a scavenge operation."""
    stub = operations_pb2_grpc.OperationsStub(self.channel)
    result = operations.stop_scavenge(stub, scavenge_id=scavenge_id, **kwargs)
    return result