From 78cfc8db950852505ab3db1eeda1c10733cf97a9 Mon Sep 17 00:00:00 2001 From: Gyu-Ho Lee Date: Fri, 9 Sep 2016 08:14:46 +0900 Subject: [PATCH] grpcproxy: implement 'LeaseTimeToLive' --- proxy/grpcproxy/lease.go | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/proxy/grpcproxy/lease.go b/proxy/grpcproxy/lease.go index fe2fa1f94..4f870220b 100644 --- a/proxy/grpcproxy/lease.go +++ b/proxy/grpcproxy/lease.go @@ -41,6 +41,11 @@ func (lp *leaseProxy) LeaseRevoke(ctx context.Context, rr *pb.LeaseRevokeRequest return pb.NewLeaseClient(conn).LeaseRevoke(ctx, rr) } +func (lp *leaseProxy) LeaseTimeToLive(ctx context.Context, rr *pb.LeaseTimeToLiveRequest) (*pb.LeaseTimeToLiveResponse, error) { + conn := lp.client.ActiveConnection() + return pb.NewLeaseClient(conn).LeaseTimeToLive(ctx, rr) +} + func (lp *leaseProxy) LeaseKeepAlive(stream pb.Lease_LeaseKeepAliveServer) error { conn := lp.client.ActiveConnection() ctx, cancel := context.WithCancel(stream.Context())