Source code for isek.node.registry

from abc import ABC, abstractmethod
from typing import Optional, Dict



[docs]
class Registry(ABC):

[docs]
    @abstractmethod
    def register_node(
        self,
        node_id: str,
        host: str,
        port: int,
        metadata: Optional[Dict[str, str]] = None,
    ):
        pass



[docs]
    @abstractmethod
    def get_available_nodes(self) -> dict:
        pass



[docs]
    @abstractmethod
    def deregister_node(self, node_id: str):
        pass



[docs]
    @abstractmethod
    def lease_refresh(self, node_id: str):
        pass