5.1.1.2.1.6. FedEval.communicaiton.grpc_communicator

5.1.1.2.1.6.1. Module Contents

5.1.1.2.1.6.1.1. Classes

_Master	message TrainingStatus {
ServerGrpcCommunicator	Helper class that provides a standard way to create an ABC using
ClientGrpcCommunicator	Helper class that provides a standard way to create an ABC using

5.1.1.2.1.6.1.2. Attributes

comm_thread_ctx
MsgType

FedEval.communicaiton.grpc_communicator.comm_thread_ctx

class FedEval.communicaiton.grpc_communicator._Master

Bases: FedEval.communicaiton.comm_pb2_grpc.FederatedLearningServicer

message TrainingStatus { bool finished = 1; int64 rounds = 2; string log_dir = 3; # results = 4; }

_has_handler(event: FedEval.communicaiton.events.ServerEvent) → bool

_check_handler_registration(event: FedEval.communicaiton.events.ServerEvent) → None

_ensure_req_queue_existance(comm_id: FedEval.role.container.CommunicationId) → queue.Queue

_ensure_invokation_queue_existance(comm_id: FedEval.role.container.CommunicationId) → Tuple[queue.Queue, threading.Lock]

_receive_request(request_iterator: Generator, comm_id: FedEval.role.container.CommunicationId) → None

connect(request_iterator, context)

Missing associated documentation comment in .proto file.

on(event: FedEval.communicaiton.events.ServerEvent, handler: Callable) → None

put_invokation(comm_id: FedEval.role.container.CommunicationId, invokation: Any)

FedEval.communicaiton.grpc_communicator.MsgType

class FedEval.communicaiton.grpc_communicator.ServerGrpcCommunicator

Bases: FedEval.communicaiton.communicator.ServerCommunicator

Helper class that provides a standard way to create an ABC using inheritance.

handle_disconnection() → Iterable[FedEval.config.role.ClientId]

handle_reconnection() → Iterable[FedEval.config.role.ClientId]

activate(node_id: FedEval.role.container.NodeId, client_ids: Iterable[FedEval.config.role.ClientId]) → None

invoke(event: FedEval.communicaiton.events.ClientEvent, *args, callee: FedEval.config.role.ClientId | None = None, **kwargs)

invoke_all(event: FedEval.communicaiton.events.ClientEvent, payload: Dict[str, Any] | None = None, *args, callees: Iterable[FedEval.config.role.ClientId] | None = None, **kwargs)

on(event: FedEval.communicaiton.events.ClientEvent) → Callable[[Callable], Any]

route(rule: str, **options: Any)

run_server() → None

class FedEval.communicaiton.grpc_communicator.ClientGrpcCommunicator

Bases: FedEval.communicaiton.communicator.ClientCommunicator

Helper class that provides a standard way to create an ABC using inheritance.

_on(event: FedEval.communicaiton.events.ClientEvent, handler: Callable) → None

_has_handler(event: FedEval.communicaiton.events.ClientEvent) → bool

_check_handler_registration(event: FedEval.communicaiton.events.ClientEvent) → None

on(event: FedEval.communicaiton.events.ClientEvent, *on_args, **on_kwargs)

invoke(event: FedEval.communicaiton.events.ServerEvent, *args, **kwargs)

_invokation_generator()

wait(**kw) → None