Method Put

drivers/sftp/driver.go:111–124

(ctx context.Context, dstDir model.Obj, stream model.FileStreamer, up driver.UpdateProgress)

}

func (d *SFTP) Put(ctx context.Context, dstDir model.Obj, stream model.FileStreamer, up driver.UpdateProgress) error {
	if err := d.clientReconnectOnConnectionError(); err != nil {
		return err
	}
	dstFile, err := d.client.Create(path.Join(dstDir.GetPath(), stream.GetName()))
	if err != nil {
		return err
	}
	defer func() {
		_ = dstFile.Close()
	}()
	err = utils.CopyWithCtx(ctx, dstFile, driver.NewLimitedUploadStream(ctx, stream), stream.GetSize(), up)
	return err
}

func (d *SFTP) GetDetails(ctx context.Context) (*model.StorageDetails, error) {
	stat, err := d.client.StatVFS(d.RootFolderPath)