kinesis_video_streamer_test.cpp
/tmp/ws/src/kinesis_video_streamer/kinesis_video_streamer/test/
kinesis__video__streamer__test_8cpp
kinesis_video_streamer/ros_stream_subscription_installer.h
kinesis_video_streamer/streamer.h
kinesis_video_streamer/subscriber_callbacks.h
kinesis_video_streamer_test_utils.h
KinesisVideoStreamerE2ETest
KinesisVideoStreamerTestBase
#define
ROS_POSTCALLBACK_ASSERT_TRUE
kinesis__video__streamer__test_8cpp.html
a0ff252ff8b06c58f00dc2347dc2291fc
(expr)
void
ImageTransportTestCallback
kinesis__video__streamer__test_8cpp.html
aa02a01a1cce5542c5887a01da2e0ebb4
(const KinesisStreamManagerInterface &stream_manager, std::string stream_name, const sensor_msgs::ImageConstPtr &image)
INSTANTIATE_TEST_CASE_P
kinesis__video__streamer__test_8cpp.html
a181cd7d5bc8630a31208cef63f331a6c
(End2EndTest, KinesisVideoStreamerE2ETest,::testing::ValuesIn(callback_tuples))
void
KinesisVideoFrameTransportTestCallback
kinesis__video__streamer__test_8cpp.html
a7ac87b2c034ef1293f7530fcbcee244f
(KinesisStreamManagerInterface &stream_manager, std::string stream_name, const kinesis_video_msgs::KinesisVideoFrame::ConstPtr &frame_msg)
int
main
kinesis__video__streamer__test_8cpp.html
a3c04138a5bfe5d72780bb7e82a18e627
(int argc, char **argv)
void
RekognitionEnabledKinesisVideoFrameTransportTestCallback
kinesis__video__streamer__test_8cpp.html
a46980b11ecfaaf8656f94e88a5e8eb1a
(KinesisStreamManagerInterface &stream_manager, std::string stream_name, const kinesis_video_msgs::KinesisVideoFrame::ConstPtr &frame_msg, const ros::Publisher &publisher)
void
rosout_logger_callback
kinesis__video__streamer__test_8cpp.html
a76b26a49a4c6c669cae521241fd1bc95
(const rosgraph_msgs::Log &published_log)
TEST
kinesis__video__streamer__test_8cpp.html
ab3f3d59596264c27a28fa1a09d6e2228
(StreamerGlobalSuite, rosParameterConstruction)
TEST_F
kinesis__video__streamer__test_8cpp.html
a9d667ad2f45376d01dc417b6ca2a8ac1
(KinesisVideoStreamerTestBase, sanity)
TEST_F
kinesis__video__streamer__test_8cpp.html
a5b1257716925aa4b1fbdb964fefba7b6
(KinesisVideoStreamerTestBase, invalidCallbackShouldReturnFalse)
TEST_F
kinesis__video__streamer__test_8cpp.html
aac5b7d20277e03e50361f7e3e405fd6e
(KinesisVideoStreamerTestBase, codecPrivateDataFailure)
TEST_F
kinesis__video__streamer__test_8cpp.html
add6515806eff236c59d97844329ef6cf
(KinesisVideoStreamerTestBase, invalidStreamDefinition)
TEST_F
kinesis__video__streamer__test_8cpp.html
a3c59f13e693443411e2da313874cc216
(KinesisVideoStreamerTestBase, streamInitializationFailures)
TEST_P
kinesis__video__streamer__test_8cpp.html
a87e7ed7b4848dd13e44939accb90a63d
(KinesisVideoStreamerE2ETest, E2ETest)
vector< tuple< Aws::Kinesis::KinesisVideoFrameTransportCallbackFn, Aws::Kinesis::ImageTransportCallbackFn, Aws::Kinesis::RekognitionEnabledKinesisVideoFrameTransportCallbackFn > >
callback_tuples
kinesis__video__streamer__test_8cpp.html
a98f8f876361d9084d8ce0e7fdc873ac8
constexpr double
kMultipleCallbacksWaitTime
kinesis__video__streamer__test_8cpp.html
a131c970fd9a3571e9ca2fd7bfc0d5048
queue< rosgraph_msgs::Log > *
kRosoutQueue
kinesis__video__streamer__test_8cpp.html
acf4e6fedbb2201f12c3f42d371cccbc3
constexpr double
kSingleCallbackWaitTime
kinesis__video__streamer__test_8cpp.html
aa1c903c5879701cedae8259da7e57fdb
TestData *
kTestData
kinesis__video__streamer__test_8cpp.html
a23d198713104c1ae2f6d74ffa8ed381a
kinesis_video_streamer_test_utils.h
/tmp/ws/src/kinesis_video_streamer/kinesis_video_streamer/test/
kinesis__video__streamer__test__utils_8h
kinesis_video_streamer/ros_stream_subscription_installer.h
kinesis_video_streamer/streamer.h
MockStreamDefinitionProvider
MockStreamManager
MockStreamSubscriptionInstaller
TestData
main.cpp
/tmp/ws/src/kinesis_video_streamer/kinesis_video_streamer/src/
main_8cpp
kinesis_video_streamer/ros_stream_subscription_installer.h
kinesis_video_streamer/streamer.h
kinesis_video_streamer/subscriber_callbacks.h
#define
RETURN_CODE_MASK
main_8cpp.html
ad80e99fec0b6df439ce6620e8f065efa
#define
UNKNOWN_ERROR_KINESIS_VIDEO_EXIT_CODE
main_8cpp.html
a12246ae70dadccafc456bca636446a62
int
main
main_8cpp.html
a0ddf1224851353fc92bfbff6f499fa97
(int argc, char *argv[])
int
shutdown
main_8cpp.html
a8c534622484aacaec934471ede9e7587
(Aws::SDKOptions options, int return_code)
constexpr char
kNodeName
main_8cpp.html
aa393db245e25ab858dea96ba1804d15b
[]
ros_stream_subscription_installer.cpp
/tmp/ws/src/kinesis_video_streamer/kinesis_video_streamer/src/
ros__stream__subscription__installer_8cpp
kinesis_video_streamer/ros_stream_subscription_installer.h
Aws
Aws::Kinesis
ros_stream_subscription_installer.h
/tmp/ws/src/kinesis_video_streamer/kinesis_video_streamer/include/kinesis_video_streamer/
ros__stream__subscription__installer_8h
kinesis_video_streamer/subscriber_callbacks.h
Aws::Kinesis::RosStreamSubscriptionInstaller
Aws
Aws::Kinesis
void(*
ImageTransportCallbackFn
namespaceAws_1_1Kinesis.html
a1004a5e90d3e994c73bb2fadd03bbde0
)(const KinesisStreamManagerInterface &stream_manager, std::string stream_name, const sensor_msgs::ImageConstPtr &image)
enum Aws::Kinesis::kinesis_stream_ros_input_type_e
KinesisStreamRosInputType
namespaceAws_1_1Kinesis.html
ac11a4a26f4556450c9dc09ef9fdcb5a8
void(*
KinesisVideoFrameTransportCallbackFn
namespaceAws_1_1Kinesis.html
a0834402a53d9b71aa3352bdbc0ae74e8
)(KinesisStreamManagerInterface &stream_manager, std::string stream_name, const kinesis_video_msgs::KinesisVideoFrame::ConstPtr &frame_msg)
void(*
RekognitionEnabledKinesisVideoFrameTransportCallbackFn
namespaceAws_1_1Kinesis.html
a4b0db1a1849581f866c787552dce6aa9
)(KinesisStreamManagerInterface &stream_manager, std::string stream_name, const kinesis_video_msgs::KinesisVideoFrame::ConstPtr &frame_msg, const ros::Publisher &publisher)
kinesis_stream_ros_input_type_e
namespaceAws_1_1Kinesis.html
acdf13ab29ff57c127db9df08c7e0e419
KINESIS_STREAM_INPUT_TYPE_KINESIS_VIDEO_FRAME
namespaceAws_1_1Kinesis.html
acdf13ab29ff57c127db9df08c7e0e419ad68444045fe3583b49f3108bff407821
KINESIS_STREAM_INPUT_TYPE_IMAGE_TRANSPORT
namespaceAws_1_1Kinesis.html
acdf13ab29ff57c127db9df08c7e0e419a962c90368a7faef1335f472d8dec9686
KINESIS_STREAM_INPUT_TYPE_REKOGNITION_ENABLED_KINESIS_VIDEO_FRAME
namespaceAws_1_1Kinesis.html
acdf13ab29ff57c127db9df08c7e0e419ab628fb0ecf1c3c542780788dea10f4f6
streamer.cpp
/tmp/ws/src/kinesis_video_streamer/kinesis_video_streamer/src/
streamer_8cpp
kinesis_video_streamer/ros_stream_subscription_installer.h
kinesis_video_streamer/streamer.h
kinesis_video_streamer/subscriber_callbacks.h
Aws
Aws::Kinesis
#define
RETURN_CODE_MASK
streamer_8cpp.html
ad80e99fec0b6df439ce6620e8f065efa
#define
UNKNOWN_ERROR_KINESIS_VIDEO_EXIT_CODE
streamer_8cpp.html
a12246ae70dadccafc456bca636446a62
constexpr char
kNodeName
streamer_8cpp.html
aa393db245e25ab858dea96ba1804d15b
[]
const char *
kSpinnerThreadCountOverrideParameter
streamer_8cpp.html
ab65e7aa766ecf98ae2eb3fb69f645bac
streamer.h
/tmp/ws/src/kinesis_video_streamer/kinesis_video_streamer/include/kinesis_video_streamer/
streamer_8h
Aws::Kinesis::StreamerNode
Aws
Aws::Kinesis
constexpr uint32_t
kDefaultNumberOfSpinnerThreads
namespaceAws_1_1Kinesis.html
a052e9c5b81f89ead81d0268bacd66ad6
streamer_node_test.cpp
/tmp/ws/src/kinesis_video_streamer/kinesis_video_streamer/test/
streamer__node__test_8cpp
kinesis_video_streamer/ros_stream_subscription_installer.h
kinesis_video_streamer/streamer.h
kinesis_video_streamer/subscriber_callbacks.h
MockRosStreamSubscriptionInstaller
TestStreamerNode
int
main
streamer__node__test_8cpp.html
a3c04138a5bfe5d72780bb7e82a18e627
(int argc, char **argv)
TEST_F
streamer__node__test_8cpp.html
a4de7bf84bbe0da5e0cd572c5077e986b
(TestStreamerNode, CreateNode)
TEST_F
streamer__node__test_8cpp.html
a81b1cc52987b3c340146e55c0667ba04
(TestStreamerNode, InitializeStreamerNode)
subscriber_callbacks.cpp
/tmp/ws/src/kinesis_video_streamer/kinesis_video_streamer/src/
subscriber__callbacks_8cpp
kinesis_video_streamer/subscriber_callbacks.h
Aws
Aws::Kinesis
#define
PUTFRAME_LOG_INTERVAL_IN_SECONDS
subscriber__callbacks_8cpp.html
ac03da5dd9d945246e239d76d612ec589
void
ImageTransportCallback
namespaceAws_1_1Kinesis.html
aed7eb4548d2e09c1fc1be51d019e0093
(const KinesisStreamManagerInterface &stream_manager, std::string stream_name, const sensor_msgs::ImageConstPtr &image)
void
KinesisVideoFrameTransportCallback
namespaceAws_1_1Kinesis.html
a22a504873fd0b9ca5c4d1b232b404ccb
(KinesisStreamManagerInterface &stream_manager, std::string stream_name, const kinesis_video_msgs::KinesisVideoFrame::ConstPtr &frame_msg)
void
RekognitionEnabledKinesisVideoFrameTransportCallback
namespaceAws_1_1Kinesis.html
ab2d042ed7b511f8e5b939c31445adc7f
(KinesisStreamManagerInterface &stream_manager, std::string stream_name, const kinesis_video_msgs::KinesisVideoFrame::ConstPtr &frame_msg, const ros::Publisher &publisher)
subscriber_callbacks.h
/tmp/ws/src/kinesis_video_streamer/kinesis_video_streamer/include/kinesis_video_streamer/
subscriber__callbacks_8h
Aws
Aws::Kinesis
void
ImageTransportCallback
namespaceAws_1_1Kinesis.html
aed7eb4548d2e09c1fc1be51d019e0093
(const KinesisStreamManagerInterface &stream_manager, std::string stream_name, const sensor_msgs::ImageConstPtr &image)
void
KinesisVideoFrameTransportCallback
namespaceAws_1_1Kinesis.html
a22a504873fd0b9ca5c4d1b232b404ccb
(KinesisStreamManagerInterface &stream_manager, std::string stream_name, const kinesis_video_msgs::KinesisVideoFrame::ConstPtr &frame_msg)
void
RekognitionEnabledKinesisVideoFrameTransportCallback
namespaceAws_1_1Kinesis.html
ab2d042ed7b511f8e5b939c31445adc7f
(KinesisStreamManagerInterface &stream_manager, std::string stream_name, const kinesis_video_msgs::KinesisVideoFrame::ConstPtr &frame_msg, const ros::Publisher &publisher)
KinesisVideoStreamerE2ETest
classKinesisVideoStreamerE2ETest.html
KinesisVideoStreamerTestBase
void
RunTest
classKinesisVideoStreamerE2ETest.html
a838c9f323e8ad268e93460b1313962bf
()
void
SetUp
classKinesisVideoStreamerE2ETest.html
a288a6bb0ebc58ba7471c060e966f3e95
()
void
TearDown
classKinesisVideoStreamerE2ETest.html
a21bfbc50eb415204bceae9da4e6f4c38
()
RosStreamSubscriptionInstaller *
real_subscription_installer
classKinesisVideoStreamerE2ETest.html
ab3f11a314df8157d296f7f996518f006
KinesisVideoStreamerTestBase
classKinesisVideoStreamerTestBase.html
void
SetUp
classKinesisVideoStreamerTestBase.html
a673d4c91f1393551e1f5270323b8556c
() override
void
TearDown
classKinesisVideoStreamerTestBase.html
aaf3d5c803b3b82e38b7a04be6c7a4260
() override
ros::NodeHandle
handle
classKinesisVideoStreamerTestBase.html
a3afccb38ae7c1d55188fda94bf86b3fa
TestParameterReader
parameter_reader
classKinesisVideoStreamerTestBase.html
aff694f9d75cc53c99af40c063856e118
StreamDefinitionProvider
real_stream_definition_provider
classKinesisVideoStreamerTestBase.html
a3187026e43fbad240b2e3afebb5de294
MockStreamDefinitionProvider *
stream_definition_provider
classKinesisVideoStreamerTestBase.html
a4ef0de9a675da5a4058b88fa8f996175
MockStreamManager *
stream_manager
classKinesisVideoStreamerTestBase.html
ab25abe70d34cdb9631d6060366e58f0b
MockStreamSubscriptionInstaller *
subscription_installer
classKinesisVideoStreamerTestBase.html
acdc3f319b81e780778b2fb4551d3157f
TestData
test_data
classKinesisVideoStreamerTestBase.html
aacb795ff5d01ba08c383da7d445c0c66
MockRosStreamSubscriptionInstaller
classMockRosStreamSubscriptionInstaller.html
Aws::Kinesis::RosStreamSubscriptionInstaller
MOCK_METHOD0
classMockRosStreamSubscriptionInstaller.html
a9d754bdd8ed747d7ae73a4fe7beb521d
(SetDefaultCallbacks, bool())
MOCK_METHOD1
classMockRosStreamSubscriptionInstaller.html
a04c434dd794f1541aac053fe78066532
(SetupImageTransport, bool(const ImageTransportCallbackFn callback))
MOCK_METHOD1
classMockRosStreamSubscriptionInstaller.html
a225b14e80aa0687e18bdc7d3337434b3
(set_stream_manager, void(KinesisStreamManagerInterface *stream_manager))
MockRosStreamSubscriptionInstaller
classMockRosStreamSubscriptionInstaller.html
a39ce371793a7fed8bf9c09a303b6a90f
(ros::NodeHandle &handle)
MockStreamDefinitionProvider
structMockStreamDefinitionProvider.html
Aws::Kinesis::StreamDefinitionProvider
KinesisManagerStatus
GetCodecPrivateData
structMockStreamDefinitionProvider.html
ae9eca4d7f565a651449aadea79f95079
(const ParameterPath &prefix, const ParameterReaderInterface &reader, PBYTE *out_codec_private_data, uint32_t *out_codec_private_data_size) const override
std::unique_ptr< StreamDefinition >
GetStreamDefinition
structMockStreamDefinitionProvider.html
a2d0544d8045613351302441cc4ae2bff
(const ParameterPath &prefix, const ParameterReaderInterface &reader, const PBYTE codec_private_data, uint32_t codec_private_data_size) const override
MockStreamDefinitionProvider
structMockStreamDefinitionProvider.html
a837ee656baea644728ce848f8e515c3c
(TestData *data)
TestData *
data_
structMockStreamDefinitionProvider.html
a24e166ae43aa5416d696085e8ee058bd
MockStreamManager
structMockStreamManager.html
Aws::Kinesis::KinesisStreamManagerInterface
KinesisManagerStatus
FetchRekognitionResults
structMockStreamManager.html
ad41d4dc6b664d7d7c9707d0e3f0b9fd0
(const std::string &stream_name, Aws::Vector< Model::Record > *records) override
void
FreeStream
structMockStreamManager.html
a679996e75e821e47fb7994e725932525
(std::string stream_name) override
KinesisManagerStatus
GenerateStreamSubscriptionDescriptor
structMockStreamManager.html
aec699c9a060d151b78ffc7d5b1feb60f
(int stream_idx, StreamSubscriptionDescriptor &descriptor) override
KinesisManagerStatus
InitializeStreamSubscription
structMockStreamManager.html
a52c1064ef25534c1e758cdaba9aa00b0
(const StreamSubscriptionDescriptor &descriptor) override
KinesisManagerStatus
InitializeVideoProducer
structMockStreamManager.html
abf496ee2af3ab0c9162c3e1461ecf5b0
(std::string region, std::unique_ptr< DeviceInfoProvider > device_info_provider, std::unique_ptr< ClientCallbackProvider > client_callback_provider, std::unique_ptr< StreamCallbackProvider > stream_callback_provider, std::unique_ptr< CredentialProvider > credential_provider, VideoProducerFactory video_producer_factory) override
KinesisManagerStatus
InitializeVideoProducer
structMockStreamManager.html
a3f54cb0ebf2f8a6288c742692782f246
(std::string region, VideoProducerFactory video_producer_factory) override
KinesisManagerStatus
InitializeVideoStream
structMockStreamManager.html
aba90c30c44e521a8cffd935312b8502d
(std::unique_ptr< StreamDefinition > stream_definition) override
KinesisManagerStatus
KinesisVideoStreamerSetup
structMockStreamManager.html
ae4bd4cd1d2409141120ed6e95029eff8
() override
MockStreamManager
structMockStreamManager.html
aa67c5be763bea42f4b4900dfe24b56ef
(TestData *data)
MockStreamManager
structMockStreamManager.html
a8d7bff69ebd3430d3a09a36b17d767df
(TestData *data, TestParameterReader *parameter_reader, StreamDefinitionProvider *stream_definition_provider, StreamSubscriptionInstaller *subscription_installer)
KinesisManagerStatus
ProcessCodecPrivateDataForStream
structMockStreamManager.html
a3e707dbb5c9bd1b34f915d7a7a0b5cc7
(const std::string &stream_name, std::vector< uint8_t > codec_private_data) override
KinesisManagerStatus
PutFrame
structMockStreamManager.html
abfb6293464fa57862b067059ea3ebe87
(std::string stream_name, Frame &frame) const override
KinesisManagerStatus
PutMetadata
structMockStreamManager.html
a086b32beae6ca4afcdabf1b049293298
(std::string stream_name, const std::string &name, const std::string &value) const
TestData *
data_
structMockStreamManager.html
ab15a0eebf63de035c69d325e55fecee6
MockStreamSubscriptionInstaller
structMockStreamSubscriptionInstaller.html
Aws::Kinesis::RosStreamSubscriptionInstaller
KinesisManagerStatus
Install
structMockStreamSubscriptionInstaller.html
aa292ccf4b30163804dbc22e9e673d274
(const StreamSubscriptionDescriptor &descriptor) const override
MockStreamSubscriptionInstaller
structMockStreamSubscriptionInstaller.html
a1beb62fa1128ca1f5a52108aaa7af05b
(TestData *data, Aws::Kinesis::KinesisStreamManagerInterface &stream_manager, ros::NodeHandle &handle)
void
Uninstall
structMockStreamSubscriptionInstaller.html
a23510dacc9cbc09e464845b2c32cfb8d
(std::string &topic_name)
TestData *
data_
structMockStreamSubscriptionInstaller.html
a31678ed2e63b2198bd46813bc350e901
Aws::Kinesis::RosStreamSubscriptionInstaller
classAws_1_1Kinesis_1_1RosStreamSubscriptionInstaller.html
Aws::Kinesis::StreamSubscriptionInstaller
RosStreamSubscriptionInstaller
classAws_1_1Kinesis_1_1RosStreamSubscriptionInstaller.html
ab7f65f2b6a8f18a0686f8e340882bfa1
(ros::NodeHandle &handle)
void
set_stream_manager
classAws_1_1Kinesis_1_1RosStreamSubscriptionInstaller.html
a19d2260f8cd8a4017ac3a70574f67a07
(KinesisStreamManagerInterface *stream_manager)
virtual bool
SetDefaultCallbacks
classAws_1_1Kinesis_1_1RosStreamSubscriptionInstaller.html
a4acd9f5438ebc967ef315a6646c4427c
()
bool
SetupImageTransport
classAws_1_1Kinesis_1_1RosStreamSubscriptionInstaller.html
a9b7f82366023c7d07b3d8c21dcc104ac
(const ImageTransportCallbackFn callback)
bool
SetupKinesisVideoFrameTransport
classAws_1_1Kinesis_1_1RosStreamSubscriptionInstaller.html
aae9021f1fb4bd7ee78c0cfb21ad19c07
(const KinesisVideoFrameTransportCallbackFn callback)
bool
SetupRekognitionEnabledKinesisVideoFrameTransport
classAws_1_1Kinesis_1_1RosStreamSubscriptionInstaller.html
a8e0d784f8a655f0f5ef779a32566184b
(const RekognitionEnabledKinesisVideoFrameTransportCallbackFn callback)
void
Uninstall
classAws_1_1Kinesis_1_1RosStreamSubscriptionInstaller.html
ab7badd81b66f0f5bb697748119a2683c
(const std::string &topic_name) override
ros::NodeHandle *
handle_
classAws_1_1Kinesis_1_1RosStreamSubscriptionInstaller.html
a95927f861f84a22cbff907722c9348fd
std::vector< image_transport::Subscriber >
image_transport_subscribers_
classAws_1_1Kinesis_1_1RosStreamSubscriptionInstaller.html
a8805df8a7de4abbfabb715015d377152
std::map< std::string, ros::Publisher >
publishers_
classAws_1_1Kinesis_1_1RosStreamSubscriptionInstaller.html
a4d56bd19522cdc2ce25e2a383ba955e9
std::vector< ros::Subscriber >
standard_subscribers_
classAws_1_1Kinesis_1_1RosStreamSubscriptionInstaller.html
a5a3ec233200cdb37d4f6a8aee3efaa3b
Aws::Kinesis::KinesisStreamManagerInterface *
stream_manager_
classAws_1_1Kinesis_1_1RosStreamSubscriptionInstaller.html
a129c7a2c2720b309595097d3c756c0ae
Aws::Kinesis::StreamerNode
classAws_1_1Kinesis_1_1StreamerNode.html
ros::NodeHandle
KinesisManagerStatus
Initialize
classAws_1_1Kinesis_1_1StreamerNode.html
a0061f7aeea733b35da7c79df43574d55
()
KinesisManagerStatus
InitializeStreamSubscriptions
classAws_1_1Kinesis_1_1StreamerNode.html
ad6b42d743afe37d3e3d16ed5a3d1b909
()
void
set_subscription_installer
classAws_1_1Kinesis_1_1StreamerNode.html
acc2cbbade533cc53ad107085d92859fa
(std::shared_ptr< RosStreamSubscriptionInstaller > subscription_installer)
void
Spin
classAws_1_1Kinesis_1_1StreamerNode.html
a9b724450dc07eb725dd682b5842a4620
()
StreamerNode
classAws_1_1Kinesis_1_1StreamerNode.html
ac0f7e3ba2aff9789d70a7b857d9ddeeb
(const std::string &ns)
~StreamerNode
classAws_1_1Kinesis_1_1StreamerNode.html
a9c5152bf81625c3b0252b0ae41e7701c
()=default
std::shared_ptr< Aws::Client::ParameterReaderInterface >
parameter_reader_
classAws_1_1Kinesis_1_1StreamerNode.html
a0c03f8928165acab5baff330291d7f4e
StreamDefinitionProvider
stream_definition_provider_
classAws_1_1Kinesis_1_1StreamerNode.html
a769830eb6f8c7d8834ba9c4a5f7e8b98
std::shared_ptr< KinesisStreamManager >
stream_manager_
classAws_1_1Kinesis_1_1StreamerNode.html
ab9cce11034dea9cbf41e3ad93cddd3df
std::shared_ptr< RosStreamSubscriptionInstaller >
subscription_installer_
classAws_1_1Kinesis_1_1StreamerNode.html
a735ee707b452cbb3305274c60749e2be
TestData
structTestData.html
void
Reset
structTestData.html
adaf5ea30fef74149e24cbb9eddc12d1c
()
uint32_t
fetch_rekognition_results_call_count
structTestData.html
ab0d437aff7dc9850641d3b163c79bf38
uint32_t
free_stream_call_count
structTestData.html
a8bc2ef3c5f6f51a078a88934c10bcfa0
uint32_t
get_codec_private_data_call_count
structTestData.html
af4317a9280ddc1fa8dd5093bcfeedd03
KinesisManagerStatus
get_codec_private_data_return_value
structTestData.html
a7d941d3f7fe5baa4c477d9fe85dee6ee
uint32_t
get_stream_definition_call_count
structTestData.html
a47ae1c93c1a981bd69c23a93bf87c613
StreamDefinition *
get_stream_definition_return_value
structTestData.html
af96d2531da8ccce1265e3aa4f8bd866b
uint32_t
image_callback_call_count
structTestData.html
a90813f99cb719fde0a011b8ece8618d1
uint32_t
initialize_video_producer_call_count
structTestData.html
a998aa08bbd13fed9fdfdb72c3a6e525c
KinesisManagerStatus
initialize_video_producer_return_value
structTestData.html
a10d7c8c5d1909063a4e98edc09978e15
uint32_t
initialize_video_stream_call_count
structTestData.html
a4575834324c40d2d6978532df0356c2e
KinesisManagerStatus
initialize_video_stream_return_value
structTestData.html
a9e2461ef1131d4c5224470c3b003cba2
uint32_t
kinesis_video_frame_callback_call_count
structTestData.html
ab613d21028ce666df79386fd3b26549d
uint32_t
process_codec_private_data_call_count
structTestData.html
a00aaa702b374de95d15d36f9f76641d4
KinesisManagerStatus
process_codec_private_data_return_value
structTestData.html
a879f623efb36a3a844469bcb72b10a1c
uint32_t
put_frame_call_count
structTestData.html
aa11ab006e2b3a7f2f662b2d0d99b7897
KinesisManagerStatus
put_frame_return_value
structTestData.html
a095e2030b138ed3e4980ab08f04c7d13
uint32_t
put_metadata_call_count
structTestData.html
a4f4df5f120b11158a2d0609ac58db989
KinesisManagerStatus
put_metadata_return_value
structTestData.html
a9b0498cb6e1940dab8661f76dc93f262
uint32_t
rekognition_kinesis_video_frame_callback_call_count
structTestData.html
aca3ec427f9c6f2b9d8fa4596a7cd7d64
uint32_t
subscribe_call_count
structTestData.html
a96ba8d25ac334fb5e20ddead9f13d5d5
KinesisManagerStatus
subscribe_return_value
structTestData.html
a2bb0e3abf6b2bbdfac817af148a06cf7
TestStreamerNode
classTestStreamerNode.html
void
SetUp
classTestStreamerNode.html
a2da235a71df05f7ebdc6ba9a771fbf32
() override
void
TearDown
classTestStreamerNode.html
afabace4aab847d5de9298fa2299cd179
() override
std::shared_ptr< MockRosStreamSubscriptionInstaller >
mock_subscription_installer_
classTestStreamerNode.html
a9b0849476aa07d39ca5e96f881333db3
std::shared_ptr< StreamerNode >
streamer_node_
classTestStreamerNode.html
ac64d3c56e2cc43d3692c6d1ba0c95631
Aws
namespaceAws.html
Aws::Kinesis
AwsError
namespaceAws.html
afd39ddc80dc548e50313cbb5d52e183a
AwsError
namespaceAws.html
afd39ddc80dc548e50313cbb5d52e183a
AwsError
namespaceAws.html
afd39ddc80dc548e50313cbb5d52e183a
AWS_ERR_ALREADY
namespaceAws.html
afd39ddc80dc548e50313cbb5d52e183aab8ff1234012a5cdd8584b01195bb8555
AWS_ERR_ALREADY
namespaceAws.html
afd39ddc80dc548e50313cbb5d52e183aab8ff1234012a5cdd8584b01195bb8555
AWS_ERR_ALREADY
namespaceAws.html
afd39ddc80dc548e50313cbb5d52e183aab8ff1234012a5cdd8584b01195bb8555
AWS_ERR_EMPTY
namespaceAws.html
afd39ddc80dc548e50313cbb5d52e183aab356b5a9fb3772ccdcc843e812f92941
AWS_ERR_EMPTY
namespaceAws.html
afd39ddc80dc548e50313cbb5d52e183aab356b5a9fb3772ccdcc843e812f92941
AWS_ERR_EMPTY
namespaceAws.html
afd39ddc80dc548e50313cbb5d52e183aab356b5a9fb3772ccdcc843e812f92941
AWS_ERR_FAILURE
namespaceAws.html
afd39ddc80dc548e50313cbb5d52e183aa8a1bd9cdabf8823d1cc3c6f25b9aed88
AWS_ERR_FAILURE
namespaceAws.html
afd39ddc80dc548e50313cbb5d52e183aa8a1bd9cdabf8823d1cc3c6f25b9aed88
AWS_ERR_FAILURE
namespaceAws.html
afd39ddc80dc548e50313cbb5d52e183aa8a1bd9cdabf8823d1cc3c6f25b9aed88
AWS_ERR_MEMORY
namespaceAws.html
afd39ddc80dc548e50313cbb5d52e183aab129a8355257c47ded173ba8ae02332c
AWS_ERR_MEMORY
namespaceAws.html
afd39ddc80dc548e50313cbb5d52e183aab129a8355257c47ded173ba8ae02332c
AWS_ERR_MEMORY
namespaceAws.html
afd39ddc80dc548e50313cbb5d52e183aab129a8355257c47ded173ba8ae02332c
AWS_ERR_NOT_ENOUGH_SPACE
namespaceAws.html
afd39ddc80dc548e50313cbb5d52e183aafdbd1b8e0b7d513bb86881fde98ec667
AWS_ERR_NOT_ENOUGH_SPACE
namespaceAws.html
afd39ddc80dc548e50313cbb5d52e183aafdbd1b8e0b7d513bb86881fde98ec667
AWS_ERR_NOT_ENOUGH_SPACE
namespaceAws.html
afd39ddc80dc548e50313cbb5d52e183aafdbd1b8e0b7d513bb86881fde98ec667
AWS_ERR_NOT_FOUND
namespaceAws.html
afd39ddc80dc548e50313cbb5d52e183aacf37003947fe3abb79d2e0f6ba5910ac
AWS_ERR_NOT_FOUND
namespaceAws.html
afd39ddc80dc548e50313cbb5d52e183aacf37003947fe3abb79d2e0f6ba5910ac
AWS_ERR_NOT_FOUND
namespaceAws.html
afd39ddc80dc548e50313cbb5d52e183aacf37003947fe3abb79d2e0f6ba5910ac
AWS_ERR_NOT_INITIALIZED
namespaceAws.html
afd39ddc80dc548e50313cbb5d52e183aa0e47051f8ea37f17be42e308476f355d
AWS_ERR_NOT_INITIALIZED
namespaceAws.html
afd39ddc80dc548e50313cbb5d52e183aa0e47051f8ea37f17be42e308476f355d
AWS_ERR_NOT_INITIALIZED
namespaceAws.html
afd39ddc80dc548e50313cbb5d52e183aa0e47051f8ea37f17be42e308476f355d
AWS_ERR_NOT_SUPPORTED
namespaceAws.html
afd39ddc80dc548e50313cbb5d52e183aa8a16fe6e50c247245f55bf889d92ba03
AWS_ERR_NOT_SUPPORTED
namespaceAws.html
afd39ddc80dc548e50313cbb5d52e183aa8a16fe6e50c247245f55bf889d92ba03
AWS_ERR_NOT_SUPPORTED
namespaceAws.html
afd39ddc80dc548e50313cbb5d52e183aa8a16fe6e50c247245f55bf889d92ba03
AWS_ERR_NULL_PARAM
namespaceAws.html
afd39ddc80dc548e50313cbb5d52e183aae7222ccbffb46d1b419539ecca1b2b46
AWS_ERR_NULL_PARAM
namespaceAws.html
afd39ddc80dc548e50313cbb5d52e183aae7222ccbffb46d1b419539ecca1b2b46
AWS_ERR_NULL_PARAM
namespaceAws.html
afd39ddc80dc548e50313cbb5d52e183aae7222ccbffb46d1b419539ecca1b2b46
AWS_ERR_OK
namespaceAws.html
afd39ddc80dc548e50313cbb5d52e183aa2dcf570438564ff2d67420db78923f16
AWS_ERR_OK
namespaceAws.html
afd39ddc80dc548e50313cbb5d52e183aa2dcf570438564ff2d67420db78923f16
AWS_ERR_OK
namespaceAws.html
afd39ddc80dc548e50313cbb5d52e183aa2dcf570438564ff2d67420db78923f16
AWS_ERR_PARAM
namespaceAws.html
afd39ddc80dc548e50313cbb5d52e183aad921dbddf3406b7fe5f859a1d811ed7f
AWS_ERR_PARAM
namespaceAws.html
afd39ddc80dc548e50313cbb5d52e183aad921dbddf3406b7fe5f859a1d811ed7f
AWS_ERR_PARAM
namespaceAws.html
afd39ddc80dc548e50313cbb5d52e183aad921dbddf3406b7fe5f859a1d811ed7f
AWS_ERR_TIMEOUT
namespaceAws.html
afd39ddc80dc548e50313cbb5d52e183aab86c01afb720fb92c5e376e9dd1e01fb
AWS_ERR_TIMEOUT
namespaceAws.html
afd39ddc80dc548e50313cbb5d52e183aab86c01afb720fb92c5e376e9dd1e01fb
AWS_ERR_TIMEOUT
namespaceAws.html
afd39ddc80dc548e50313cbb5d52e183aab86c01afb720fb92c5e376e9dd1e01fb
Aws::Kinesis
namespaceAws_1_1Kinesis.html
Aws::Kinesis::RosStreamSubscriptionInstaller
Aws::Kinesis::StreamerNode
void(*
ImageTransportCallbackFn
namespaceAws_1_1Kinesis.html
a1004a5e90d3e994c73bb2fadd03bbde0
)(const KinesisStreamManagerInterface &stream_manager, std::string stream_name, const sensor_msgs::ImageConstPtr &image)
enum Aws::Kinesis::kinesis_manager_status_e
KinesisManagerStatus
namespaceAws_1_1Kinesis.html
aaa92d18aaf5c7dd83386774c11401d90
int
KinesisStreamInputType
namespaceAws_1_1Kinesis.html
a22ea0bd15bac512620a722d928bf0fb6
enum Aws::Kinesis::kinesis_stream_ros_input_type_e
KinesisStreamRosInputType
namespaceAws_1_1Kinesis.html
ac11a4a26f4556450c9dc09ef9fdcb5a8
void(*
KinesisVideoFrameTransportCallbackFn
namespaceAws_1_1Kinesis.html
a0834402a53d9b71aa3352bdbc0ae74e8
)(KinesisStreamManagerInterface &stream_manager, std::string stream_name, const kinesis_video_msgs::KinesisVideoFrame::ConstPtr &frame_msg)
void(*
RekognitionEnabledKinesisVideoFrameTransportCallbackFn
namespaceAws_1_1Kinesis.html
a4b0db1a1849581f866c787552dce6aa9
)(KinesisStreamManagerInterface &stream_manager, std::string stream_name, const kinesis_video_msgs::KinesisVideoFrame::ConstPtr &frame_msg, const ros::Publisher &publisher)
std::function< bool(const StreamSubscriptionDescriptor &descriptor)>
SubscriberSetupFn
namespaceAws_1_1Kinesis.html
a93625d04b7779b0e424369ee73354435
kinesis_manager_status_e
namespaceAws_1_1Kinesis.html
a4cb12ab1c75f0d32282ff05b72d404c2
kinesis_stream_ros_input_type_e
namespaceAws_1_1Kinesis.html
acdf13ab29ff57c127db9df08c7e0e419
KINESIS_STREAM_INPUT_TYPE_KINESIS_VIDEO_FRAME
namespaceAws_1_1Kinesis.html
acdf13ab29ff57c127db9df08c7e0e419ad68444045fe3583b49f3108bff407821
KINESIS_STREAM_INPUT_TYPE_IMAGE_TRANSPORT
namespaceAws_1_1Kinesis.html
acdf13ab29ff57c127db9df08c7e0e419a962c90368a7faef1335f472d8dec9686
KINESIS_STREAM_INPUT_TYPE_REKOGNITION_ENABLED_KINESIS_VIDEO_FRAME
namespaceAws_1_1Kinesis.html
acdf13ab29ff57c127db9df08c7e0e419ab628fb0ecf1c3c542780788dea10f4f6
std::unique_ptr< com::amazonaws::kinesis::video::CredentialProvider >
CreateDefaultCredentialProvider
namespaceAws_1_1Kinesis.html
a7e5c3c21717913e7278e260a2313b2c4
()
Aws::Client::ParameterPath
GetKinesisVideoParameter
namespaceAws_1_1Kinesis.html
ab9318e70e8f5366590ed4b2d78310c10
(const char *parameter_name)
Aws::Client::ParameterPath
GetStreamParameterPath
namespaceAws_1_1Kinesis.html
aa9e39add1a35446c7a8a5187afb4bde1
(int stream_idx, const char *parameter_name)
Aws::Client::ParameterPath
GetStreamParameterPrefix
namespaceAws_1_1Kinesis.html
acfd73a4c7776bd587ad991e9e5f1912f
(int stream_idx)
void
ImageTransportCallback
namespaceAws_1_1Kinesis.html
aed7eb4548d2e09c1fc1be51d019e0093
(const KinesisStreamManagerInterface &stream_manager, std::string stream_name, const sensor_msgs::ImageConstPtr &image)
void
KinesisVideoFrameTransportCallback
namespaceAws_1_1Kinesis.html
a22a504873fd0b9ca5c4d1b232b404ccb
(KinesisStreamManagerInterface &stream_manager, std::string stream_name, const kinesis_video_msgs::KinesisVideoFrame::ConstPtr &frame_msg)
void
RekognitionEnabledKinesisVideoFrameTransportCallback
namespaceAws_1_1Kinesis.html
ab2d042ed7b511f8e5b939c31445adc7f
(KinesisStreamManagerInterface &stream_manager, std::string stream_name, const kinesis_video_msgs::KinesisVideoFrame::ConstPtr &frame_msg, const ros::Publisher &publisher)
constexpr uint32_t
kDefaultMessageQueueSize
namespaceAws_1_1Kinesis.html
a51d9032626464e31563c39be8c33f297
constexpr uint32_t
kDefaultNumberOfSpinnerThreads
namespaceAws_1_1Kinesis.html
a052e9c5b81f89ead81d0268bacd66ad6
constexpr uint16_t
kDefaultRecordsLimitForRekognitionResults
namespaceAws_1_1Kinesis.html
a5b661261ed15c179d462d0623dff3f8e
KINESIS_MANAGER_STATUS_BASE64DECODE_FAILED
namespaceAws_1_1Kinesis.html
a4cb12ab1c75f0d32282ff05b72d404c2a49244f616c539043f8f102ffbabd81c8
KINESIS_MANAGER_STATUS_CREATESTREAMSYNC_FAILED
namespaceAws_1_1Kinesis.html
a4cb12ab1c75f0d32282ff05b72d404c2a616a18b65fd1dbd015368d93d67dc4ba
KINESIS_MANAGER_STATUS_DEFAULT_CREDENTIAL_PROVIDER_CREATION_FAILED
namespaceAws_1_1Kinesis.html
a4cb12ab1c75f0d32282ff05b72d404c2a869384092bc493690e7a234b6955b7f5
KINESIS_MANAGER_STATUS_EMPTY_STREAM_NAME
namespaceAws_1_1Kinesis.html
a4cb12ab1c75f0d32282ff05b72d404c2ac05f1994cf4e2bac0014680a9ee09e87
KINESIS_MANAGER_STATUS_ERROR_BASE
namespaceAws_1_1Kinesis.html
a4cb12ab1c75f0d32282ff05b72d404c2ae8a78b06e905352be5846e9974daffbc
KINESIS_MANAGER_STATUS_GET_RECORDS_FAILED
namespaceAws_1_1Kinesis.html
a4cb12ab1c75f0d32282ff05b72d404c2aee5ea822d76b7485b6a17fb243c62b13
KINESIS_MANAGER_STATUS_GET_RECORDS_THROTTLED
namespaceAws_1_1Kinesis.html
a4cb12ab1c75f0d32282ff05b72d404c2a83a2919b9615485945983f15597e2c1b
KINESIS_MANAGER_STATUS_GET_SHARD_ITERATOR_FAILED
namespaceAws_1_1Kinesis.html
a4cb12ab1c75f0d32282ff05b72d404c2ae5af6795e03e7de6187d02fa3aea2ecd
KINESIS_MANAGER_STATUS_GET_STREAM_DEFINITION_FAILED
namespaceAws_1_1Kinesis.html
a4cb12ab1c75f0d32282ff05b72d404c2a1c2680d73b6e453b943c04606f2aff13
KINESIS_MANAGER_STATUS_INVALID_INPUT
namespaceAws_1_1Kinesis.html
a4cb12ab1c75f0d32282ff05b72d404c2a00f272e6f9726d761663655442c98aa3
KINESIS_MANAGER_STATUS_LIST_SHARDS_EMPTY
namespaceAws_1_1Kinesis.html
a4cb12ab1c75f0d32282ff05b72d404c2a476b47aeea9e011d2d31c5035e73c6dd
KINESIS_MANAGER_STATUS_LIST_SHARDS_FAILED
namespaceAws_1_1Kinesis.html
a4cb12ab1c75f0d32282ff05b72d404c2a984ed82a91545aace3b137bffd5c02b2
KINESIS_MANAGER_STATUS_MALLOC_FAILED
namespaceAws_1_1Kinesis.html
a4cb12ab1c75f0d32282ff05b72d404c2a17b60f122eb1d0beae7988c6a6856a7a
KINESIS_MANAGER_STATUS_NO_STREAMS_SPECIFIED
namespaceAws_1_1Kinesis.html
a4cb12ab1c75f0d32282ff05b72d404c2a926c43bef41ac3d78cddaea160e1eee1
KINESIS_MANAGER_STATUS_PROCESS_CODEC_DATA_STREAM_CONFIG_NOT_FOUND
namespaceAws_1_1Kinesis.html
a4cb12ab1c75f0d32282ff05b72d404c2a3405b1473b7812a3abf396f7b5811ae1
KINESIS_MANAGER_STATUS_PUTFRAME_FAILED
namespaceAws_1_1Kinesis.html
a4cb12ab1c75f0d32282ff05b72d404c2a2798db152e8d807fd7d95d9ca9985eb2
KINESIS_MANAGER_STATUS_PUTFRAME_STREAM_NOT_FOUND
namespaceAws_1_1Kinesis.html
a4cb12ab1c75f0d32282ff05b72d404c2ae7aa1667666eaecc19eb0108016b03c0
KINESIS_MANAGER_STATUS_PUTMETADATA_FAILED
namespaceAws_1_1Kinesis.html
a4cb12ab1c75f0d32282ff05b72d404c2a96a45cb794cad1fd4704f7ef8c605b50
KINESIS_MANAGER_STATUS_PUTMETADATA_STREAM_NOT_FOUND
namespaceAws_1_1Kinesis.html
a4cb12ab1c75f0d32282ff05b72d404c2a992fac1633b67cee8222c2264994b363
KINESIS_MANAGER_STATUS_STREAM_ALREADY_EXISTS
namespaceAws_1_1Kinesis.html
a4cb12ab1c75f0d32282ff05b72d404c2a04b563b8c9f5d338605676c36f8ae6cb
KINESIS_MANAGER_STATUS_SUBSCRIPTION_INSTALLATION_FAILED
namespaceAws_1_1Kinesis.html
a4cb12ab1c75f0d32282ff05b72d404c2ab6a0c7e851903cc6c9f409056101776f
KINESIS_MANAGER_STATUS_SUBSCRIPTION_INSTALLER_NOT_FOUND
namespaceAws_1_1Kinesis.html
a4cb12ab1c75f0d32282ff05b72d404c2a66ff9a888ad511fc7d986aa0195df547
KINESIS_MANAGER_STATUS_SUCCESS
namespaceAws_1_1Kinesis.html
a4cb12ab1c75f0d32282ff05b72d404c2ada4f0a0b980886d6aaea7fbdf34ce8fb
KINESIS_MANAGER_STATUS_VIDEO_PRODUCER_ALREADY_INITIALIZED
namespaceAws_1_1Kinesis.html
a4cb12ab1c75f0d32282ff05b72d404c2a2775ba14746832db10905efd99aff893
KINESIS_MANAGER_STATUS_VIDEO_PRODUCER_NOT_INITIALIZED
namespaceAws_1_1Kinesis.html
a4cb12ab1c75f0d32282ff05b72d404c2ae37ab1c1f9c3274b7ad18c6f7e4f1429
const struct Aws::Kinesis::@0
kinesis_video
namespaceAws_1_1Kinesis.html
a77974829376a5042846651981c36d454
const char *
log4cplus_config
namespaceAws_1_1Kinesis.html
af483df345cb66b0d11ede31142bb409e
const char *
message_queue_size
namespaceAws_1_1Kinesis.html
a575028c985ab7577b65963e581c5b05c
const char *
prefix
namespaceAws_1_1Kinesis.html
ad08e639efffd6ccbf696f95d8222dbfb
const char *
rekognition_data_stream
namespaceAws_1_1Kinesis.html
a3d546d8c6008bf97eaa6b07dc5d39bbb
const char *
rekognition_topic_name
namespaceAws_1_1Kinesis.html
ae961f8addbfa55ebd6965355e88a9f58
const struct Aws::Kinesis::@0
stream
namespaceAws_1_1Kinesis.html
a946f8ff8a7a655f19fe689858dadd36e
const char *
stream_count
namespaceAws_1_1Kinesis.html
a7070b9b3d3048e2eea35944916f40e04
const char *
stream_name
namespaceAws_1_1Kinesis.html
a18e67a107d5c9d3dc9258054a7248844
const char *
stream_namespace
namespaceAws_1_1Kinesis.html
ac5645ddbe9ffda30502ec4c7908558ff
const struct Aws::Kinesis::@0
subscription_queue_size
namespaceAws_1_1Kinesis.html
a53284d0fa1e3785bb9da9d5f7fdeccc0
const struct Aws::Kinesis::@0
subscription_topic
namespaceAws_1_1Kinesis.html
a911c938151fdcdfd53226c7a0c196b59
const char *
topic_name
namespaceAws_1_1Kinesis.html
abeff6f3d16a314c3ffe76f0710de2245
const char *
topic_type
namespaceAws_1_1Kinesis.html
a344b0b670cad2452e90d411f22dead4b