Commit e0021a90 authored by Lluis Gifre Renom's avatar Lluis Gifre Renom
Browse files

Merge branch 'feat/hackfest-r2' of https://labs.etsi.org/rep/tfs/controller... 

Merge branch 'feat/hackfest-r2' of https://labs.etsi.org/rep/tfs/controller into feat/hackfest-accumulated-fixes
parents e7f79f5c 03939ecf

hackfest/commands.txt

+78 −11
Original line number Diff line number Diff line
@@ -115,6 +115,9 @@ python3 client_connection.py 
cd ~/tfs-ctrl/hackfest/tapi/server

pip install -r requirements.txt



cd ~/tfs-ctrl/hackfest/tapi/tapi_app

./requirements.sh



# (done) Build & Implement methods for the TAPI v2.1.3 server:

cd ~/tfs-ctrl/hackfest/tapi

wget https://repo1.maven.org/maven2/io/swagger/codegen/v3/swagger-codegen-cli/3.0.35/swagger-codegen-cli-3.0.35.jar
@@ -134,7 +137,7 @@ cd ~/tfs-ctrl/hackfest/tapi/server 
python3 -m tapi_server 8080 database/mini-ols-context.json



# Run TAPI client using cURL (In a new window):

$ cd ~/tfs-ctrl/hackfest/tapi/client

cd ~/tfs-ctrl/hackfest/tapi/client



# Interrogate Context and SIPs:

curl -X GET -H "Content-Type: application/json" http://127.0.0.1:8080/restconf/data/tapi-common:context/
@@ -163,6 +166,7 @@ curl -X DELETE -H "Content-Type: application/json" http://127.0.0.1:8080/restcon 




## EXERCISE



# Exercise: retrieve and draw the topology

# solution in folder tapi_app
@@ -175,24 +179,32 @@ python3 tapi_app.py 
# Deploy TeraFlowSDN

################################################################################



# Check status of Kubernetes

## GUIDED



# Check status of MicroK8s

microk8s.status --wait-ready



# If not running, start MicroK8s

microk8s.start



# Periodically inspect status of MicroK8s until all addons are enabled

watch -n 1 microk8s.status --wait-ready



# Check all resources in Kubernetes

microk8s.kubectl get all --all-namespaces

watch -n 1 kubectl get all --all-namespaces



# Deploy TeraFlowSDN

cd ~/tfs-ctrl

source my_deploy.sh 

./deploy.sh 

./deploy/all.sh 



# Show status of your deployment

(if new terminal) cd ~/tfs-ctrl && source my_deploy.sh

./show_deploy.sh 

./deploy/show.sh



# Show logs of a specific component

(if new terminal) cd ~/tfs-ctrl && source my_deploy.sh

scripts/show_logs_device.sh

./scripts/show_logs_device.sh
@@ -202,6 +214,8 @@ scripts/show_logs_device.sh 


# (done) Build a Netconf server supporting basic OpenConfig data model



## GUIDED



# Start the Netconf/OpenConfig server

cd ~/tfs-ctrl/hackfest/netconf-oc

python3 server_openconfig.py 8300
@@ -212,7 +226,8 @@ python3 server_openconfig.py 8300 
# Service requests

################################################################################



## L3VPN service from JSON descriptors

## EXERCISE

# Exercise: L3VPN service from JSON descriptors



# (in a new terminal) Start OLS TAPI server:

cd ~/tfs-ctrl/hackfest/tapi/server
@@ -236,9 +251,8 @@ python3 server_openconfig.py 8304 






############

# Mock OSM

############

## EXERCISE

# Exercise: L2VPN slice from Mock OSM



$ cd ~/tfs-ctrl/hackfest/

$ python -m mock_osm
@@ -262,12 +276,65 @@ Service b8c99e2c-39d8-424d-9833-554634269555 deleted 
(mock-osm) exit

Bye!







############

# gRPC

############



## GUIDED



# Generate connection messages from .proto

cd ~/tfs-ctrl/hackfest/grpc

python -m grpc_tools.protoc -I=. --python_out=connection/ connection.proto



# Create a connection message and save to a file

cd ~/tfs-ctrl/hackfest/grpc/connection

python3 create.py connection.txt 



# List a connection from a file

