Skip to content

Commit

Permalink
remove mentioned about endpoint granularity load reporting
Browse files Browse the repository at this point in the history
  • Loading branch information
easwars committed Oct 17, 2024
1 parent c4e85bd commit 434d43b
Showing 1 changed file with 0 additions and 9 deletions.
9 changes: 0 additions & 9 deletions xds/internal/xdsclient/transport/lrs/lrs_stream.go
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,6 @@ package lrs

import (
"context"
"errors"
"fmt"
"io"
"sync"
Expand Down Expand Up @@ -223,9 +222,6 @@ func (lrs *StreamImpl) sendFirstLoadStatsRequest(stream transport.StreamingCall,
// server requested for load from all clusters
// - the load reporting interval, and
// - any error encountered
//
// If the server requests for endpoint-level load reporting, an error is
// returned, since this is not yet supported.
func (lrs *StreamImpl) recvFirstLoadStatsResponse(stream transport.StreamingCall) ([]string, time.Duration, error) {
r, err := stream.Recv()
if err != nil {
Expand All @@ -245,11 +241,6 @@ func (lrs *StreamImpl) recvFirstLoadStatsResponse(stream transport.StreamingCall
}
loadReportingInterval := internal.AsDuration()

if resp.ReportEndpointGranularity {
// TODO(easwars): Support per endpoint loads.
return nil, 0, errors.New("lrs: endpoint loads requested, but not supported by current implementation")
}

clusters := resp.Clusters
if resp.SendAllClusters {
// Return an empty slice to send stats for all clusters.
Expand Down

0 comments on commit 434d43b

Please sign in to comment.