+ nDjUa0t$^RIHt^RIt^RIHtHt^RIHt^RI t ^RI H t H t ^RIHtHtHt^RI HtHt^RIHt]'d^RIt^R IHt^R IHtR R lt]],],tR ]R&RRRR/RRlltR8RRRR/RRllltR9RR/RRllltR9RR/RRllltR8RRllt RRRRRRRRR R!R"R/R#R$llt!R%RR&RRR/R'R(llt"]!R)4R8R*R+ll4t#R,R-R.RR/R0RRR1R!R2RR3R4R5RRRRR/ R6R7llt$R#):) annotationsN) TYPE_CHECKING TypeAlias) deprecated) BlueprintLikecreate_in_memory_blueprint) BinaryStreamRecordingStreamget_application_id)FileSinkGrpcSink) _spawn_viewer) Recording)r c V^8dQhRRRR/#) recordingRecordingStream | Nonereturnbool)formats"O/data/cameron/venvs/s3viz/lib/python3.14/site-packages/rerun_sdk/rerun/sinks.py __annotate__rs!!$:!t!ctVe!\P!VP4#\P!4#N)bindings is_enabledinnerrs&ris_recording_enabledr!s,""9??33     rr LogSinkLikedefault_blueprintrc(V^8dQhRRRRRRRR/#) rsinksr"r#BlueprintLike | NonerrrNoner)rs"rrr%s6OO O+O&O Orc \4p\4pVF-pWS9dVPV4KVPV4K/ V'd%\RRPRV44 24h\ V4'g\ P !R4R#\V4pVf \R4hRpVe\VVR7Pp\P!.VOTVeVP4MRR7R#) aX Stream data to multiple different sinks. Duplicate sinks are not allowed. For example, two [`rerun.GrpcSink`][]s that use the same `url` will cause this function to throw a `ValueError`. This _replaces_ existing sinks. Calling `rr.init(spawn=True)`, `rr.spawn()`, `rr.connect_grpc()` or similar followed by `set_sinks` will result in only the sinks passed to `set_sinks` remaining active. Only data logged _after_ the `set_sinks` call will be logged to the newly attached sinks. Parameters ---------- sinks: A list of sinks to wrap. See [`rerun.GrpcSink`][], [`rerun.FileSink`][], [`rerun.BinaryStream`][]. default_blueprint: Optionally set a default blueprint to use for this application. If the application already has an active blueprint, the new blueprint won't become active until the user clicks the "reset blueprint" button. If you want to activate the new blueprint immediately, instead use the [`rerun.send_blueprint`][] API. recording: Specifies the [`rerun.RecordingStream`][] to use. If left unspecified, defaults to the current active data recording, if there is one. See also: [`rerun.init`][], [`rerun.set_global_data_recording`][]. Example ------- ```py rr.init("rerun_example_tee") rr.set_sinks( rr.GrpcSink(), rr.FileSink("data.rrd") ) rr.log("my/point", rr.Points3D(position=[1.0, 2.0, 3.0])) ``` zDuplicate sinks detected: z, c38"TFp\V4xK R#5ir)str).0ds& r set_sinks..\s?[PZ1APZsz,Rerun is disabled - set_sinks() call ignoredNhNo application id found. You must call rerun.init before connecting to a viewer, or provide a recording.application_id blueprint)r#r) setadd ValueErrorjoinr!loggingwarningr rstorager set_sinks to_native)r#rr%seen duplicatessinkr1blueprint_storages$$* rr:r:%s^ 5DJ < NN4 HHTN  5dii?[PZ?[6[5\]^^  * *FG' 2N v  $6)'  '   %++4+@)%%'drc(V^8dQhRRRRRRRR/#) rurl str | Noner#r&rrrr'r)rs"rrrws277 7,7& 7  7rc&\V4'g\P!R4R#^RIHpV!V4pVf \ R4hRpVe\ VVR7Pp\P!TTVeVP4MRR7R#)az Connect to a remote Rerun Viewer on the given URL. This function returns immediately. Parameters ---------- url: The URL to connect to. The scheme must be one of `rerun://`, `rerun+http://`, or `rerun+https://`, and the pathname must be `/proxy`. The default is `rerun+http://127.0.0.1:9876/proxy`. default_blueprint: Optionally set a default blueprint to use for this application. If the application already has an active blueprint, the new blueprint won't become active until the user clicks the "reset blueprint" button. If you want to activate the new blueprint immediately, instead use the [`rerun.send_blueprint`][] API. recording: Specifies the [`rerun.RecordingStream`][] to use. If left unspecified, defaults to the current active data recording, if there is one. See also: [`rerun.init`][], [`rerun.set_global_data_recording`][]. z/Rerun is disabled - connect_grpc() call ignoredNr r/r0)rAr#r) r!r7r8rerun.recording_streamr r5rr9r connect_grpcr;)rAr#rr r1r?s&$$ rrFrFws> * *IJ9' 2N v  $6)'  '    ++4+@)%%'dr write_footerTc ,V^8dQhRRRRRRRRR R /#) rpathzstr | pathlib.Pathr#r&rrrGrrr'r)rs"rrrsADD D+D&D  D  Drc<\V4'g\P!R4R#^RIHpV!VR7pVf \ R4hRpVe\ VVR7Pp\P!\V4TVeVP4MRVR7R#)a8 Stream all log-data to a file. Call this _before_ you log any data! The Rerun Viewer is able to read continuously from the resulting rrd file while it is being written. However, depending on your OS and configuration, changes may not be immediately visible due to file caching. This is a common issue on Windows and (to a lesser extent) on MacOS. Parameters ---------- path: The path to save the data to. default_blueprint Optionally set a default blueprint to use for this application. If the application already has an active blueprint, the new blueprint won't become active until the user clicks the "reset blueprint" button. If you want to activate the new blueprint immediately, instead use the [`rerun.send_blueprint`][] API. recording: Specifies the [`rerun.RecordingStream`][] to use. If left unspecified, defaults to the current active data recording, if there is one. See also: [`rerun.init`][], [`rerun.set_global_data_recording`][]. write_footer: Whether to emit a complete RRD footer (including a manifest of every chunk) at the end of the stream. Defaults to `True`. Producing a footer keeps per-chunk metadata in memory for the lifetime of the sink, which grows linearly with the number of chunks logged. Pass `write_footer=False` for long-running streaming sessions; the resulting file is still a valid RRD and a footer can be added after the fact via `rerun rrd optimize`. *Warning*: lack of footer will significantly hurt random-access performance and some tools (e.g. LazyStore) may not work properly. \Rerun is disabled - save() call ignored. You must call rerun.init before saving a recording.NrDr r/r0)rIr#rrG) r!r7r8rEr r5rr9rsaver*r;)rIr#rrGr r1r?s&&&$ rrLrLsV * *vw9')\V4'g\P!R4R#^RIHpV!VR7pVf \ R4hRpVe\ VVR7Pp\P!TTTVeVP4MRTT;'g.R7#) a Serve log-data over gRPC. You can connect to this server with the native viewer using `rerun rerun+http://localhost:{grpc_port}/proxy`. The gRPC server will buffer all log data in memory so that late connecting viewers will get all the data. You can control the amount of data buffered by the gRPC server with the `server_memory_limit` argument. Once reached, the earliest logged data will be dropped. Static data is never dropped. Returns the URI of the server so you can connect the viewer to it. This function returns immediately. In order to keep the server running, you must keep the Python process running as well. NOTE: The grpc server is associated with a [`rerun.RecordingStream`][] object. By default, if no other recording was specified, this will be the global recording. When that `RecordingStream` is disconnected, or otherwise goes out of scope, the associated gRPC server will be shut down. See: [Issue: #12313](https://github.com/rerun-io/rerun/issues/12313) for possible complications. Parameters ---------- grpc_port: The port to serve the gRPC server on (defaults to 9876) default_blueprint: Optionally set a default blueprint to use for this application. If the application already has an active blueprint, the new blueprint won't become active until the user clicks the "reset blueprint" button. If you want to activate the new blueprint immediately, instead use the [`rerun.send_blueprint`][] API. recording: Specifies the [`rerun.RecordingStream`][] to use. If left unspecified, defaults to the current active data recording, if there is one. See also: [`rerun.init`][], [`rerun.set_global_data_recording`][]. server_memory_limit: Maximum amount of memory to use for buffering log data for clients that connect late. This can be a percentage of the total ram (e.g. "50%") or an absolute value (e.g. "4GB"). newest_first: If `True`, the server will start sending back the newest messages _first_. If `False`, the messages will be played back in the order they arrived. cors_allow_origin: Additional origin patterns allowed to make CORS requests to the gRPC server. By default, only localhost and rerun.io are allowed. Patterns are matched against the full `Origin` header (e.g. `"https://example.com:8080"`), using glob-style matching where `*` matches any sequence of characters. Examples: `"https://*.example.com"`, `"https://example.com:8080"`, `"https://example.com:*"`. z-Rerun is disabled - serve_grpc() call ignoredz[rerun is disabled]rDr Nr/r0)rTr#rrVrW) r!r7r8rEr r5rr9r serve_grpcr;) rSr#rrTrVrWr r1r?s $$$$$$ rrZrZLsp * *GH$9'):')r{s""+(!ITT ")6 ! "H,|; Y;O.2O)-Od7/37)- 77tD  DDN< <<~*S S/3S)- S & S  S+/Sl-- - )- -` j8S S S  S & S !& S  S #S #'S /3S )-S S r