cd ~/tfs-ctrl/hackfest/grpc/connection

python3 list.py connection.txt 



# Build ConnectionService from .proto

cd ~/tfs-ctrl/hackfest/grpc

python -m grpc_tools.protoc -I=. --python_out=connectionService/ --grpc_python_out=connectionService/ connectionService.proto



# Start ConnectionService server

cd ~/tfs-ctrl/hackfest/grpc/connectionService

python3 connectionService_server.py



# Start ConnectionService client (in another terminal)

cd ~/tfs-ctrl/hackfest/grpc/connectionService

python3 connectionService_client.py





## EXERCISE

# Exercise: add streams



# Build ConnectionServiceWithNotif from .proto

cd ~/tfs-ctrl/hackfest/grpc

python -m grpc_tools.protoc -I=. --python_out=connectionServiceWithNotif/ --grpc_python_out=connectionServiceWithNotif/ connectionServiceWithNotif.proto



## Solution:

# Run ConnectionServiceWithNotif server

cd ~/tfs-ctrl/hackfest/grpc/connectionServiceWithNotif

python3 connectionServiceWithNotif_server.py



# Run ConnectionServiceWithNotif client (in another terminal)

$ cd ~/tfs-ctrl/hackfest/grpc/connectionServiceWithNotif

$ python3 connectionServiceWithNotif_client.py







############

# gNMI

############



## GUIDED



## Download and install the latest release

$ sudo bash -c "$(curl -sL https://get.containerlab.dev)“

$ sudo bash -c "$(curl -sL https://get.containerlab.dev)"



## Deploy proposed two SR node scenario

$ cd tfs-ctrl/hackfest/gnmi

hackfest/gnmi/sonic.clab.yml→hackfest/gnmi/srlinux.clab.yml

+6 −7
Original line number Diff line number Diff line
@@ -12,18 +12,17 @@ 
# See the License for the specific language governing permissions and

# limitations under the License.



# file: sonic.clab.yml

name: sonic-vs

# file: srlinux.clab.yml

name: srlinux



topology:

  nodes:

    srl1:

      kind: sonic-vs

      image: docker-sonic-vs

      kind: srl

      image: ghcr.io/nokia/srlinux

    srl2:

      kind: sonic-vs

      image: docker-sonic-vs

      kind: srl

      image: ghcr.io/nokia/srlinux



  links:

    - endpoints: ["srl1:e1-1", "srl2:e1-1"]

hackfest/grpc/connection/connection_pb2.py

+23 −152
Original line number Diff line number Diff line 
# -*- coding: utf-8 -*-

# Generated by the protocol buffer compiler.  DO NOT EDIT!

# source: connection.proto



import sys

_b=sys.version_info[0]<3 and (lambda x:x) or (lambda x:x.encode('latin1'))

"""Generated protocol buffer code."""

from google.protobuf import descriptor as _descriptor

from google.protobuf import descriptor_pool as _descriptor_pool

from google.protobuf import message as _message

from google.protobuf import reflection as _reflection

from google.protobuf import symbol_database as _symbol_database
@@ -14,163 +14,34 @@ _sym_db = _symbol_database.Default() 






DESCRIPTOR = _descriptor.FileDescriptor(

  name='connection.proto',

  package='connection',

  syntax='proto3',

  serialized_options=None,

  serialized_pb=_b('\n\x10\x63onnection.proto\x12\nconnection\"\xf5\x01\n\nConnection\x12\x14\n\x0c\x63onnectionId\x18\x01 \x01(\t\x12\x12\n\nsourceNode\x18\x02 \x01(\t\x12\x12\n\ntargetNode\x18\x03 \x01(\t\x12\x12\n\nsourcePort\x18\x04 \x01(\t\x12\x12\n\ntargetPort\x18\x05 \x01(\t\x12\x11\n\tbandwidth\x18\x06 \x01(\r\x12\x43\n\x11layerProtocolName\x18\x07 \x01(\x0e\x32(.connection.Connection.LayerProtocolName\")\n\x11LayerProtocolName\x12\x07\n\x03\x45TH\x10\x00\x12\x0b\n\x07OPTICAL\x10\x01\"<\n\x0e\x43onnectionList\x12*\n\nconnection\x18\x01 \x03(\x0b\x32\x16.connection.Connectionb\x06proto3')

)







