Add lease to transfer to preserve streams during transfer
Signed-off-by: Derek McGowan <derek@mcg.dev>
This commit is contained in:
parent
d7ef6cbfa3
commit
a5b979623e
@ -32,6 +32,12 @@ import (
|
||||
)
|
||||
|
||||
func (c *Client) Transfer(ctx context.Context, src interface{}, dest interface{}, opts ...transfer.Opt) error {
|
||||
ctx, done, err := c.WithLease(ctx)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
defer done(ctx)
|
||||
|
||||
return proxy.NewTransferrer(transferapi.NewTransferClient(c.conn), c.streamCreator()).Transfer(ctx, src, dest, opts...)
|
||||
}
|
||||
|
||||
|
Loading…
Reference in New Issue
Block a user