Function doListRangeRequest

api/multiobj.go:72–96

Handles multi-object (delete, prefetch, evict) operations as well as (archive, copy and ETL) transactions

(baseParams BaseParams, bck cmn.Bck, action string, msg interface{})

// Handles multi-object (delete, prefetch, evict) operations
// as well as (archive, copy and ETL) transactions
func doListRangeRequest(baseParams BaseParams, bck cmn.Bck, action string, msg interface{}) (xactID string, err error) {
	q := bck.AddToQuery(nil)
	switch action {
	case apc.ActDeleteObjects, apc.ActEvictObjects:
		baseParams.Method = http.MethodDelete
	case apc.ActPrefetchObjects, apc.ActCopyObjects, apc.ActETLObjects:
		baseParams.Method = http.MethodPost
	case apc.ActArchive:
		baseParams.Method = http.MethodPut
	default:
		err = fmt.Errorf("invalid action %q", action)
		return
	}
	reqParams := AllocRp()
	{
		reqParams.BaseParams = baseParams
		reqParams.Path = apc.URLPathBuckets.Join(bck.Name)
		reqParams.Body = cos.MustMarshal(apc.ActionMsg{Action: action, Value: msg})
		reqParams.Header = http.Header{cos.HdrContentType: []string{cos.ContentJSON}}
		reqParams.Query = q
	}
	err = reqParams.DoHTTPReqResp(&xactID)
	FreeRp(reqParams)
	return
}