From 465e8a90ddb8279dd6992edb0ef9204cb96e0744 Mon Sep 17 00:00:00 2001 From: ieQu1 <99872536+ieQu1@users.noreply.github.com> Date: Mon, 16 Oct 2023 10:17:44 +0200 Subject: [PATCH] revert(ds): Remove change from the old protocol file --- .../emqx_persistent_session_ds_proto_v1.erl | 19 +------------------ scripts/check-elixir-applications.exs | 2 +- scripts/check-elixir-deps-discrepancies.exs | 2 +- ...elixir-emqx-machine-boot-discrepancies.exs | 2 +- scripts/check_missing_reboot_apps.exs | 2 +- 5 files changed, 5 insertions(+), 22 deletions(-) diff --git a/apps/emqx/src/proto/emqx_persistent_session_ds_proto_v1.erl b/apps/emqx/src/proto/emqx_persistent_session_ds_proto_v1.erl index d9b882f3d..d35ccd963 100644 --- a/apps/emqx/src/proto/emqx_persistent_session_ds_proto_v1.erl +++ b/apps/emqx/src/proto/emqx_persistent_session_ds_proto_v1.erl @@ -23,8 +23,7 @@ open_iterator/4, close_iterator/2, - close_all_iterators/2, - get_streams/5 + close_all_iterators/2 ]). -include_lib("emqx/include/bpapi.hrl"). @@ -51,22 +50,6 @@ open_iterator(Nodes, TopicFilter, StartMS, IteratorID) -> ?TIMEOUT ). --spec get_streams( - node(), - emqx_ds:keyspace(), - emqx_ds:shard_id(), - emqx_ds:topic_filter(), - emqx_ds:time() -) -> - [emqx_ds_storage_layer:stream()]. -get_streams(Node, Keyspace, ShardId, TopicFilter, StartTime) -> - erpc:call( - Node, - emqx_ds_storage_layer, - get_streams, - [Keyspace, ShardId, TopicFilter, StartTime] - ). - -spec close_iterator( [node()], emqx_ds:iterator_id() diff --git a/scripts/check-elixir-applications.exs b/scripts/check-elixir-applications.exs index 1e604c69f..42c838199 100755 --- a/scripts/check-elixir-applications.exs +++ b/scripts/check-elixir-applications.exs @@ -1,4 +1,4 @@ -#! /usr/bin/env elixir +#!/usr/bin/env elixir defmodule CheckElixirApplications do alias EMQXUmbrella.MixProject diff --git a/scripts/check-elixir-deps-discrepancies.exs b/scripts/check-elixir-deps-discrepancies.exs index 1363219ed..408079d7d 100755 --- a/scripts/check-elixir-deps-discrepancies.exs +++ b/scripts/check-elixir-deps-discrepancies.exs @@ -1,4 +1,4 @@ -#! /usr/bin/env elixir +#!/usr/bin/env elixir # ensure we have a fresh rebar.lock diff --git a/scripts/check-elixir-emqx-machine-boot-discrepancies.exs b/scripts/check-elixir-emqx-machine-boot-discrepancies.exs index 9ffdc47bf..d07e6978f 100755 --- a/scripts/check-elixir-emqx-machine-boot-discrepancies.exs +++ b/scripts/check-elixir-emqx-machine-boot-discrepancies.exs @@ -1,4 +1,4 @@ -#! /usr/bin/env elixir +#!/usr/bin/env elixir defmodule CheckElixirEMQXMachineBootDiscrepancies do alias EMQXUmbrella.MixProject diff --git a/scripts/check_missing_reboot_apps.exs b/scripts/check_missing_reboot_apps.exs index 7f2178ec1..91d4b39ea 100755 --- a/scripts/check_missing_reboot_apps.exs +++ b/scripts/check_missing_reboot_apps.exs @@ -1,4 +1,4 @@ -#! /usr/bin/env elixir +#!/usr/bin/env elixir alias EMQXUmbrella.MixProject