Class GStreamerPipeline#

Class Documentation#

class GStreamerPipeline#

Public Functions

GStreamerPipeline()#
~GStreamerPipeline()#
GStreamerPipeline(const GStreamerPipeline&) = delete#
GStreamerPipeline &operator=(const GStreamerPipeline&) = delete#
GStreamerPipeline(GStreamerPipeline&&) noexcept#
GStreamerPipeline &operator=(GStreamerPipeline&&) noexcept#
std::expected<void, GStreamerError> create_pipeline(const PipelineConfig &config)#
std::expected<void, GStreamerError> create_pipeline_from_string(const std::string &description)#
std::expected<void, GStreamerError> create_inference_pipeline(const std::string &input_source, const std::string &model_path, const std::vector<std::size_t> &input_shape, const std::string &output_format = "RAW")#
std::expected<void, GStreamerError> start()#
std::expected<void, GStreamerError> stop()#
std::expected<void, GStreamerError> pause()#
std::expected<void, GStreamerError> resume()#
bool is_playing() const#
bool is_paused() const#
void set_buffer_callback(BufferCallback callback)#
std::expected<BufferInfo, GStreamerError> pull_sample(std::uint32_t timeout_ms = 5000)#
std::expected<void, GStreamerError> push_buffer(void *data, std::size_t size, const FrameMetadata &metadata)#
std::expected<std::uint64_t, GStreamerError> get_position_ns() const#
std::expected<std::uint64_t, GStreamerError> get_duration_ns() const#
std::expected<void, GStreamerError> seek(std::uint64_t timestamp_ns)#
std::string get_caps_string() const#
int get_current_state() const#

Public Static Functions

static std::expected<void, GStreamerError> initialize_gstreamer(int *argc = nullptr, char ***argv = nullptr)#
static void deinitialize_gstreamer()#