_CONNECTION_LAYERPROTOCOLNAME = _descriptor.EnumDescriptor(

  name='LayerProtocolName',

  full_name='connection.Connection.LayerProtocolName',

  filename=None,

  file=DESCRIPTOR,

  values=[

    _descriptor.EnumValueDescriptor(

      name='ETH', index=0, number=0,

      serialized_options=None,

      type=None),

    _descriptor.EnumValueDescriptor(

      name='OPTICAL', index=1, number=1,

      serialized_options=None,

      type=None),

  ],

  containing_type=None,

  serialized_options=None,

  serialized_start=237,

  serialized_end=278,

)

_sym_db.RegisterEnumDescriptor(_CONNECTION_LAYERPROTOCOLNAME)





_CONNECTION = _descriptor.Descriptor(

  name='Connection',

  full_name='connection.Connection',

  filename=None,

  file=DESCRIPTOR,

  containing_type=None,

  fields=[

    _descriptor.FieldDescriptor(

      name='connectionId', full_name='connection.Connection.connectionId', index=0,

      number=1, type=9, cpp_type=9, label=1,

      has_default_value=False, default_value=_b("").decode('utf-8'),

      message_type=None, enum_type=None, containing_type=None,

      is_extension=False, extension_scope=None,

      serialized_options=None, file=DESCRIPTOR),

    _descriptor.FieldDescriptor(

      name='sourceNode', full_name='connection.Connection.sourceNode', index=1,

      number=2, type=9, cpp_type=9, label=1,

      has_default_value=False, default_value=_b("").decode('utf-8'),

      message_type=None, enum_type=None, containing_type=None,

      is_extension=False, extension_scope=None,

      serialized_options=None, file=DESCRIPTOR),

    _descriptor.FieldDescriptor(

      name='targetNode', full_name='connection.Connection.targetNode', index=2,

      number=3, type=9, cpp_type=9, label=1,

      has_default_value=False, default_value=_b("").decode('utf-8'),

      message_type=None, enum_type=None, containing_type=None,

      is_extension=False, extension_scope=None,

      serialized_options=None, file=DESCRIPTOR),

    _descriptor.FieldDescriptor(

      name='sourcePort', full_name='connection.Connection.sourcePort', index=3,

      number=4, type=9, cpp_type=9, label=1,

      has_default_value=False, default_value=_b("").decode('utf-8'),

      message_type=None, enum_type=None, containing_type=None,

      is_extension=False, extension_scope=None,

      serialized_options=None, file=DESCRIPTOR),

    _descriptor.FieldDescriptor(

      name='targetPort', full_name='connection.Connection.targetPort', index=4,

      number=5, type=9, cpp_type=9, label=1,

      has_default_value=False, default_value=_b("").decode('utf-8'),

      message_type=None, enum_type=None, containing_type=None,

      is_extension=False, extension_scope=None,

      serialized_options=None, file=DESCRIPTOR),

    _descriptor.FieldDescriptor(

      name='bandwidth', full_name='connection.Connection.bandwidth', index=5,

      number=6, type=13, cpp_type=3, label=1,

      has_default_value=False, default_value=0,

      message_type=None, enum_type=None, containing_type=None,

      is_extension=False, extension_scope=None,

      serialized_options=None, file=DESCRIPTOR),

    _descriptor.FieldDescriptor(

      name='layerProtocolName', full_name='connection.Connection.layerProtocolName', index=6,

      number=7, type=14, cpp_type=8, label=1,

      has_default_value=False, default_value=0,

      message_type=None, enum_type=None, containing_type=None,

      is_extension=False, extension_scope=None,

      serialized_options=None, file=DESCRIPTOR),

  ],

  extensions=[

  ],

  nested_types=[],

  enum_types=[

    _CONNECTION_LAYERPROTOCOLNAME,

  ],

  serialized_options=None,

  is_extendable=False,

  syntax='proto3',

  extension_ranges=[],

  oneofs=[

  ],

  serialized_start=33,

  serialized_end=278,

)



DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x10\x63onnection.proto\x12\nconnection\"\xf5\x01\n\nConnection\x12\x14\n\x0c\x63onnectionId\x18\x01 \x01(\t\x12\x12\n\nsourceNode\x18\x02 \x01(\t\x12\x12\n\ntargetNode\x18\x03 \x01(\t\x12\x12\n\nsourcePort\x18\x04 \x01(\t\x12\x12\n\ntargetPort\x18\x05 \x01(\t\x12\x11\n\tbandwidth\x18\x06 \x01(\r\x12\x43\n\x11layerProtocolName\x18\x07 \x01(\x0e\x32(.connection.Connection.LayerProtocolName\")\n\x11LayerProtocolName\x12\x07\n\x03\x45TH\x10\x00\x12\x0b\n\x07OPTICAL\x10\x01\"<\n\x0e\x43onnectionList\x12*\n\nconnection\x18\x01 \x03(\x0b\x32\x16.connection.Connectionb\x06proto3')



_CONNECTIONLIST = _descriptor.Descriptor(

  name='ConnectionList',

  full_name='connection.ConnectionList',

  filename=None,

  file=DESCRIPTOR,

  containing_type=None,

  fields=[

    _descriptor.FieldDescriptor(

      name='connection', full_name='connection.ConnectionList.connection', index=0,

      number=1, type=11, cpp_type=10, label=3,

      has_default_value=False, default_value=[],

      message_type=None, enum_type=None, containing_type=None,

      is_extension=False, extension_scope=None,

      serialized_options=None, file=DESCRIPTOR),

  ],

  extensions=[

  ],

  nested_types=[],

  enum_types=[

  ],

  serialized_options=None,

  is_extendable=False,

  syntax='proto3',

  extension_ranges=[],

  oneofs=[

  ],

  serialized_start=280,

  serialized_end=340,

)



_CONNECTION.fields_by_name['layerProtocolName'].enum_type = _CONNECTION_LAYERPROTOCOLNAME

_CONNECTION_LAYERPROTOCOLNAME.containing_type = _CONNECTION

_CONNECTIONLIST.fields_by_name['connection'].message_type = _CONNECTION

DESCRIPTOR.message_types_by_name['Connection'] = _CONNECTION

DESCRIPTOR.message_types_by_name['ConnectionList'] = _CONNECTIONLIST

_sym_db.RegisterFileDescriptor(DESCRIPTOR)



Connection = _reflection.GeneratedProtocolMessageType('Connection', (_message.Message,), dict(

  DESCRIPTOR = _CONNECTION,

  __module__ = 'connection_pb2'

_CONNECTION = DESCRIPTOR.message_types_by_name['Connection']

_CONNECTIONLIST = DESCRIPTOR.message_types_by_name['ConnectionList']

_CONNECTION_LAYERPROTOCOLNAME = _CONNECTION.enum_types_by_name['LayerProtocolName']

Connection = _reflection.GeneratedProtocolMessageType('Connection', (_message.Message,), {

  'DESCRIPTOR' : _CONNECTION,

  '__module__' : 'connection_pb2'

  # @@protoc_insertion_point(class_scope:connection.Connection)

  ))

  })

_sym_db.RegisterMessage(Connection)



ConnectionList = _reflection.GeneratedProtocolMessageType('ConnectionList', (_message.Message,), dict(

  DESCRIPTOR = _CONNECTIONLIST,

  __module__ = 'connection_pb2'

ConnectionList = _reflection.GeneratedProtocolMessageType('ConnectionList', (_message.Message,), {

  'DESCRIPTOR' : _CONNECTIONLIST,

  '__module__' : 'connection_pb2'

  # @@protoc_insertion_point(class_scope:connection.ConnectionList)

  ))

  })

_sym_db.RegisterMessage(ConnectionList)



if _descriptor._USE_C_DESCRIPTORS == False:



  DESCRIPTOR._options = None

  _CONNECTION._serialized_start=33

  _CONNECTION._serialized_end=278

  _CONNECTION_LAYERPROTOCOLNAME._serialized_start=237

  _CONNECTION_LAYERPROTOCOLNAME._serialized_end=278

  _CONNECTIONLIST._serialized_start=280

  _CONNECTIONLIST._serialized_end=340

# @@protoc_insertion_point(module_scope)

hackfest/grpc/connectionService/connectionService_pb2.py

