a
/
agola
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

objectstorage: return object size in objectinfo 

Return object size in object info.
This commit is contained in:
Simone Gotti 2019-10-25 10:53:14 +02:00
parent 3808c71b37
commit ae1e92b115
4 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
internal/objectstorage/posix/posix.go
View File

@ -73,7 +73,7 @@ func (s *PosixStorage) Stat(p string) (*types.ObjectInfo, error) {
return nil, err return nil, err
} }
return &types.ObjectInfo{Path: p, LastModified: fi.ModTime()}, nil return &types.ObjectInfo{Path: p, LastModified: fi.ModTime(), Size: fi.Size()}, nil
} }
func (s *PosixStorage) ReadObject(p string) (types.ReadSeekCloser, error) { func (s *PosixStorage) ReadObject(p string) (types.ReadSeekCloser, error) {
@ -215,7 +215,7 @@ func (s *PosixStorage) List(prefix, startWith, delimiter string, doneCh <-chan s
if strings.HasPrefix(p, prefix) && p > startWith { if strings.HasPrefix(p, prefix) && p > startWith {
select { select {
// Send object content. // Send object content.
case objectCh <- types.ObjectInfo{Path: p, LastModified: info.ModTime()}: case objectCh <- types.ObjectInfo{Path: p, LastModified: info.ModTime(), Size: info.Size()}:
// If receives done from the caller, return here. // If receives done from the caller, return here.
case <-doneCh: case <-doneCh:
return io.EOF return io.EOF

4
internal/objectstorage/posixflat/posixflat.go
View File

@ -249,7 +249,7 @@ func (s *PosixFlatStorage) Stat(p string) (*types.ObjectInfo, error) {
return nil, err return nil, err
} }
return &types.ObjectInfo{Path: p, LastModified: fi.ModTime()}, nil return &types.ObjectInfo{Path: p, LastModified: fi.ModTime(), Size: fi.Size()}, nil
} }
func (s *PosixFlatStorage) ReadObject(p string) (types.ReadSeekCloser, error) { func (s *PosixFlatStorage) ReadObject(p string) (types.ReadSeekCloser, error) {
@ -412,7 +412,7 @@ func (s *PosixFlatStorage) List(prefix, startWith, delimiter string, doneCh <-ch
if p > prevp { if p > prevp {
select { select {
// Send object content. // Send object content.
case objectCh <- types.ObjectInfo{Path: p, LastModified: info.ModTime()}: case objectCh <- types.ObjectInfo{Path: p, LastModified: info.ModTime(), Size: info.Size()}:
// If receives done from the caller, return here. // If receives done from the caller, return here.
case <-doneCh: case <-doneCh:
return io.EOF return io.EOF

4
internal/objectstorage/s3/s3.go
View File

@ -72,7 +72,7 @@ func (s *S3Storage) Stat(p string) (*types.ObjectInfo, error) {
return nil, merr return nil, merr
} }
return &types.ObjectInfo{Path: p, LastModified: oi.LastModified}, nil return &types.ObjectInfo{Path: p, LastModified: oi.LastModified, Size: oi.Size}, nil
} }
func (s *S3Storage) ReadObject(filepath string) (types.ReadSeekCloser, error) { func (s *S3Storage) ReadObject(filepath string) (types.ReadSeekCloser, error) {
@ -156,7 +156,7 @@ func (s *S3Storage) List(prefix, startWith, delimiter string, doneCh <-chan stru
for _, object := range result.Contents { for _, object := range result.Contents {
select { select {
// Send object content. // Send object content.
case objectCh <- types.ObjectInfo{Path: object.Key, LastModified: object.LastModified}: case objectCh <- types.ObjectInfo{Path: object.Key, LastModified: object.LastModified, Size: object.Size}:
// If receives done from the caller, return here. // If receives done from the caller, return here.
case <-doneCh: case <-doneCh:
return return

4
internal/objectstorage/types/types.go
View File

@ -33,9 +33,9 @@ type ReadSeekCloser interface {
} }
type ObjectInfo struct { type ObjectInfo struct {
Path string Path string
LastModified time.Time LastModified time.Time
Size int64
Err error Err error
} }