edge_src.h

Go to the documentation of this file.

/* SPDX-License-Identifier: LGPL-2.1-only */
#ifndef __GST_EDGE_SRC_H__
#define __GST_EDGE_SRC_H__
 
#include <gst/gst.h>
#include <gst/base/gstbasesrc.h>
#include "edge_common.h"
#include <nnstreamer-edge.h>
#include "nnstreamer_log.h"
#include "nnstreamer_plugin_api.h"
#include "nnstreamer_util.h"
 
G_BEGIN_DECLS
#define GST_TYPE_EDGESRC \
    (gst_edgesrc_get_type())
#define GST_EDGESRC(obj) \
    (G_TYPE_CHECK_INSTANCE_CAST((obj),GST_TYPE_EDGESRC,GstEdgeSrc))
#define GST_EDGESRC_CLASS(klass) \
    (G_TYPE_CHECK_CLASS_CAST((klass),GST_TYPE_EDGESRC,GstEdgeSrcClass))
#define GST_IS_EDGESRC(obj) \
    (G_TYPE_CHECK_INSTANCE_TYPE((obj),GST_TYPE_EDGESRC))
#define GST_IS_EDGESRC_CLASS(klass) \
    (G_TYPE_CHECK_CLASS_TYPE((klass), GST_TYPE_EDGESRC))
#define GST_EDGESRC_CAST(obj) ((GstEdgeSrc *) (obj))
typedef struct _GstEdgeSrc GstEdgeSrc;
typedef struct _GstEdgeSrcClass GstEdgeSrcClass;
 
struct _GstEdgeSrc
{
  GstBaseSrc element;
 
  gchar *dest_host;
  guint16 dest_port;
  gchar *topic;
 
  nns_edge_connect_type_e connect_type;
  nns_edge_h edge_h;
  GAsyncQueue *msg_queue;
 
  gboolean playing;
 
  gchar* custom_lib;
};
 
struct _GstEdgeSrcClass
{
  GstBaseSrcClass parent_class;
};
 
GType gst_edgesrc_get_type (void);
 
G_END_DECLS
#endif /* __GST_EDGE_SRC_H__ */