+27 −187
Original line number Diff line number Diff line 
# -*- coding: utf-8 -*-

# Generated by the protocol buffer compiler.  DO NOT EDIT!

# source: connectionService.proto



import sys

_b=sys.version_info[0]<3 and (lambda x:x) or (lambda x:x.encode('latin1'))

"""Generated protocol buffer code."""

from google.protobuf import descriptor as _descriptor

from google.protobuf import descriptor_pool as _descriptor_pool

from google.protobuf import message as _message

from google.protobuf import reflection as _reflection

from google.protobuf import symbol_database as _symbol_database
@@ -15,197 +15,37 @@ _sym_db = _symbol_database.Default() 
from google.protobuf import empty_pb2 as google_dot_protobuf_dot_empty__pb2





DESCRIPTOR = _descriptor.FileDescriptor(

  name='connectionService.proto',

  package='connection',

  syntax='proto3',

  serialized_options=None,

  serialized_pb=_b('\n\x17\x63onnectionService.proto\x12\nconnection\x1a\x1bgoogle/protobuf/empty.proto\"\xf5\x01\n\nConnection\x12\x14\n\x0c\x63onnectionId\x18\x01 \x01(\t\x12\x12\n\nsourceNode\x18\x02 \x01(\t\x12\x12\n\ntargetNode\x18\x03 \x01(\t\x12\x12\n\nsourcePort\x18\x04 \x01(\t\x12\x12\n\ntargetPort\x18\x05 \x01(\t\x12\x11\n\tbandwidth\x18\x06 \x01(\r\x12\x43\n\x11layerProtocolName\x18\x07 \x01(\x0e\x32(.connection.Connection.LayerProtocolName\")\n\x11LayerProtocolName\x12\x07\n\x03\x45TH\x10\x00\x12\x0b\n\x07OPTICAL\x10\x01\"<\n\x0e\x43onnectionList\x12*\n\nconnection\x18\x01 \x03(\x0b\x32\x16.connection.Connection2\xa1\x01\n\x11\x43onnectionService\x12\x44\n\x10\x43reateConnection\x12\x16.connection.Connection\x1a\x16.google.protobuf.Empty\"\x00\x12\x46\n\x0eListConnection\x12\x16.google.protobuf.Empty\x1a\x1a.connection.ConnectionList\"\x00\x62\x06proto3')

  ,

  dependencies=[google_dot_protobuf_dot_empty__pb2.DESCRIPTOR,])







_CONNECTION_LAYERPROTOCOLNAME = _descriptor.EnumDescriptor(

  name='LayerProtocolName',

  full_name='connection.Connection.LayerProtocolName',

  filename=None,

  file=DESCRIPTOR,

  values=[

    _descriptor.EnumValueDescriptor(

      name='ETH', index=0, number=0,

      serialized_options=None,

      type=None),

    _descriptor.EnumValueDescriptor(

      name='OPTICAL', index=1, number=1,

      serialized_options=None,

      type=None),

  ],

  containing_type=None,

  serialized_options=None,

  serialized_start=273,

  serialized_end=314,

)

_sym_db.RegisterEnumDescriptor(_CONNECTION_LAYERPROTOCOLNAME)





