Code

Add TTL to Operator RPC Client#259

Code

Closed

emlautarom1 wants to merge 34 commits intomainNuffle-Labs/nffl:mainfrom feature/rpc_client_ttlNuffle-Labs/nffl:feature/rpc_client_ttlCopy head branch name to clipboard

+439-336

Commits

Commits on Jun 19, 2024

• Initial V2 impl for rpc_client

  emlautarom1

  committed
  0b420fb

• Add retry later

  emlautarom1

  committed
  27f918b

• Add submittedAt to actions

  emlautarom1

  committed
  ae9904e

• Extract retry and retry later strategies

  emlautarom1

  committed
  9e1e849

• Add retryIfRecentEnough

  emlautarom1

  committed
  890ac87

• Add TestRetryLaterIfRecentEnough

  emlautarom1

  committed
  9a46a4f

• Rename retry mechanism

  emlautarom1

  committed
  4fef16a

• Test retryAtMost

  emlautarom1

  committed
  8e558f5

• Store retryPredicate in struct member

  emlautarom1

  committed
  3950423

• Separate impl from tests

  emlautarom1

  committed
  e0a82a0

• Rename to AggregatorRpcClient

  emlautarom1

  committed
  6a7c004

• Don't use self

  emlautarom1

  committed
  6b0107d

• Abstract rpc.Client

  emlautarom1

  committed
  3fc60c6

• Add NewHTTPAggregatorRpcClient

  emlautarom1

  committed
  658f752

• Add AggregatorRpcClienter interface

  emlautarom1

  committed
  17c134c

• Remove interface (single implementation)

  emlautarom1

  committed
  ca0820a

• Rename client method names

  emlautarom1

  committed
  b64cb17

• Add TestGetAggregatedCheckpointMessages

  Show description for 5eae2a1
  emlautarom1

  committed
  5eae2a1

• Make GetAggregatedCheckpointMessages blocking

  emlautarom1

  committed
  a0f833f

Commits on Jun 20, 2024

• Replace event loop with blocking code

  emlautarom1

  committed
  b5f5207

• Add Metricable interface to AggregatorRpcClient

  emlautarom1

  committed
  24b027e

• Use listener in SendSignedCheckpointTaskResponseToAggregator

  emlautarom1

  committed
  cf09334

• Use listener in SendSignedStateRootUpdateToAggregator

  emlautarom1

  committed
  5ec7d28

• Use listener in SendSignedOperatorSetUpdateToAggregator

  emlautarom1

  committed
  e576b5f

• Add logs to GetAggregatedCheckpointMessages

  emlautarom1

  committed
  22f5264

• Add RetryWithDelay

  emlautarom1

  committed
  fefaa66

• Rename parameter

  emlautarom1

  committed
  f3d197c

• Add RetryAnd to compose rather than decorators

  emlautarom1

  committed
  fc5665b

• Add DefaultRetryStrategy

  emlautarom1

  committed
  f71d642

• Start aggregator before operator

  emlautarom1

  committed
  6a6db7d

• Replace original with v2

  emlautarom1

  committed
  28b0005

• Increase coverage by using different messages

  emlautarom1

  committed
  7bcc7ff

• Ensure retry strategy is local to each method call

  emlautarom1

  committed
  f4ee227

• Typo

  emlautarom1

  committed
  9f3809e