Skip to content

test_services_pb2_grpc

drunc.grpc_testing_tools.test_services_pb2_grpc

Client and server classes corresponding to protobuf-defined services.

Classes

ChildControllerService

Bases: object

Service for ChildController components

ChildControllerServiceServicer

Bases: object

Service for ChildController components

Functions
Kill(request, context)

Method for graceful shutdown of the ChildController service

Source code in drunc/grpc_testing_tools/test_services_pb2_grpc.py 
477
478
479
480
481
482
def Kill(self, request, context):
    """Method for graceful shutdown of the ChildController service
    """
    context.set_code(grpc.StatusCode.UNIMPLEMENTED)
    context.set_details('Method not implemented!')
    raise NotImplementedError('Method not implemented!')
MakeRequest(request, context)

Basic method for connectivity testing

Source code in drunc/grpc_testing_tools/test_services_pb2_grpc.py 
470
471
472
473
474
475
def MakeRequest(self, request, context):
    """Basic method for connectivity testing
    """
    context.set_code(grpc.StatusCode.UNIMPLEMENTED)
    context.set_details('Method not implemented!')
    raise NotImplementedError('Method not implemented!')

ChildControllerServiceStub(channel)

Bases: object

Service for ChildController components

Constructor.

Parameters:

Name Type Description Default
channel

A grpc.Channel.

 required
Source code in drunc/grpc_testing_tools/test_services_pb2_grpc.py 
448
449
450
451
452
453
454
455
456
457
458
459
460
461
462
463
def __init__(self, channel):
    """Constructor.

    Args:
        channel: A grpc.Channel.
    """
    self.MakeRequest = channel.unary_unary(
            '/test_services.ChildControllerService/MakeRequest',
            request_serializer=test__services__pb2.DummyRequest.SerializeToString,
            response_deserializer=test__services__pb2.DummyResponse.FromString,
            _registered_method=True)
    self.Kill = channel.unary_unary(
            '/test_services.ChildControllerService/Kill',
            request_serializer=test__services__pb2.KillRequest.SerializeToString,
            response_deserializer=test__services__pb2.KillResponse.FromString,
            _registered_method=True)
Functions

ManagerService

Bases: object

Service for Manager component

ManagerServiceServicer

Bases: object

Service for Manager component

Functions
Kill(request, context)

Method for graceful shutdown of the Manager service

Source code in drunc/grpc_testing_tools/test_services_pb2_grpc.py 
78
79
80
81
82
83
def Kill(self, request, context):
    """Method for graceful shutdown of the Manager service
    """
    context.set_code(grpc.StatusCode.UNIMPLEMENTED)
    context.set_details('Method not implemented!')
    raise NotImplementedError('Method not implemented!')
MakeRequest(request, context)

Basic method for connectivity testing

Source code in drunc/grpc_testing_tools/test_services_pb2_grpc.py 
64
65
66
67
68
69
def MakeRequest(self, request, context):
    """Basic method for connectivity testing
    """
    context.set_code(grpc.StatusCode.UNIMPLEMENTED)
    context.set_details('Method not implemented!')
    raise NotImplementedError('Method not implemented!')
ReceiveUpdate(request, context)

Method for receiving updates from RootController

Source code in drunc/grpc_testing_tools/test_services_pb2_grpc.py 
85
86
87
88
89
90
def ReceiveUpdate(self, request, context):
    """Method for receiving updates from RootController
    """
    context.set_code(grpc.StatusCode.UNIMPLEMENTED)
    context.set_details('Method not implemented!')
    raise NotImplementedError('Method not implemented!')
boot(request, context)

Boot other processes via the manager

Source code in drunc/grpc_testing_tools/test_services_pb2_grpc.py 
71
72
73
74
75
76
def boot(self, request, context):
    """Boot other processes via the manager 
    """
    context.set_code(grpc.StatusCode.UNIMPLEMENTED)
    context.set_details('Method not implemented!')
    raise NotImplementedError('Method not implemented!')

ManagerServiceStub(channel)

Bases: object

Service for Manager component

Constructor.

Parameters:

Name Type Description Default
channel

A grpc.Channel.

 required
