From f95f865060de8b1d6a5f97b51f870b411482d48e Mon Sep 17 00:00:00 2001 From: Gyu-Ho Lee Date: Thu, 19 Oct 2017 15:02:19 -0700 Subject: [PATCH] clientv3: unexport pb.LeaseClient in lease client Signed-off-by: Gyu-Ho Lee --- clientv3/retry.go | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/clientv3/retry.go b/clientv3/retry.go index 523205567..408383d27 100644 --- a/clientv3/retry.go +++ b/clientv3/retry.go @@ -164,7 +164,7 @@ func (rkv *retryWriteKVClient) Compact(ctx context.Context, in *pb.CompactionReq } type retryLeaseClient struct { - pb.LeaseClient + lc pb.LeaseClient repeatableRetry retryRPCFunc } @@ -179,7 +179,7 @@ func RetryLeaseClient(c *Client) pb.LeaseClient { func (rlc *retryLeaseClient) LeaseTimeToLive(ctx context.Context, in *pb.LeaseTimeToLiveRequest, opts ...grpc.CallOption) (resp *pb.LeaseTimeToLiveResponse, err error) { err = rlc.repeatableRetry(ctx, func(rctx context.Context) error { - resp, err = rlc.LeaseClient.LeaseTimeToLive(rctx, in, opts...) + resp, err = rlc.lc.LeaseTimeToLive(rctx, in, opts...) return err }) return resp, err @@ -187,7 +187,7 @@ func (rlc *retryLeaseClient) LeaseTimeToLive(ctx context.Context, in *pb.LeaseTi func (rlc *retryLeaseClient) LeaseLeases(ctx context.Context, in *pb.LeaseLeasesRequest, opts ...grpc.CallOption) (resp *pb.LeaseLeasesResponse, err error) { err = rlc.repeatableRetry(ctx, func(rctx context.Context) error { - resp, err = rlc.LeaseClient.LeaseLeases(rctx, in, opts...) + resp, err = rlc.lc.LeaseLeases(rctx, in, opts...) return err }) return resp, err @@ -195,7 +195,7 @@ func (rlc *retryLeaseClient) LeaseLeases(ctx context.Context, in *pb.LeaseLeases func (rlc *retryLeaseClient) LeaseGrant(ctx context.Context, in *pb.LeaseGrantRequest, opts ...grpc.CallOption) (resp *pb.LeaseGrantResponse, err error) { err = rlc.repeatableRetry(ctx, func(rctx context.Context) error { - resp, err = rlc.LeaseClient.LeaseGrant(rctx, in, opts...) + resp, err = rlc.lc.LeaseGrant(rctx, in, opts...) return err }) return resp, err @@ -204,7 +204,7 @@ func (rlc *retryLeaseClient) LeaseGrant(ctx context.Context, in *pb.LeaseGrantRe func (rlc *retryLeaseClient) LeaseRevoke(ctx context.Context, in *pb.LeaseRevokeRequest, opts ...grpc.CallOption) (resp *pb.LeaseRevokeResponse, err error) { err = rlc.repeatableRetry(ctx, func(rctx context.Context) error { - resp, err = rlc.LeaseClient.LeaseRevoke(rctx, in, opts...) + resp, err = rlc.lc.LeaseRevoke(rctx, in, opts...) return err }) return resp, err @@ -212,7 +212,7 @@ func (rlc *retryLeaseClient) LeaseRevoke(ctx context.Context, in *pb.LeaseRevoke func (rlc *retryLeaseClient) LeaseKeepAlive(ctx context.Context, opts ...grpc.CallOption) (stream pb.Lease_LeaseKeepAliveClient, err error) { err = rlc.repeatableRetry(ctx, func(rctx context.Context) error { - stream, err = rlc.LeaseClient.LeaseKeepAlive(rctx, opts...) + stream, err = rlc.lc.LeaseKeepAlive(rctx, opts...) return err }) return stream, err