_CONNECTION = _descriptor.Descriptor(

  name='Connection',

  full_name='connection.Connection',

  filename=None,

  file=DESCRIPTOR,

  containing_type=None,

  fields=[

    _descriptor.FieldDescriptor(

      name='connectionId', full_name='connection.Connection.connectionId', index=0,

      number=1, type=9, cpp_type=9, label=1,

      has_default_value=False, default_value=_b("").decode('utf-8'),

      message_type=None, enum_type=None, containing_type=None,

      is_extension=False, extension_scope=None,

      serialized_options=None, file=DESCRIPTOR),

    _descriptor.FieldDescriptor(

      name='sourceNode', full_name='connection.Connection.sourceNode', index=1,

      number=2, type=9, cpp_type=9, label=1,

      has_default_value=False, default_value=_b("").decode('utf-8'),

      message_type=None, enum_type=None, containing_type=None,

      is_extension=False, extension_scope=None,

      serialized_options=None, file=DESCRIPTOR),

    _descriptor.FieldDescriptor(

      name='targetNode', full_name='connection.Connection.targetNode', index=2,

      number=3, type=9, cpp_type=9, label=1,

      has_default_value=False, default_value=_b("").decode('utf-8'),

      message_type=None, enum_type=None, containing_type=None,

      is_extension=False, extension_scope=None,

      serialized_options=None, file=DESCRIPTOR),

    _descriptor.FieldDescriptor(

      name='sourcePort', full_name='connection.Connection.sourcePort', index=3,

      number=4, type=9, cpp_type=9, label=1,

      has_default_value=False, default_value=_b("").decode('utf-8'),

      message_type=None, enum_type=None, containing_type=None,

      is_extension=False, extension_scope=None,

      serialized_options=None, file=DESCRIPTOR),

    _descriptor.FieldDescriptor(

      name='targetPort', full_name='connection.Connection.targetPort', index=4,

      number=5, type=9, cpp_type=9, label=1,

      has_default_value=False, default_value=_b("").decode('utf-8'),

      message_type=None, enum_type=None, containing_type=None,

      is_extension=False, extension_scope=None,

      serialized_options=None, file=DESCRIPTOR),

    _descriptor.FieldDescriptor(

      name='bandwidth', full_name='connection.Connection.bandwidth', index=5,

      number=6, type=13, cpp_type=3, label=1,

      has_default_value=False, default_value=0,

      message_type=None, enum_type=None, containing_type=None,

      is_extension=False, extension_scope=None,

      serialized_options=None, file=DESCRIPTOR),

    _descriptor.FieldDescriptor(

      name='layerProtocolName', full_name='connection.Connection.layerProtocolName', index=6,

      number=7, type=14, cpp_type=8, label=1,

      has_default_value=False, default_value=0,

      message_type=None, enum_type=None, containing_type=None,

      is_extension=False, extension_scope=None,

      serialized_options=None, file=DESCRIPTOR),

  ],

  extensions=[

  ],

  nested_types=[],

  enum_types=[

    _CONNECTION_LAYERPROTOCOLNAME,

  ],

  serialized_options=None,

  is_extendable=False,

  syntax='proto3',

  extension_ranges=[],

  oneofs=[

  ],

  serialized_start=69,

  serialized_end=314,

)

DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x17\x63onnectionService.proto\x12\nconnection\x1a\x1bgoogle/protobuf/empty.proto\"\xf5\x01\n\nConnection\x12\x14\n\x0c\x63onnectionId\x18\x01 \x01(\t\x12\x12\n\nsourceNode\x18\x02 \x01(\t\x12\x12\n\ntargetNode\x18\x03 \x01(\t\x12\x12\n\nsourcePort\x18\x04 \x01(\t\x12\x12\n\ntargetPort\x18\x05 \x01(\t\x12\x11\n\tbandwidth\x18\x06 \x01(\r\x12\x43\n\x11layerProtocolName\x18\x07 \x01(\x0e\x32(.connection.Connection.LayerProtocolName\")\n\x11LayerProtocolName\x12\x07\n\x03\x45TH\x10\x00\x12\x0b\n\x07OPTICAL\x10\x01\"<\n\x0e\x43onnectionList\x12*\n\nconnection\x18\x01 \x03(\x0b\x32\x16.connection.Connection2\xa1\x01\n\x11\x43onnectionService\x12\x44\n\x10\x43reateConnection\x12\x16.connection.Connection\x1a\x16.google.protobuf.Empty\"\x00\x12\x46\n\x0eListConnection\x12\x16.google.protobuf.Empty\x1a\x1a.connection.ConnectionList\"\x00\x62\x06proto3')





_CONNECTIONLIST = _descriptor.Descriptor(

  name='ConnectionList',

  full_name='connection.ConnectionList',

  filename=None,

  file=DESCRIPTOR,

  containing_type=None,

  fields=[

    _descriptor.FieldDescriptor(

      name='connection', full_name='connection.ConnectionList.connection', index=0,

      number=1, type=11, cpp_type=10, label=3,

      has_default_value=False, default_value=[],

      message_type=None, enum_type=None, containing_type=None,

      is_extension=False, extension_scope=None,

      serialized_options=None, file=DESCRIPTOR),

  ],

  extensions=[

  ],

  nested_types=[],

  enum_types=[

  ],

  serialized_options=None,

  is_extendable=False,

  syntax='proto3',

  extension_ranges=[],

  oneofs=[

  ],

  serialized_start=316,

  serialized_end=376,

)



