From a2f8eef449dab9efad5f8fde6eb57619e925b841 Mon Sep 17 00:00:00 2001 From: Ran Mishael Date: Mon, 26 Aug 2024 11:06:07 +0200 Subject: [PATCH] rename --- protocol/rpcconsumer/relay_processor.go | 6 +++--- protocol/rpcconsumer/relay_processor_test.go | 2 +- protocol/rpcconsumer/rpcconsumer_server.go | 4 ++-- 3 files changed, 6 insertions(+), 6 deletions(-) diff --git a/protocol/rpcconsumer/relay_processor.go b/protocol/rpcconsumer/relay_processor.go index 8f671f90ed..799d84caba 100644 --- a/protocol/rpcconsumer/relay_processor.go +++ b/protocol/rpcconsumer/relay_processor.go @@ -60,10 +60,10 @@ type RelayProcessor struct { metricsInf MetricsInterface chainIdAndApiInterfaceGetter chainIdAndApiInterfaceGetter relayRetriesManager *RelayRetriesManager - retryOptions retryProcessorOptions + retryOptions relayProcessorRetryOptions } -type retryProcessorOptions struct { +type relayProcessorRetryOptions struct { relayCountOnNodeError int disableCacheOnNodeError bool disableRelayRetry bool @@ -80,7 +80,7 @@ func NewRelayProcessor( debugRelay bool, metricsInf MetricsInterface, chainIdAndApiInterfaceGetter chainIdAndApiInterfaceGetter, - retryOptions retryProcessorOptions, + retryOptions relayProcessorRetryOptions, relayRetriesManager *RelayRetriesManager, ) *RelayProcessor { guid, _ := utils.GetUniqueIdentifier(ctx) diff --git a/protocol/rpcconsumer/relay_processor_test.go b/protocol/rpcconsumer/relay_processor_test.go index 70ee97431b..44822f1dbe 100644 --- a/protocol/rpcconsumer/relay_processor_test.go +++ b/protocol/rpcconsumer/relay_processor_test.go @@ -16,7 +16,7 @@ import ( "github.com/stretchr/testify/require" ) -var retryOptionsTest = retryProcessorOptions{ +var retryOptionsTest = relayProcessorRetryOptions{ disableRelayRetry: false, relayCountOnNodeError: 2, disableCacheOnNodeError: false, diff --git a/protocol/rpcconsumer/rpcconsumer_server.go b/protocol/rpcconsumer/rpcconsumer_server.go index 1c7ede5a53..a5fe92ff6f 100644 --- a/protocol/rpcconsumer/rpcconsumer_server.go +++ b/protocol/rpcconsumer/rpcconsumer_server.go @@ -73,7 +73,7 @@ type RPCConsumerServer struct { connectedSubscriptionsContexts map[string]*CancelableContextHolder chainListener chainlib.ChainListener connectedSubscriptionsLock sync.RWMutex - retryOptions retryProcessorOptions + retryOptions relayProcessorRetryOptions relayRetriesManager *RelayRetriesManager } @@ -124,7 +124,7 @@ func (rpccs *RPCConsumerServer) ServeRPCRequests(ctx context.Context, listenEndp rpccs.debugRelays = cmdFlags.DebugRelays rpccs.connectedSubscriptionsContexts = make(map[string]*CancelableContextHolder) rpccs.consumerProcessGuid = strconv.FormatUint(utils.GenerateUniqueIdentifier(), 10) - rpccs.retryOptions = retryProcessorOptions{ + rpccs.retryOptions = relayProcessorRetryOptions{ disableRelayRetry: cmdFlags.DisableRetryOnNodeErrors, relayCountOnNodeError: cmdFlags.SetRelayCountOnNodeError, disableCacheOnNodeError: cmdFlags.DisableCacheOnNodeError,