From 0e4185b40cff3784028a2bda03481ab14809980d Mon Sep 17 00:00:00 2001 From: Patrice Vignola Date: Fri, 24 Feb 2023 07:56:31 -0800 Subject: [PATCH] Remove the StreamDuties endpoint (#12044) MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Co-authored-by: Radosław Kapka --- .../client/beacon-api/beacon_api_validator_client.go | 9 --------- validator/client/grpc-api/grpc_validator_client.go | 4 ---- validator/client/iface/validator_client.go | 1 - 3 files changed, 14 deletions(-) diff --git a/validator/client/beacon-api/beacon_api_validator_client.go b/validator/client/beacon-api/beacon_api_validator_client.go index e7d857a4f93e..6e9a2be255ee 100644 --- a/validator/client/beacon-api/beacon_api_validator_client.go +++ b/validator/client/beacon-api/beacon_api_validator_client.go @@ -113,15 +113,6 @@ func (c *beaconApiValidatorClient) StreamBlocksAltair(ctx context.Context, in *e return c.streamBlocks(ctx, in, time.Second), nil } -func (c *beaconApiValidatorClient) StreamDuties(ctx context.Context, in *ethpb.DutiesRequest) (ethpb.BeaconNodeValidator_StreamDutiesClient, error) { - if c.fallbackClient != nil { - return c.fallbackClient.StreamDuties(ctx, in) - } - - // TODO: Implement me - panic("beaconApiValidatorClient.StreamDuties is not implemented. To use a fallback client, create this validator with NewBeaconApiValidatorClientWithFallback instead.") -} - func (c *beaconApiValidatorClient) SubmitAggregateSelectionProof(ctx context.Context, in *ethpb.AggregateSelectionRequest) (*ethpb.AggregateSelectionResponse, error) { return c.submitAggregateSelectionProof(ctx, in) } diff --git a/validator/client/grpc-api/grpc_validator_client.go b/validator/client/grpc-api/grpc_validator_client.go index c7e1fc78439b..9019beeed428 100644 --- a/validator/client/grpc-api/grpc_validator_client.go +++ b/validator/client/grpc-api/grpc_validator_client.go @@ -75,10 +75,6 @@ func (c *grpcValidatorClient) StreamBlocksAltair(ctx context.Context, in *ethpb. return c.beaconNodeValidatorClient.StreamBlocksAltair(ctx, in) } -func (c *grpcValidatorClient) StreamDuties(ctx context.Context, in *ethpb.DutiesRequest) (ethpb.BeaconNodeValidator_StreamDutiesClient, error) { - return c.beaconNodeValidatorClient.StreamDuties(ctx, in) -} - func (c *grpcValidatorClient) SubmitAggregateSelectionProof(ctx context.Context, in *ethpb.AggregateSelectionRequest) (*ethpb.AggregateSelectionResponse, error) { return c.beaconNodeValidatorClient.SubmitAggregateSelectionProof(ctx, in) } diff --git a/validator/client/iface/validator_client.go b/validator/client/iface/validator_client.go index 36027deb7ecc..cffa179c7697 100644 --- a/validator/client/iface/validator_client.go +++ b/validator/client/iface/validator_client.go @@ -10,7 +10,6 @@ import ( type ValidatorClient interface { GetDuties(ctx context.Context, in *ethpb.DutiesRequest) (*ethpb.DutiesResponse, error) - StreamDuties(ctx context.Context, in *ethpb.DutiesRequest) (ethpb.BeaconNodeValidator_StreamDutiesClient, error) DomainData(ctx context.Context, in *ethpb.DomainRequest) (*ethpb.DomainResponse, error) WaitForChainStart(ctx context.Context, in *empty.Empty) (*ethpb.ChainStartResponse, error) WaitForActivation(ctx context.Context, in *ethpb.ValidatorActivationRequest) (ethpb.BeaconNodeValidator_WaitForActivationClient, error)