rename

lavanet · Aug 26, 2024 · a2f8eef · a2f8eef
1 parent bc2afb7
commit a2f8eef
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 6 deletions.
diff --git 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
@@ -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
@@ -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,