Skip to content

Latest commit

 

History

History
40 lines (27 loc) · 1014 Bytes

README.md

File metadata and controls

40 lines (27 loc) · 1014 Bytes
Raw

lockStream

A highly consistent distributed lock service based on raft consensus protocol. It supports two APIs, acquire and release.

Running lockStream

Dependencies

lockStream uses grpc package for communication between client and server as well as its nodes. Please install it using below command.

pip install grpcio==1.51.1 grpcio-tools==1.51.1

Starting lockStream server

controller.py module can be used to start the server.

Or we can use run.sh script to start the servers as well. Currently the ports are hardcoded in controller.py.

bash lstream/run.sh

Sending client requests

from lstream.client import LockServiceClient

client = LockServiceClient([("127.0.0.1", 17000), ("127.0.0.1", 18000), ("127.0.0.1", 19000)])

assert client.acquire("test") == True
assert client.release("test") == True
assert client.acquire("test") == True
assert client.release("test") == True

Note

Implementation is just for education purpose.