Newer
Older
from __future__ import print_function
import grpc
import connectionService_pb2
import connectionService_pb2_grpc
from google.protobuf import empty_pb2 as google_dot_protobuf_dot_empty__pb2
try:
raw_input # Python 2
except NameError:
raw_input = input # Python 3
def createConnection():
with grpc.insecure_channel('localhost:50051') as channel:
connection=connectionService_pb2.Connection()
connection.connectionId = raw_input("Enter connectionID: ")
connection.sourceNode = raw_input("Enter sourceNode: ")
connection.targetNode = raw_input("Enter targetNode: ")
connection.sourcePort = raw_input("Enter sourcePort: ")
connection.targetPort = raw_input("Enter targetPort: ")
connection.bandwidth = int( raw_input("Enter bandwidth: ") )
stub = connectionService_pb2_grpc.ConnectionServiceStub(channel)
response = stub.CreateConnection(connection)
print("ConnectionService client received: " + str(response) )
def listConnection():
with grpc.insecure_channel('localhost:50051') as channel:
stub = connectionService_pb2_grpc.ConnectionServiceStub(channel)
response = stub.ListConnection(google_dot_protobuf_dot_empty__pb2.Empty())
print("ConnectionService client received: " + str(response) )
if __name__ == '__main__':
createConnection()
listConnection()