narupa.protocol.state.state_service_pb2_grpc module

Client and server classes corresponding to protobuf-defined services.

class narupa.protocol.state.state_service_pb2_grpc.State

Bases: object

Missing associated documentation comment in .proto file.

static SubscribeStateUpdates(request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None)

static UpdateLocks(request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None)

static UpdateState(request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None)

class narupa.protocol.state.state_service_pb2_grpc.StateServicer

Bases: object

Missing associated documentation comment in .proto file.

SubscribeStateUpdates(request, context)

Periodically received aggregated updates from last known state to latest state of a shared key/value store.

UpdateLocks(request, context)

Attempt to acquire, renew, or release exclusive control of keys in the shared key/value store.

UpdateState(request, context)

Attempt to make an update to the shared key/value store.

class narupa.protocol.state.state_service_pb2_grpc.StateStub(channel)

Bases: object

Missing associated documentation comment in .proto file.

narupa.protocol.state.state_service_pb2_grpc.add_StateServicer_to_server(servicer, server)