3
3
use arrow:: array:: RecordBatch ;
4
4
use pyo3:: { prelude:: * , Bound , PyResult } ;
5
5
6
- use re_grpc_client:: message_proxy:: write_table:: table_client ;
6
+ use re_grpc_client:: message_proxy:: write_table:: viewer_client ;
7
7
use re_log_encoding:: codec:: wire:: encoder:: Encode as _;
8
8
use re_protos:: sdk_comms:: v1alpha1:: message_proxy_service_client:: MessageProxyServiceClient ;
9
9
@@ -19,7 +19,7 @@ pub(crate) fn register(_py: Python<'_>, m: &Bound<'_, PyModule>) -> PyResult<()>
19
19
/// A connection to an instance of a Rerun viewer.
20
20
#[ pyclass( name = "ViewerClient" ) ]
21
21
pub struct PyViewerClient {
22
- conn : TableConnectionHandle ,
22
+ conn : ViewerConnectionHandle ,
23
23
}
24
24
#[ pymethods]
25
25
impl PyViewerClient {
@@ -29,7 +29,7 @@ impl PyViewerClient {
29
29
fn new ( py : Python < ' _ > , addr : String ) -> PyResult < Self > {
30
30
let origin = addr. as_str ( ) . parse :: < re_uri:: Origin > ( ) . map_err ( to_py_err) ?;
31
31
32
- let conn = TableConnectionHandle :: new ( py, origin. clone ( ) ) ?;
32
+ let conn = ViewerConnectionHandle :: new ( py, origin. clone ( ) ) ?;
33
33
34
34
Ok ( Self { conn } )
35
35
}
@@ -55,19 +55,19 @@ impl PyViewerClient {
55
55
/// table-related operations, most importantly `WriteTable`.
56
56
// TODO(grtlr): In the future, we probably want to merge this with the other APIs.
57
57
#[ derive( Clone ) ]
58
- pub struct TableConnectionHandle {
58
+ pub struct ViewerConnectionHandle {
59
59
client : MessageProxyServiceClient < tonic:: transport:: Channel > ,
60
60
}
61
61
62
- impl TableConnectionHandle {
62
+ impl ViewerConnectionHandle {
63
63
pub fn new ( py : Python < ' _ > , origin : re_uri:: Origin ) -> PyResult < Self > {
64
- let client = wait_for_future ( py, table_client ( origin. clone ( ) ) ) . map_err ( to_py_err) ?;
64
+ let client = wait_for_future ( py, viewer_client ( origin. clone ( ) ) ) . map_err ( to_py_err) ?;
65
65
66
66
Ok ( Self { client } )
67
67
}
68
68
}
69
69
70
- impl TableConnectionHandle {
70
+ impl ViewerConnectionHandle {
71
71
fn send_table (
72
72
& mut self ,
73
73
py : Python < ' _ > ,
0 commit comments