change var name

Author: PatStiles

core/chainio/avs_subscriber.go

@@ -68,13 +68,13 @@ func (s *AvsSubscriber) SubscribeToNewTasksV2(newTaskCreatedChan chan *servicema
 	// Subscribe to new tasks
 	sub, err := SubscribeToNewTasksV2Retryable(&bind.WatchOpts{}, s.AvsContractBindings.ServiceManager, internalChannel, nil)
 	if err != nil {
-		s.logger.Error("Primary failed to subscribe to new AlignedLayer V2 tasks after %d retries", retry.RpcNumRetries, "err", err)
+		s.logger.Error("Primary failed to subscribe to new AlignedLayer V2 tasks after %d retries", retry.EthCallNumRetries, "err", err)
 		return nil, err
 	}
 
 	subFallback, err := SubscribeToNewTasksV2Retryable(&bind.WatchOpts{}, s.AvsContractBindings.ServiceManagerFallback, internalChannel, nil)
 	if err != nil {
-		s.logger.Error("Fallback failed to subscribe to new AlignedLayer V2 tasks after %d retries", retry.RpcNumRetries, "err", err)
+		s.logger.Error("Fallback failed to subscribe to new AlignedLayer V2 tasks after %d retries", retry.EthCallNumRetries, "err", err)
 		return nil, err
 	}
 	s.logger.Info("Subscribed to new AlignedLayer V2 tasks")

core/chainio/retryable.go

@@ -71,7 +71,7 @@ func (w *AvsWriter) BatchesStateRetryable(opts *bind.CallOpts, arg0 [32]byte) (s
 	Responded             bool
 	RespondToTaskFeeLimit *big.Int
 }, error) {
-	return retry.RetryWithData(BatchesState(w, opts, arg0), retry.RpcRetryConfig())
+	return retry.RetryWithData(BatchesState(w, opts, arg0), retry.EthCallRetryConfig())
 }
 
 func BatcherBalances(w *AvsWriter, opts *bind.CallOpts, senderAddress common.Address) func() (*big.Int, error) {
@@ -94,7 +94,7 @@ Get the balance of a batcher from the AVS contract.
 - Retry times (3 retries): 1 sec, 2 sec, 4 sec
 */
 func (w *AvsWriter) BatcherBalancesRetryable(opts *bind.CallOpts, senderAddress common.Address) (*big.Int, error) {
-	return retry.RetryWithData(BatcherBalances(w, opts, senderAddress), retry.RpcRetryConfig())
+	return retry.RetryWithData(BatcherBalances(w, opts, senderAddress), retry.EthCallRetryConfig())
 }
 
 func BalanceAt(w *AvsWriter, ctx context.Context, aggregatorAddress common.Address, blockNumber *big.Int) func() (*big.Int, error) {
@@ -119,7 +119,7 @@ TODO: it gets the balance from an Address, not necessarily an aggregator. The na
 - Retry times (3 retries): 1 sec, 2 sec, 4 sec.
 */
 func (w *AvsWriter) BalanceAtRetryable(ctx context.Context, aggregatorAddress common.Address, blockNumber *big.Int) (*big.Int, error) {
-	return retry.RetryWithData(BalanceAt(w, ctx, aggregatorAddress, blockNumber), retry.RpcRetryConfig())
+	return retry.RetryWithData(BalanceAt(w, ctx, aggregatorAddress, blockNumber), retry.EthCallRetryConfig())
 }
 
 // |---AVS_SUBSCRIBER---|
@@ -144,7 +144,7 @@ Get the latest block number from Ethereum
 - Retry times (3 retries): 1 sec, 2 sec, 4 sec.
 */
 func (s *AvsSubscriber) BlockNumberRetryable(ctx context.Context) (uint64, error) {
-	return retry.RetryWithData(BlockNumber(s, ctx), retry.RpcRetryConfig())
+	return retry.RetryWithData(BlockNumber(s, ctx), retry.EthCallRetryConfig())
 }
 
 func FilterBatchV2(s *AvsSubscriber, opts *bind.FilterOpts, batchMerkleRoot [][32]byte) func() (*servicemanager.ContractAlignedLayerServiceManagerNewBatchV2Iterator, error) {
@@ -165,7 +165,7 @@ Get NewBatchV2 logs from the AVS contract.
 - Retry times (3 retries): 1 sec, 2 sec, 4 sec.
 */
 func (s *AvsSubscriber) FilterBatchV2Retryable(opts *bind.FilterOpts, batchMerkleRoot [][32]byte) (*servicemanager.ContractAlignedLayerServiceManagerNewBatchV2Iterator, error) {
-	return retry.RetryWithData(FilterBatchV2(s, opts, batchMerkleRoot), retry.RpcRetryConfig())
+	return retry.RetryWithData(FilterBatchV2(s, opts, batchMerkleRoot), retry.EthCallRetryConfig())
 }
 
 func FilterBatchV3(s *AvsSubscriber, opts *bind.FilterOpts, batchMerkleRoot [][32]byte) func() (*servicemanager.ContractAlignedLayerServiceManagerNewBatchV3Iterator, error) {
@@ -186,7 +186,7 @@ Get NewBatchV3 logs from the AVS contract.
 - Retry times (3 retries): 1 sec, 2 sec, 4 sec.
 */
 func (s *AvsSubscriber) FilterBatchV3Retryable(opts *bind.FilterOpts, batchMerkleRoot [][32]byte) (*servicemanager.ContractAlignedLayerServiceManagerNewBatchV3Iterator, error) {
-	return retry.RetryWithData(FilterBatchV3(s, opts, batchMerkleRoot), retry.RpcRetryConfig())
+	return retry.RetryWithData(FilterBatchV3(s, opts, batchMerkleRoot), retry.EthCallRetryConfig())
 }
 
 func BatchState(s *AvsSubscriber, opts *bind.CallOpts, arg0 [32]byte) func() (struct {
@@ -220,7 +220,7 @@ func (s *AvsSubscriber) BatchesStateRetryable(opts *bind.CallOpts, arg0 [32]byte
 	RespondToTaskFeeLimit *big.Int
 }, error) {
 
-	return retry.RetryWithData(BatchState(s, opts, arg0), retry.RpcRetryConfig())
+	return retry.RetryWithData(BatchState(s, opts, arg0), retry.EthCallRetryConfig())
 }
 
 func SubscribeNewHead(s *AvsSubscriber, ctx context.Context, c chan<- *types.Header) func() (ethereum.Subscription, error) {
@@ -243,7 +243,7 @@ Subscribe to new heads from the Ethereum node.
 - Retry times (3 retries): 1 sec, 2 sec, 4 sec.
 */
 func (s *AvsSubscriber) SubscribeNewHeadRetryable(ctx context.Context, c chan<- *types.Header) (ethereum.Subscription, error) {
-	return retry.RetryWithData(SubscribeNewHead(s, ctx, c), retry.RpcRetryConfig())
+	return retry.RetryWithData(SubscribeNewHead(s, ctx, c), retry.EthCallRetryConfig())
 }
 
 func SubscribeToNewTasksV2(
@@ -270,7 +270,7 @@ func SubscribeToNewTasksV2Retryable(
 	newTaskCreatedChan chan *servicemanager.ContractAlignedLayerServiceManagerNewBatchV2,
 	batchMerkleRoot [][32]byte,
 ) (event.Subscription, error) {
-	return retry.RetryWithData(SubscribeToNewTasksV2(opts, serviceManager, newTaskCreatedChan, batchMerkleRoot), retry.RpcRetryConfig())
+	return retry.RetryWithData(SubscribeToNewTasksV2(opts, serviceManager, newTaskCreatedChan, batchMerkleRoot), retry.EthCallRetryConfig())
 }
 
 func SubscribeToNewTasksV3(
@@ -297,5 +297,5 @@ func SubscribeToNewTasksV3Retryable(
 	newTaskCreatedChan chan *servicemanager.ContractAlignedLayerServiceManagerNewBatchV3,
 	batchMerkleRoot [][32]byte,
 ) (event.Subscription, error) {
-	return retry.RetryWithData(SubscribeToNewTasksV3(opts, serviceManager, newTaskCreatedChan, batchMerkleRoot), retry.RpcRetryConfig())
+	return retry.RetryWithData(SubscribeToNewTasksV3(opts, serviceManager, newTaskCreatedChan, batchMerkleRoot), retry.EthCallRetryConfig())
 }

core/retry.go

@@ -25,14 +25,14 @@ func (e PermanentError) Is(err error) bool {
 }
 
 const (
-	RpcInitialInterval             = 1 * time.Second  // Initial delay for retry interval.
-	RpcMaxInterval                 = 60 * time.Second // Maximum interval an individual retry may have.
-	RpcMaxElapsedTime              = 0 * time.Second  // Maximum time all retries may take. `0` corresponds to no limit on the time of the retries.
-	RpcRandomizationFactor float64 = 0                // Randomization (Jitter) factor used to map retry interval to a range of values around the computed interval. In precise terms (random value in range [1 - randomizationfactor, 1 + randomizationfactor]). NOTE: This is set to 0 as we do not use jitter in Aligned.
-	RpcMultiplier          float64 = 2                // Multiplier factor computed exponential retry interval is scaled by.
-	RpcNumRetries          uint64  = 3                // Total number of retries attempted.
-	ChainInitialInterval           = 12 * time.Second // Initial delay for retry interval for contract calls. Corresponds to 1 ethereum block.
-	ChainMaxInterval               = 2 * time.Minute  // Maximum interval for an individual retry.
+	EthCallInitialInterval             = 1 * time.Second  // Initial delay for retry interval.
+	EthCallMaxInterval                 = 60 * time.Second // Maximum interval an individual retry may have.
+	EthCallMaxElapsedTime              = 0 * time.Second  // Maximum time all retries may take. `0` corresponds to no limit on the time of the retries.
+	EthCallRandomizationFactor float64 = 0                // Randomization (Jitter) factor used to map retry interval to a range of values around the computed interval. In precise terms (random value in range [1 - randomizationfactor, 1 + randomizationfactor]). NOTE: This is set to 0 as we do not use jitter in Aligned.
+	EthCallMultiplier          float64 = 2                // Multiplier factor computed exponential retry interval is scaled by.
+	EthCallNumRetries          uint64  = 3                // Total number of retries attempted.
+	ChainInitialInterval               = 12 * time.Second // Initial delay for retry interval for contract calls. Corresponds to 1 ethereum block.
+	ChainMaxInterval                   = 2 * time.Minute  // Maximum interval for an individual retry.
 )
 
 type RetryConfig struct {
@@ -44,25 +44,25 @@ type RetryConfig struct {
 	NumRetries          uint64
 }
 
-func RpcRetryConfig() *RetryConfig {
+func EthCallRetryConfig() *RetryConfig {
 	return &RetryConfig{
-		InitialInterval:     RpcInitialInterval,
-		MaxInterval:         RpcMaxInterval,
-		MaxElapsedTime:      RpcMaxElapsedTime,
-		RandomizationFactor: RpcRandomizationFactor,
-		Multiplier:          RpcMultiplier,
-		NumRetries:          RpcNumRetries,
+		InitialInterval:     EthCallInitialInterval,
+		MaxInterval:         EthCallMaxInterval,
+		MaxElapsedTime:      EthCallMaxElapsedTime,
+		RandomizationFactor: EthCallRandomizationFactor,
+		Multiplier:          EthCallMultiplier,
+		NumRetries:          EthCallNumRetries,
 	}
 }
 
 func ChainRetryConfig() *RetryConfig {
 	return &RetryConfig{
 		InitialInterval:     ChainInitialInterval,
 		MaxInterval:         ChainMaxInterval,
-		MaxElapsedTime:      RpcMaxElapsedTime,
-		RandomizationFactor: RpcRandomizationFactor,
-		Multiplier:          RpcMultiplier,
-		NumRetries:          RpcNumRetries,
+		MaxElapsedTime:      EthCallMaxElapsedTime,
+		RandomizationFactor: EthCallRandomizationFactor,
+		Multiplier:          EthCallMultiplier,
+		NumRetries:          EthCallNumRetries,
 	}
 }
 

core/retry_test.go

@@ -48,8 +48,8 @@ func TestRetryWithData(t *testing.T) {
 		MaxInterval:         2,
 		MaxElapsedTime:      3,
 		RandomizationFactor: 0,
-		Multiplier:          retry.RpcMultiplier,
-		NumRetries:          retry.RpcNumRetries,
+		Multiplier:          retry.EthCallMultiplier,
+		NumRetries:          retry.EthCallNumRetries,
 	}
 	_, err := retry.RetryWithData(function, config)
 	if err != nil {
@@ -67,8 +67,8 @@ func TestRetry(t *testing.T) {
 		MaxInterval:         2,
 		MaxElapsedTime:      3,
 		RandomizationFactor: 0,
-		Multiplier:          retry.RpcMultiplier,
-		NumRetries:          retry.RpcNumRetries,
+		Multiplier:          retry.EthCallMultiplier,
+		NumRetries:          retry.EthCallNumRetries,
 	}
 	err := retry.Retry(function, config)
 	if err != nil {
@@ -170,7 +170,7 @@ func TestWaitForTransactionReceipt(t *testing.T) {
 	}
 
 	// Assert Call succeeds when Anvil running
-	receipt_function := utils.WaitForTransactionReceipt(*client, *client, hash, retry.RpcRetryConfig())
+	receipt_function := utils.WaitForTransactionReceipt(*client, *client, hash, retry.EthCallRetryConfig())
 	_, err = receipt_function()
 	assert.NotNil(t, err, "Error Waiting for Transaction with Anvil Running: %s\n", err)
 	if !strings.Contains(err.Error(), "not found") {
@@ -183,7 +183,7 @@ func TestWaitForTransactionReceipt(t *testing.T) {
 		return
 	}
 
-	receipt_function = utils.WaitForTransactionReceipt(*client, *client, hash, retry.RpcRetryConfig())
+	receipt_function = utils.WaitForTransactionReceipt(*client, *client, hash, retry.EthCallRetryConfig())
 	_, err = receipt_function()
 	assert.NotNil(t, err)
 	if _, ok := err.(retry.PermanentError); ok {
@@ -200,7 +200,7 @@ func TestWaitForTransactionReceipt(t *testing.T) {
 		t.Errorf("Error setting up Anvil: %s\n", err)
 	}
 
-	receipt_function = utils.WaitForTransactionReceipt(*client, *client, hash, retry.RpcRetryConfig())
+	receipt_function = utils.WaitForTransactionReceipt(*client, *client, hash, retry.EthCallRetryConfig())
 	_, err = receipt_function()
 	assert.NotNil(t, err)
 	if !strings.Contains(err.Error(), "not found") {

core/utils/eth_client_utils.go

@@ -103,5 +103,5 @@ func GetGasPriceRetryable(client eth.InstrumentedClient, fallbackClient eth.Inst
 
 		return gasPrice, nil
 	}
-	return retry.RetryWithData(respondToTaskV2_func, retry.RpcRetryConfig())
+	return retry.RetryWithData(respondToTaskV2_func, retry.EthCallRetryConfig())
 }