Skip to content

Commit

Permalink
Adjust comments
Browse files Browse the repository at this point in the history
Signed-off-by: MyonKeminta <MyonKeminta@users.noreply.github.com>
  • Loading branch information
MyonKeminta committed Jul 25, 2024
1 parent 8dfa046 commit 655a557
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 3 deletions.
2 changes: 0 additions & 2 deletions client/tso_client.go
Original file line number Diff line number Diff line change
Expand Up @@ -350,8 +350,6 @@ type tsoConnectionContext struct {
// Current URL of the stream connection.
streamURL string
// Current stream to send gRPC requests.
// - `pdpb.PD_TsoClient` for a leader/follower in the PD cluster.
// - `tsopb.TSO_TsoClient` for a primary/secondary in the TSO cluster.
stream *tsoStream
}

Expand Down
5 changes: 4 additions & 1 deletion client/tso_stream.go
Original file line number Diff line number Diff line change
Expand Up @@ -174,7 +174,10 @@ func (s tsoTSOStreamAdapter) Recv() (tsoRequestResult, error) {

type tsoStream struct {
serverURL string
stream grpcTSOStreamAdapter
// The internal gRPC stream.
// - `pdpb.PD_TsoClient` for a leader/follower in the PD cluster.
// - `tsopb.TSO_TsoClient` for a primary/secondary in the TSO cluster.
stream grpcTSOStreamAdapter
}

func (s *tsoStream) getServerURL() string {
Expand Down

0 comments on commit 655a557

Please sign in to comment.