_CONNECTION.fields_by_name['layerProtocolName'].enum_type = _CONNECTION_LAYERPROTOCOLNAME

_CONNECTION_LAYERPROTOCOLNAME.containing_type = _CONNECTION

_CONNECTIONLIST.fields_by_name['connection'].message_type = _CONNECTION

DESCRIPTOR.message_types_by_name['Connection'] = _CONNECTION

DESCRIPTOR.message_types_by_name['ConnectionList'] = _CONNECTIONLIST

_sym_db.RegisterFileDescriptor(DESCRIPTOR)



Connection = _reflection.GeneratedProtocolMessageType('Connection', (_message.Message,), dict(

  DESCRIPTOR = _CONNECTION,

  __module__ = 'connectionService_pb2'

_CONNECTION = DESCRIPTOR.message_types_by_name['Connection']

_CONNECTIONLIST = DESCRIPTOR.message_types_by_name['ConnectionList']

_CONNECTION_LAYERPROTOCOLNAME = _CONNECTION.enum_types_by_name['LayerProtocolName']

Connection = _reflection.GeneratedProtocolMessageType('Connection', (_message.Message,), {

  'DESCRIPTOR' : _CONNECTION,

  '__module__' : 'connectionService_pb2'

  # @@protoc_insertion_point(class_scope:connection.Connection)

  ))

  })

_sym_db.RegisterMessage(Connection)



ConnectionList = _reflection.GeneratedProtocolMessageType('ConnectionList', (_message.Message,), dict(

  DESCRIPTOR = _CONNECTIONLIST,

  __module__ = 'connectionService_pb2'

ConnectionList = _reflection.GeneratedProtocolMessageType('ConnectionList', (_message.Message,), {

  'DESCRIPTOR' : _CONNECTIONLIST,

  '__module__' : 'connectionService_pb2'

  # @@protoc_insertion_point(class_scope:connection.ConnectionList)

  ))

  })

_sym_db.RegisterMessage(ConnectionList)







_CONNECTIONSERVICE = _descriptor.ServiceDescriptor(

  name='ConnectionService',

  full_name='connection.ConnectionService',

  file=DESCRIPTOR,

  index=0,

  serialized_options=None,

  serialized_start=379,

  serialized_end=540,

  methods=[

  _descriptor.MethodDescriptor(

    name='CreateConnection',

    full_name='connection.ConnectionService.CreateConnection',

    index=0,

    containing_service=None,

    input_type=_CONNECTION,

    output_type=google_dot_protobuf_dot_empty__pb2._EMPTY,

    serialized_options=None,

  ),

  _descriptor.MethodDescriptor(

    name='ListConnection',

    full_name='connection.ConnectionService.ListConnection',

    index=1,

    containing_service=None,

    input_type=google_dot_protobuf_dot_empty__pb2._EMPTY,

    output_type=_CONNECTIONLIST,

    serialized_options=None,

  ),

])

_sym_db.RegisterServiceDescriptor(_CONNECTIONSERVICE)



DESCRIPTOR.services_by_name['ConnectionService'] = _CONNECTIONSERVICE



_CONNECTIONSERVICE = DESCRIPTOR.services_by_name['ConnectionService']

if _descriptor._USE_C_DESCRIPTORS == False:



  DESCRIPTOR._options = None

  _CONNECTION._serialized_start=69

  _CONNECTION._serialized_end=314

  _CONNECTION_LAYERPROTOCOLNAME._serialized_start=273

  _CONNECTION_LAYERPROTOCOLNAME._serialized_end=314

  _CONNECTIONLIST._serialized_start=316

  _CONNECTIONLIST._serialized_end=376

  _CONNECTIONSERVICE._serialized_start=379

  _CONNECTIONSERVICE._serialized_end=540

# @@protoc_insertion_point(module_scope)

hackfest/grpc/connectionService/connectionService_pb2_grpc.py

+82 −46

File changed.

Preview size limit exceeded, changes collapsed.