public long getId ( final WorkerNetAddress address ) throws IOException { return retryRPC ( ( RpcCallable < Long > ) ( ) -> { GetWorkerIdPRequest request = GetWorkerIdPRequest . newBuilder ( ) . setWorkerNetAddress ( GrpcUtils . toProto ( address ) ) . build ( ) ; return mClient . getWorkerId ( request ) . getWorkerId ( ) ; } ) ; }
Returns a worker id for a workers net address .