From 3e4eeddb78002653fd0f6fc3bdaa7d0b6f70ee5b Mon Sep 17 00:00:00 2001
From: Thales Macedo Garitezi <thalesmg@gmail.com>
Date: Wed, 24 Jul 2024 09:43:58 -0300
Subject: [PATCH] fix: add missing `resource_type` callback implementations

---
 .../src/emqx_bridge_azure_blob_storage_connector.erl         | 5 +++++
 .../src/emqx_bridge_couchbase_connector.erl                  | 5 +++++
 apps/emqx_cluster_link/src/emqx_cluster_link_mqtt.erl        | 5 +++++
 3 files changed, 15 insertions(+)

diff --git a/apps/emqx_bridge_azure_blob_storage/src/emqx_bridge_azure_blob_storage_connector.erl b/apps/emqx_bridge_azure_blob_storage/src/emqx_bridge_azure_blob_storage_connector.erl
index cdf16a8cb..740493f49 100644
--- a/apps/emqx_bridge_azure_blob_storage/src/emqx_bridge_azure_blob_storage_connector.erl
+++ b/apps/emqx_bridge_azure_blob_storage/src/emqx_bridge_azure_blob_storage_connector.erl
@@ -18,6 +18,7 @@
 %% `emqx_resource' API
 -export([
     callback_mode/0,
+    resource_type/0,
 
     on_start/2,
     on_stop/2,
@@ -148,6 +149,10 @@
 callback_mode() ->
     always_sync.
 
+-spec resource_type() -> atom().
+resource_type() ->
+    azure_blob_storage.
+
 -spec on_start(connector_resource_id(), connector_config()) ->
     {ok, connector_state()} | {error, _Reason}.
 on_start(_ConnResId, ConnConfig) ->
diff --git a/apps/emqx_bridge_couchbase/src/emqx_bridge_couchbase_connector.erl b/apps/emqx_bridge_couchbase/src/emqx_bridge_couchbase_connector.erl
index 1e7122800..2c104ee16 100644
--- a/apps/emqx_bridge_couchbase/src/emqx_bridge_couchbase_connector.erl
+++ b/apps/emqx_bridge_couchbase/src/emqx_bridge_couchbase_connector.erl
@@ -15,6 +15,7 @@
 %% `emqx_resource' API
 -export([
     callback_mode/0,
+    resource_type/0,
 
     on_start/2,
     on_stop/2,
@@ -84,6 +85,10 @@
 callback_mode() ->
     always_sync.
 
+-spec resource_type() -> atom().
+resource_type() ->
+    couchbase.
+
 -spec on_start(connector_resource_id(), connector_config()) ->
     {ok, connector_state()} | {error, _Reason}.
 on_start(ConnResId, ConnConfig) ->
diff --git a/apps/emqx_cluster_link/src/emqx_cluster_link_mqtt.erl b/apps/emqx_cluster_link/src/emqx_cluster_link_mqtt.erl
index 5185803b6..3a6411cbe 100644
--- a/apps/emqx_cluster_link/src/emqx_cluster_link_mqtt.erl
+++ b/apps/emqx_cluster_link/src/emqx_cluster_link_mqtt.erl
@@ -19,6 +19,7 @@
 %% callbacks of behaviour emqx_resource
 -export([
     callback_mode/0,
+    resource_type/0,
     on_start/2,
     on_stop/2,
     on_query/3,
@@ -99,6 +100,10 @@ remove_msg_fwd_resource(ClusterName) ->
 
 callback_mode() -> async_if_possible.
 
+-spec resource_type() -> atom().
+resource_type() ->
+    cluster_link_mqtt.
+
 on_start(ResourceId, #{pool_size := PoolSize} = ClusterConf) ->
     PoolName = ResourceId,
     Options = [