dragonflyoss
/
dragonfly
mirror of https://github.com/dragonflyoss/dragonfly.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

refractor: fix typo in object storage.go (#3374) 

fix typo

Signed-off-by: Zyyeric <eric1976808123@gmail.com>
This commit is contained in:
Zyyeric 2024-07-16 10:29:42 +08:00 committed by GitHub
parent c49bd20699
commit b7fdbcbff9
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
6 changed files with 15 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
manager/service/model.go
View File

@ -157,7 +157,7 @@ func (s *service) updateModelConfig(ctx context.Context, name string, version in
objectKey := types.MakeObjectKeyOfModelConfigFile(name) objectKey := types.MakeObjectKeyOfModelConfigFile(name)
var pbModelConfig inference.ModelConfig var pbModelConfig inference.ModelConfig
reader, err := s.objectStorage.GetOject(ctx, s.config.Trainer.BucketName, objectKey) reader, err := s.objectStorage.GetObject(ctx, s.config.Trainer.BucketName, objectKey)
if err != nil { if err != nil {
return err return err
} }

12
pkg/objectstorage/mocks/objectstorage_mock.go
View File

@ -158,19 +158,19 @@ func (mr *MockObjectStorageMockRecorder) GetObjectMetadatas(ctx, bucketName, pre
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetObjectMetadatas", reflect.TypeOf((*MockObjectStorage)(nil).GetObjectMetadatas), ctx, bucketName, prefix, marker, delimiter, limit) return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetObjectMetadatas", reflect.TypeOf((*MockObjectStorage)(nil).GetObjectMetadatas), ctx, bucketName, prefix, marker, delimiter, limit)
} }
// GetOject mocks base method. // GetObject mocks base method.
func (m *MockObjectStorage) GetOject(ctx context.Context, bucketName, objectKey string) (io.ReadCloser, error) { func (m *MockObjectStorage) GetObject(ctx context.Context, bucketName, objectKey string) (io.ReadCloser, error) {
m.ctrl.T.Helper() m.ctrl.T.Helper()
ret := m.ctrl.Call(m, "GetOject", ctx, bucketName, objectKey) ret := m.ctrl.Call(m, "GetObject", ctx, bucketName, objectKey)
ret0, _ := ret[0].(io.ReadCloser) ret0, _ := ret[0].(io.ReadCloser)
ret1, _ := ret[1].(error) ret1, _ := ret[1].(error)
return ret0, ret1 return ret0, ret1
} }
// GetOject indicates an expected call of GetOject. // GetObject indicates an expected call of GetObject.
func (mr *MockObjectStorageMockRecorder) GetOject(ctx, bucketName, objectKey any) *gomock.Call { func (mr *MockObjectStorageMockRecorder) GetObject(ctx, bucketName, objectKey any) *gomock.Call {
mr.mock.ctrl.T.Helper() mr.mock.ctrl.T.Helper()
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetOject", reflect.TypeOf((*MockObjectStorage)(nil).GetOject), ctx, bucketName, objectKey) return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetObject", reflect.TypeOf((*MockObjectStorage)(nil).GetObject), ctx, bucketName, objectKey)
} }
// GetSignURL mocks base method. // GetSignURL mocks base method.

4
pkg/objectstorage/objectstorage.go
View File

@ -115,8 +115,8 @@ type ObjectStorage interface {
// GetObjectMetadatas returns the metadata of the objects. // GetObjectMetadatas returns the metadata of the objects.
GetObjectMetadatas(ctx context.Context, bucketName, prefix, marker, delimiter string, limit int64) (*ObjectMetadatas, error) GetObjectMetadatas(ctx context.Context, bucketName, prefix, marker, delimiter string, limit int64) (*ObjectMetadatas, error)
// GetOject returns data of object. // GetObject returns data of object.
GetOject(ctx context.Context, bucketName, objectKey string) (io.ReadCloser, error) GetObject(ctx context.Context, bucketName, objectKey string) (io.ReadCloser, error)
// PutObject puts data of object. // PutObject puts data of object.
PutObject(ctx context.Context, bucketName, objectKey, digest string, reader io.Reader) error PutObject(ctx context.Context, bucketName, objectKey, digest string, reader io.Reader) error

4
pkg/objectstorage/obs.go
View File

@ -164,8 +164,8 @@ func (o *obs) GetObjectMetadatas(ctx context.Context, bucketName, prefix, marker
}, nil }, nil
} }
// GetOject returns data of object. // GetObject returns data of object.
func (o *obs) GetOject(ctx context.Context, bucketName, objectKey string) (io.ReadCloser, error) { func (o *obs) GetObject(ctx context.Context, bucketName, objectKey string) (io.ReadCloser, error) {
resp, err := o.client.GetObject(&huaweiobs.GetObjectInput{ resp, err := o.client.GetObject(&huaweiobs.GetObjectInput{
GetObjectMetadataInput: huaweiobs.GetObjectMetadataInput{ GetObjectMetadataInput: huaweiobs.GetObjectMetadataInput{
Bucket: bucketName, Bucket: bucketName,

4
pkg/objectstorage/oss.go
View File

@ -170,8 +170,8 @@ func (o *oss) GetObjectMetadatas(ctx context.Context, bucketName, prefix, marker
}, nil }, nil
} }
// GetOject returns data of object. // GetObject returns data of object.
func (o *oss) GetOject(ctx context.Context, bucketName, objectKey string) (io.ReadCloser, error) { func (o *oss) GetObject(ctx context.Context, bucketName, objectKey string) (io.ReadCloser, error) {
bucket, err := o.client.Bucket(bucketName) bucket, err := o.client.Bucket(bucketName)
if err != nil { if err != nil {
return nil, err return nil, err

4
pkg/objectstorage/s3.go
View File

@ -179,8 +179,8 @@ func (s *s3) GetObjectMetadatas(ctx context.Context, bucketName, prefix, marker,
}, nil }, nil
} }
// GetOject returns data of object. // GetObject returns data of object.
func (s *s3) GetOject(ctx context.Context, bucketName, objectKey string) (io.ReadCloser, error) { func (s *s3) GetObject(ctx context.Context, bucketName, objectKey string) (io.ReadCloser, error) {
resp, err := s.client.GetObjectWithContext(ctx, &awss3.GetObjectInput{ resp, err := s.client.GetObjectWithContext(ctx, &awss3.GetObjectInput{
Bucket: aws.String(bucketName), Bucket: aws.String(bucketName),
Key: aws.String(objectKey), Key: aws.String(objectKey),