| 85 | } |
| 86 | |
| 87 | func RegisterNodeAgentServer(s grpc.ServiceRegistrar, srv NodeAgentServer) { |
| 88 | // If the following call panics, it indicates UnimplementedNodeAgentServer was |
| 89 | // embedded by pointer and is nil. This will cause panics if an |
| 90 | // unimplemented method is ever invoked, so we test this at initialization |
| 91 | // time to prevent it from happening at runtime later due to I/O. |
| 92 | if t, ok := srv.(interface{ testEmbeddedByValue() }); ok { |
| 93 | t.testEmbeddedByValue() |
| 94 | } |
| 95 | s.RegisterService(&NodeAgent_ServiceDesc, srv) |
| 96 | } |
| 97 | |
| 98 | func _NodeAgent_Session_Handler(srv interface{}, stream grpc.ServerStream) error { |
| 99 | return srv.(NodeAgentServer).Session(&grpc.GenericServerStream[NodeMessage, ServerMessage]{ServerStream: stream}) |