Coverage for dak/policyqueue/v1/policyqueue_pb2_grpc.py: 57%

1# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT! 

2import grpc 

3 

4from dak.policyqueue.v1 import policyqueue_pb2 as dak_dot_policyqueue_dot_v1_dot_policyqueue__pb2 

5from google.protobuf import empty_pb2 as google_dot_protobuf_dot_empty__pb2 

6 

7 

8class PolicyQueueServiceStub(object): 

9 """PolicyQueueService manages uploads in policy queues. 

10 """ 

11 

12 def __init__(self, channel): 

13 """Constructor. 

14 

15 Args: 

16 channel: A grpc.Channel. 

17 """ 

18 self.ListUploads = channel.unary_unary( 

19 '/dak.policyqueue.v1.PolicyQueueService/ListUploads', 

20 request_serializer=dak_dot_policyqueue_dot_v1_dot_policyqueue__pb2.ListUploadsRequest.SerializeToString, 

21 response_deserializer=dak_dot_policyqueue_dot_v1_dot_policyqueue__pb2.ListUploadsResponse.FromString, 

22 ) 

23 self.GetUpload = channel.unary_unary( 

24 '/dak.policyqueue.v1.PolicyQueueService/GetUpload', 

25 request_serializer=dak_dot_policyqueue_dot_v1_dot_policyqueue__pb2.GetUploadRequest.SerializeToString, 

26 response_deserializer=dak_dot_policyqueue_dot_v1_dot_policyqueue__pb2.Upload.FromString, 

27 ) 

28 self.AddOverrides = channel.unary_unary( 

29 '/dak.policyqueue.v1.PolicyQueueService/AddOverrides', 

30 request_serializer=dak_dot_policyqueue_dot_v1_dot_policyqueue__pb2.AddOverridesRequest.SerializeToString, 

31 response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString, 

32 ) 

33 self.AcceptUpload = channel.unary_unary( 

34 '/dak.policyqueue.v1.PolicyQueueService/AcceptUpload', 

35 request_serializer=dak_dot_policyqueue_dot_v1_dot_policyqueue__pb2.AcceptUploadRequest.SerializeToString, 

36 response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString, 

37 ) 

38 self.RejectUpload = channel.unary_unary( 

39 '/dak.policyqueue.v1.PolicyQueueService/RejectUpload', 

40 request_serializer=dak_dot_policyqueue_dot_v1_dot_policyqueue__pb2.RejectUploadRequest.SerializeToString, 

41 response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString, 

42 ) 

43 

44 

45class PolicyQueueServiceServicer(object): 

46 """PolicyQueueService manages uploads in policy queues. 

47 """ 

48 

49 def ListUploads(self, request, context): 

50 """ListUploads returns uploads in the given policy queue. 

51 

52 Only the fields `name`, `policy_queue` and `target_suite` are 

53 included in the returned uploads. 

54 """ 

55 context.set_code(grpc.StatusCode.UNIMPLEMENTED) 

56 context.set_details('Method not implemented!') 

57 raise NotImplementedError('Method not implemented!') 

58 

59 def GetUpload(self, request, context): 

60 """GetUpload returns details for a single upload. 

61 """ 

62 context.set_code(grpc.StatusCode.UNIMPLEMENTED) 

63 context.set_details('Method not implemented!') 

64 raise NotImplementedError('Method not implemented!') 

65 

66 def AddOverrides(self, request, context): 

67 """AddOverrides adds overrides for an upload. 

68 

69 The new overrides must be missing, i.e., listed in the 

70 `missing_overrides` for the given upload. 

71 """ 

72 context.set_code(grpc.StatusCode.UNIMPLEMENTED) 

73 context.set_details('Method not implemented!') 

74 raise NotImplementedError('Method not implemented!') 

75 

76 def AcceptUpload(self, request, context): 

77 """AcceptUpload marks an upload for acceptance. 

78 """ 

79 context.set_code(grpc.StatusCode.UNIMPLEMENTED) 

80 context.set_details('Method not implemented!') 

81 raise NotImplementedError('Method not implemented!') 

82 

83 def RejectUpload(self, request, context): 

84 """RejectUpload rejects an upload. 

85 """ 

86 context.set_code(grpc.StatusCode.UNIMPLEMENTED) 

87 context.set_details('Method not implemented!') 

88 raise NotImplementedError('Method not implemented!') 

89 

90 

91def add_PolicyQueueServiceServicer_to_server(servicer, server): 

92 rpc_method_handlers = { 

93 'ListUploads': grpc.unary_unary_rpc_method_handler( 

94 servicer.ListUploads, 

95 request_deserializer=dak_dot_policyqueue_dot_v1_dot_policyqueue__pb2.ListUploadsRequest.FromString, 

96 response_serializer=dak_dot_policyqueue_dot_v1_dot_policyqueue__pb2.ListUploadsResponse.SerializeToString, 

97 ), 

98 'GetUpload': grpc.unary_unary_rpc_method_handler( 

99 servicer.GetUpload, 

100 request_deserializer=dak_dot_policyqueue_dot_v1_dot_policyqueue__pb2.GetUploadRequest.FromString, 

101 response_serializer=dak_dot_policyqueue_dot_v1_dot_policyqueue__pb2.Upload.SerializeToString, 

102 ), 

103 'AddOverrides': grpc.unary_unary_rpc_method_handler( 

104 servicer.AddOverrides, 

105 request_deserializer=dak_dot_policyqueue_dot_v1_dot_policyqueue__pb2.AddOverridesRequest.FromString, 

106 response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString, 

107 ), 

108 'AcceptUpload': grpc.unary_unary_rpc_method_handler( 

109 servicer.AcceptUpload, 

110 request_deserializer=dak_dot_policyqueue_dot_v1_dot_policyqueue__pb2.AcceptUploadRequest.FromString, 

111 response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString, 

112 ), 

113 'RejectUpload': grpc.unary_unary_rpc_method_handler( 

114 servicer.RejectUpload, 

115 request_deserializer=dak_dot_policyqueue_dot_v1_dot_policyqueue__pb2.RejectUploadRequest.FromString, 

116 response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString, 

117 ), 

118 } 

119 generic_handler = grpc.method_handlers_generic_handler( 

120 'dak.policyqueue.v1.PolicyQueueService', rpc_method_handlers) 

121 server.add_generic_rpc_handlers((generic_handler,))