Source code in drunc/grpc_testing_tools/test_services_pb2_grpc.py 
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
def __init__(self, channel):
    """Constructor.

    Args:
        channel: A grpc.Channel.
    """
    self.MakeRequest = channel.unary_unary(
            '/test_services.ManagerService/MakeRequest',
            request_serializer=test__services__pb2.DummyRequest.SerializeToString,
            response_deserializer=test__services__pb2.DummyResponse.FromString,
            _registered_method=True)
    self.boot = channel.unary_unary(
            '/test_services.ManagerService/boot',
            request_serializer=test__services__pb2.BootRequest.SerializeToString,
            response_deserializer=test__services__pb2.ProcessInstanceList.FromString,
            _registered_method=True)
    self.Kill = channel.unary_unary(
            '/test_services.ManagerService/Kill',
            request_serializer=test__services__pb2.KillRequest.SerializeToString,
            response_deserializer=test__services__pb2.KillResponse.FromString,
            _registered_method=True)
    self.ReceiveUpdate = channel.unary_unary(
            '/test_services.ManagerService/ReceiveUpdate',
            request_serializer=test__services__pb2.UpdateRequest.SerializeToString,
            response_deserializer=test__services__pb2.UpdateResponse.FromString,
            _registered_method=True)
Functions

RootControllerService

Bases: object

Service for RootController component (for testing connectivity to booted servers)

RootControllerServiceServicer

Bases: object

Service for RootController component (for testing connectivity to booted servers)

Functions
Kill(request, context)

Method for graceful shutdown

Source code in drunc/grpc_testing_tools/test_services_pb2_grpc.py 
279
280
281
282
283
284
def Kill(self, request, context):
    """Method for graceful shutdown
    """
    context.set_code(grpc.StatusCode.UNIMPLEMENTED)
    context.set_details('Method not implemented!')
    raise NotImplementedError('Method not implemented!')
MakeRequest(request, context)

Basic method for connectivity testing

Source code in drunc/grpc_testing_tools/test_services_pb2_grpc.py 
272
273
274
275
276
277
def MakeRequest(self, request, context):
    """Basic method for connectivity testing
    """
    context.set_code(grpc.StatusCode.UNIMPLEMENTED)
    context.set_details('Method not implemented!')
    raise NotImplementedError('Method not implemented!')
ReceiveCommand(request, context)

Method for receiving commands from Manager

Source code in drunc/grpc_testing_tools/test_services_pb2_grpc.py 
286
287
288
289
290
291
def ReceiveCommand(self, request, context):
    """Method for receiving commands from Manager
    """
    context.set_code(grpc.StatusCode.UNIMPLEMENTED)
    context.set_details('Method not implemented!')
    raise NotImplementedError('Method not implemented!')
ReceiveStatus(request, context)

Method for receiving status from ChildControllers

Source code in drunc/grpc_testing_tools/test_services_pb2_grpc.py 
293
294
295
296
297
298
def ReceiveStatus(self, request, context):
    """Method for receiving status from ChildControllers
    """
    context.set_code(grpc.StatusCode.UNIMPLEMENTED)
    context.set_details('Method not implemented!')
    raise NotImplementedError('Method not implemented!')

RootControllerServiceStub(channel)

Bases: object

Service for RootController component (for testing connectivity to booted servers)

Constructor.

Parameters:

Name Type Description Default
channel

A grpc.Channel.

 required
Source code in drunc/grpc_testing_tools/test_services_pb2_grpc.py 
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
def __init__(self, channel):
    """Constructor.

    Args:
        channel: A grpc.Channel.
    """
    self.MakeRequest = channel.unary_unary(
            '/test_services.RootControllerService/MakeRequest',
            request_serializer=test__services__pb2.DummyRequest.SerializeToString,
            response_deserializer=test__services__pb2.DummyResponse.FromString,
            _registered_method=True)
    self.Kill = channel.unary_unary(
            '/test_services.RootControllerService/Kill',
            request_serializer=test__services__pb2.KillRequest.SerializeToString,
            response_deserializer=test__services__pb2.KillResponse.FromString,
            _registered_method=True)
    self.ReceiveCommand = channel.unary_unary(
            '/test_services.RootControllerService/ReceiveCommand',
            request_serializer=test__services__pb2.CommandRequest.SerializeToString,
            response_deserializer=test__services__pb2.CommandResponse.FromString,
            _registered_method=True)
    self.ReceiveStatus = channel.unary_unary(
            '/test_services.RootControllerService/ReceiveStatus',
            request_serializer=test__services__pb2.StatusRequest.SerializeToString,
            response_deserializer=test__services__pb2.StatusResponse.FromString,
            _registered_method=True)
Functions