GetObject by inode (#69)

Author: FelGel

pkg/dataplane/http/context.go

@@ -519,6 +519,14 @@ func (c *context) GetObjectSync(getObjectInput *v3io.GetObjectInput) (*v3io.Resp
 		headers["Range"] = fmt.Sprintf("bytes=%v-%v", getObjectInput.Offset, getObjectInput.Offset+getObjectInput.NumBytes-1)
 	}
 
+	if getObjectInput.CtimeSec > 0 {
+		if headers == nil {
+			headers = make(map[string]string)
+		}
+		headers["ctime-sec"] = fmt.Sprintf("%d", getObjectInput.CtimeSec)
+		headers["ctime-nsec"] = fmt.Sprintf("%d", getObjectInput.CtimeNsec)
+	}
+
 	return c.sendRequest(&getObjectInput.DataPlaneInput,
 		http.MethodGet,
 		getObjectInput.Path,

pkg/dataplane/test/sync_test.go

@@ -272,7 +272,7 @@ func (suite *syncObjectTestSuite) TestObject() {
 	suite.Require().NoError(err, "Failed to put")
 
 	//
-	// Get the contents
+	// Get the contents by path
 	//
 
 	getObjectInput = &v3io.GetObjectInput{
@@ -291,6 +291,50 @@ func (suite *syncObjectTestSuite) TestObject() {
 	// release the response
 	response.Release()
 
+	//
+	// Get object by inode
+	//
+
+	// Get item attributes to find out what's the inode & ctime
+	getItemInput := v3io.GetItemInput{
+		Path:           path,
+		AttributeNames: []string{"**"},
+	}
+
+	// when run against a context, will populate fields like container name
+	suite.populateDataPlaneInput(&getItemInput.DataPlaneInput)
+
+	response, err = suite.container.GetItemSync(&getItemInput)
+	suite.Require().NoError(err, "Failed to get item")
+
+	// parse item attributes and extract inode & ctime
+	getItemOutput := response.Output.(*v3io.GetItemOutput)
+	inode, err := getItemOutput.Item.GetFieldInt("__inode_number")
+	suite.Require().NoError(err, "Failed to get inode")
+	ctimeSec, err := getItemOutput.Item.GetFieldInt("__ctime_secs")
+	suite.Require().NoError(err, "Failed to get ctime sec")
+	ctimeNsec, err := getItemOutput.Item.GetFieldInt("__ctime_nsecs")
+	suite.Require().NoError(err, "Failed to get ctime nsec")
+
+	// get object using inode and ctime
+	getObjectInput = &v3io.GetObjectInput{
+		Path:      fmt.Sprintf("%d", inode),
+		CtimeSec:  ctimeSec,
+		CtimeNsec: ctimeNsec,
+	}
+
+	// when run against a context, will populate fields like container name
+	suite.populateDataPlaneInput(&getObjectInput.DataPlaneInput)
+
+	response, err = suite.container.GetObjectSync(getObjectInput)
+	suite.Require().NoError(err, "Failed to get")
+
+	// make sure buckets is not empty
+	suite.Require().Equal(contents, string(response.Body()))
+
+	// release the response
+	response.Release()
+
 	//
 	// Delete the object
 	//

pkg/dataplane/types.go

@@ -181,9 +181,11 @@ type ContainerInfo struct {
 
 type GetObjectInput struct {
 	DataPlaneInput
-	Path     string
-	Offset   int
-	NumBytes int
+	Path      string
+	Offset    int
+	NumBytes  int
+	CtimeSec  int
+	CtimeNsec int
 }
 
 type PutObjectInput struct {