Functions — github.com/CyberInnovationHub-NLD/OpenSourceDataDiode

hub / github.com/CyberInnovationHub-NLD/OpenSourceDataDiode / functions

Functions144 in github.com/CyberInnovationHub-NLD/OpenSourceDataDiode

Creates an IngressMockHandler struct. This struct starts sending UDP packets to the socket path supplied in the arguments.

protocol_handlers/ph_mock_handler/src/bin/ph_mock_ingress.rs:65

Functionmain

Creates an EgressMockHandler struct. This struct starts reading data from the socket path supplied in the arguments.

protocol_handlers/ph_mock_handler/src/bin/ph_mock_egress.rs:63

Functionmain

()

protocol_handlers/ph_kafka/src/bin/ph_kafka_test_consumer.rs:43

Functionmain

()

protocol_handlers/ph_kafka/src/bin/ph_kafka_egress.rs:27

Functionmain

()

protocol_handlers/ph_kafka/src/bin/ph_kafka_ingress.rs:29

Functionmain

()

protocol_handlers/ph_kafka/src/bin/ph_kafka_test_producer.rs:43

Functionmain

()

protocol_handlers/ph_udp/src/bin/ph_udp_ingress.rs:27

Functionmain

()

protocol_handlers/ph_udp/src/bin/ph_udp_egress.rs:26

Functionmain

()

filters/filter/src/bin/filter.rs:26

Methodnew

(host: &str)

framework/transport_udp/src/rx/udp_receiver.rs:26

Methodnew

creates a new InnerUdpReceiver struct. # Arguments `socket` - The udpSocket, used to receive data on. `bip_writer` - The BipBufferWriter used to write

framework/transport_udp/src/rx/inner_udp_receiver.rs:53

Methodnew

( host: &str, reader: BipBufferReader, send_delay_ms: u64, stats_data: Arc<Sta

framework/transport_udp/src/tx/udp_sender.rs:37

Methodnew

Creates a new instance of SocketReader This function will block until the socket has been created by a SocketWriter. # Arguments `path` - The path of

framework/socket_utils/src/socket_reader.rs:31

Methodnew

Creates a new instance of BufferedSocketReader This function will block until the socket has been created by a SocketWriter. # Arguments `path` - The

framework/socket_utils/src/buffered_socket_reader.rs:33

Methodnew

(path: &str)

protocol_handlers/ph_mock_handler/src/bin/ph_mock_ingress.rs:28

Methodnew

(path: &str)

protocol_handlers/ph_mock_handler/src/bin/ph_mock_egress.rs:29

Methodnew

(payload: &[u8], offset: i64, topic: &str)

protocol_handlers/ph_kafka/src/lib.rs:43

Methodnew

( host: &str, port: u16, in_replacement: String, out_replacement: String,

protocol_handlers/ph_kafka/src/producer.rs:37

Methodnew

( topic: &str, host: &str, port: u16, max_bytes: usize, stats_data: Ar

protocol_handlers/ph_kafka/src/consumer.rs:43

Methodnew

(topic: &str, miliseconds_to_wait: u64)

protocol_handlers/ph_kafka/tests/ph_kafka_integration_test.rs:97

Methodnew_size

(topic: &str, miliseconds_to_wait: u64, size: usize)

protocol_handlers/ph_kafka/tests/ph_kafka_integration_test.rs:114

Methodnew_standard

Creates a new instance of the statsdClient

statistics/statistics_handler/src/lib.rs:120

Methodnew_with_custom_fields

( custom_counter: Option<&str>, custom_gauge: Option<&str>, )

statistics/statistics_handler/src/lib.rs:132

Functionpacketloss_test

TODO: enable this again

framework/transport_udp/src/rx/mod.rs:154

Functionread_write_single_element_test

()

framework/socket_utils/src/lib.rs:31

Functionread_writer_packet_header_test

()

framework/transport_udp/src/rx/mod.rs:132

Methodreceive_data

This function fetches data from the socket. This data is then sent to the bip_buffer using the bipBufferWriter. This function will block until space i

framework/socket_utils/src/buffered_socket_reader.rs:59

Methodrun

This function is used to start the statsdClient. When this function is called the statsdClient starts sending statistics to the specified statsd serve

statistics/statistics_handler/src/lib.rs:167

Methodrun

This function is used to start the UdpReceiver. It will create and start a InnerUdpReceiver struct. The joinhandle to this struct is returned by the r

framework/transport_udp/src/rx/udp_receiver.rs:39

Methodrun

This function starts the InnerUdpReceiver state machine. This function will run on a seperate thread. # Returns `JoinHandle<()>` - The JoinHandle of t

framework/transport_udp/src/rx/inner_udp_receiver.rs:77

Methodsend_data

(&mut self, reader: &mut BipBufferReader)

framework/socket_utils/src/buffered_socket_writer.rs:46

Functionsend_message

()

framework/transport_udp/tests/receiver_test.rs:23

Functionserialization_test

()

framework/transport_udp/src/tx/mod.rs:92

Methodstart_listening

Creates a new instance of the SocketWriter # Arguments `path` - The path the socket is created on.

framework/socket_utils/src/socket_writer.rs:30

Methodstart_listening

Creates a new instance of the SocketWriter and starts accepting connections to the socket. # Arguments `path` - The path the socket is created on.

framework/socket_utils/src/buffered_socket_writer.rs:33

Methodstop

Stops the run loop of the statsdClient.

statistics/statistics_handler/src/lib.rs:178

Methodstop

This function is used to stop the UdpSender thread. It will also send shutdown messages to the UdpReceiver.

framework/transport_udp/src/tx/udp_sender.rs:83

Methodstop

Stops the SocketWriter. Calls Shutdown::Both on the underlying stream. After the stream is stopped, the socket file is removed.

framework/socket_utils/src/socket_writer.rs:79

Methodstop

(&self)

framework/socket_utils/src/buffered_socket_writer.rs:62

Methodstop

Stops the BufferedSocketReader. Calls Shutdown::Both on the underlying stream.

framework/socket_utils/src/buffered_socket_reader.rs:88

Functionupdate_state_16_messages_test

()

framework/transport_udp/src/rx/inner_udp_receiver.rs:308

Functionupdate_state_1_message_test

()

framework/transport_udp/src/rx/inner_udp_receiver.rs:253

Functionupdate_state_2_messages_test

()

framework/transport_udp/src/rx/inner_udp_receiver.rs:276

Functionwrite_read_bip_buffer

Is used to test reading and writing of multiple buffers to a bip_buffer.

framework/bip_utils/src/lib.rs:93

← previous101–144 of 144, ranked by callers