Home
last modified time | relevance | path

Searched defs:String (Results 1 – 25 of 36) sorted by relevance

12

/xiu/library/streamhub/src/notify/
H A Dmod.rs12 on_publish_url: Option<String>, in new()
13 on_unpublish_url: Option<String>, in new()
14 on_play_url: Option<String>, in new()
15 on_stop_url: Option<String>, in new()
25 pub async fn on_publish_notify(&self, body: String) { in on_publish_notify()
44 pub async fn on_unpublish_notify(&self, body: String) { in on_unpublish_notify()
63 pub async fn on_play_notify(&self, body: String) { in on_play_notify()
82 pub async fn on_stop_notify(&self, body: String) { in on_stop_notify()
/xiu/application/http-server/src/
H A Dmain.rs33 async fn on_publish(body: String) { in on_publish()
37 async fn on_unpublish(body: String) { in on_unpublish()
41 async fn on_play(body: String) { in on_play()
45 async fn on_stop(body: String) { in on_stop()
/xiu/protocol/hls/src/
H A Dts.rs13 pub fn new(app_name: String, stream_name: String) -> Self { in new()
22 pub fn write(&mut self, data: BytesMut) -> Result<(String, String), MediaError> { in write() argument
32 pub fn delete(&mut self, ts_file_name: String) { in delete()
H A Dm3u8.rs21 name: String, in new()
22 path: String, in new()
62 app_name: String, in new()
63 stream_name: String, in new()
146 pub fn generate_m3u8_header(&self, is_vod: bool) -> String { in generate_m3u8_header()
162 pub fn refresh_playlist(&mut self) -> Result<String, MediaError> { in refresh_playlist()
H A Dflv_data_receiver.rs35 app_name: String, in new()
36 stream_name: String, in new()
97 app_name: String, in subscribe_from_rtmp_channels()
98 stream_name: String, in subscribe_from_rtmp_channels()
H A Dflv2hls.rs36 pub fn new(duration: i64, app_name: String, stream_name: String, need_record: bool) -> Self { in new()
/xiu/application/xiu/src/
H A Dapi.rs28 async fn root(&self) -> String { in root()
36 async fn get_stream_status(&self) -> Result<String> { in get_stream_status()
73 async fn kick_off_client(&self, id: KickOffClient) -> Result<String> { in kick_off_client()
/xiu/protocol/webrtc/src/session/
H A Dmod.rs248 app_name: String, in publish_whip()
249 stream_name: String, in publish_whip()
250 path: String, in publish_whip()
299 app_name: String, in unpublish_whip()
300 stream_name: String, in unpublish_whip()
323 app_name: String, in subscribe_whep()
324 stream_name: String, in subscribe_whep()
325 path: String, in subscribe_whep()
412 app_name: String, in unsubscribe_whep()
413 stream_name: String, in unsubscribe_whep()
/xiu/protocol/rtsp/src/http/
H A Dmod.rs20 pub fn get_header(&self, header_name: &String) -> Option<&String> { in get_header()
87 fn marshal(&self) -> String { in marshal()
159 fn marshal(&self) -> String { in marshal()
190 fn read_headers(reader: &mut dyn BufRead) -> Option<IndexMap<String, String>> { in read_headers() argument
/xiu/protocol/webrtc/src/http/
H A Dmod.rs18 fn marshal(&self) -> String; in marshal()
36 pub fn get_header(&self, header_name: &String) -> Option<&String> { in get_header()
128 fn marshal(&self) -> String { in marshal()
207 fn marshal(&self) -> String { in marshal()
243 fn read_headers(reader: &mut dyn BufRead) -> Option<IndexMap<String, String>> { in read_headers() argument
/xiu/protocol/rtmp/src/utils/
H A Dmod.rs77 pub fn parse_raw_stream_name(&mut self) -> (String, String) { in parse_raw_stream_name()
86 pub fn append_port(&mut self, port: String) { in append_port()
/xiu/protocol/rtmp/src/netstream/
H A Dwriter.rs45 stream_name: &String, in write_play()
91 stream_name: &String, in write_release_stream()
105 stream_name: &String, in write_fcpublish()
146 stream_name: &String, in write_publish()
147 stream_type: &String, in write_publish()
/xiu/protocol/rtmp/src/session/
H A Dcommon.rs297 app_name: String, in subscribe_from_channels()
298 stream_name: String, in subscribe_from_channels()
336 app_name: String, in unsubscribe_from_channels()
337 stream_name: String, in unsubscribe_from_channels()
359 app_name: String, in publish_to_channels()
360 stream_name: String, in publish_to_channels()
392 app_name: String, in unpublish_to_channels()
393 stream_name: String, in unpublish_to_channels()
H A Dclient_session.rs97 raw_domain_name: String, in new()
98 app_name: String, in new()
99 raw_stream_name: String, in new()
400 stream_name: &String, in send_publish()
401 stream_type: &String, in send_publish()
414 stream_name: &String, in send_play()
522 obj: &IndexMap<String, Amf0ValueType>, in on_status()
568 pub fn subscribe(&mut self, app_name: String, stream_name: String) { in subscribe()
/xiu/library/logger/src/
H A Dlogger.rs40 fn get_log_file_name(rotate: Rotate) -> String { in get_log_file_name()
90 path: String, in gen_log_file_thread_run()
140 pub fn new(level: &String, rotate: Option<Rotate>, path: Option<String>) -> Result<Logger> { in new()
/xiu/protocol/rtsp/src/
H A Dglobal_trait.rs8 fn marshal(&self) -> String; in marshal()
H A Drtsp.rs14 pub fn new(address: String, event_producer: StreamHubEventSender) -> Self { in new()
/xiu/protocol/httpflv/src/
H A Dhttpflv.rs41 app_name: String, in new()
42 stream_name: String, in new()
45 request_url: String, in new()
/xiu/protocol/rtsp/src/sdp/
H A Dfmtp.rs62 pub fn marshal(&self) -> String { in marshal()
120 fn marshal(&self) -> String { in marshal()
178 fn marshal(&self) -> String { in marshal()
251 fn marshal(&self) -> String { in marshal()
H A Dmod.rs37 fn marshal(&self) -> String { in marshal()
144 fn marshal(&self) -> String { in marshal()
304 fn marshal(&self) -> String { in marshal()
/xiu/protocol/rtmp/src/amf0/
H A Damf0_writer.rs78 properties: &IndexMap<String, Amf0ValueType>, in write_object()
94 properties: &IndexMap<String, Amf0ValueType>, in write_eacm_array()
/xiu/protocol/rtmp/src/
H A Drtmp.rs15 pub fn new(address: String, event_producer: StreamHubEventSender, gop_num: usize) -> Self { in new()
/xiu/protocol/rtmp/src/relay/
H A Dpush_client.rs19 address: String, in new()
H A Dpull_client.rs18 address: String, in new()
/xiu/protocol/webrtc/src/
H A Dwebrtc.rs21 pub fn new(address: String, event_producer: StreamHubEventSender) -> Self { in new()

12