INNER CODE UNIT · Go

revision

256dpi/lungo · bucket.go:353

		revision = int(*opt.Revision)
	}

	// create stream
	stream := newDownloadStream(ctx, b, nil, name, revision)

	// match the official driver: surface ErrFileNotFound from Open rather
	// than deferring it to the first Read/Seek
	if err := stream.load(); err != nil {
		return nil, err
	}

	return stream, nil
}

// OpenUploadStream will open an upload stream for a new file with the provided
// name.
func (b *Bucket) OpenUploadStream(ctx context.Context, name string, opts ...*options.UploadOptions) (*UploadStream, error) {

View source record →