Support mtime header (#136)

* support mtime header in getItem req

* make map with size

Co-authored-by: shay <shayp@iguazio.com>

Author: assaf758

pkg/dataplane/http/context.go

@@ -346,9 +346,19 @@ func (c *context) GetItemsSync(getItemsInput *v3io.GetItemsInput) (*v3io.Respons
 		return nil, err
 	}
 
-	headers := getItemsHeadersCapnp
+	commonHeaders := getItemsHeadersCapnp
 	if getItemsInput.RequestJSONResponse {
-		headers = getItemsHeaders
+		commonHeaders = getItemsHeaders
+	}
+
+	headers := make(map[string]string, len(commonHeaders))
+	for k, v := range commonHeaders {
+		headers[k] = v
+	}
+
+	if len(getItemsInput.DataPlaneInput.MtimeSec) > 0 {
+		headers["conditional-mtime-sec"] = getItemsInput.DataPlaneInput.MtimeSec
+		headers["conditional-mtime-nsec"] = getItemsInput.DataPlaneInput.MtimeNsec
 	}
 
 	response, err := c.sendRequest(&getItemsInput.DataPlaneInput,

pkg/dataplane/types.go

@@ -50,6 +50,8 @@ type DataPlaneInput struct {
 	ContainerName          string
 	AuthenticationToken    string
 	AccessKey              string
+	MtimeSec               string
+	MtimeNsec              string
 	Timeout                time.Duration
 	IncludeResponseInError bool
 }
@@ -295,6 +297,7 @@ type GetItemsInput struct {
 	SortKeyRangeEnd     string
 	AllowObjectScatter  string
 	ReturnData          string
+	ReturnAllInodes     bool
 	DataMaxSize         int
 	RequestJSONResponse bool `json:"RequestJsonResponse"`
 	ChokeGetItemsMS     int