Function StreamingSignV4Outposts

pkg/signer/request-signature-streaming.go:396–427

StreamingSignV4Outposts - provides chunked upload signatureV4 support for S3 on Outposts (service name s3-outposts).

(req *http.Request, accessKeyID, secretAccessKey, sessionToken,
	region string, dataLen int64, reqTime time.Time, sh256 md5simd.Hasher,
)

// StreamingSignV4Outposts - provides chunked upload signatureV4 support for S3 on Outposts (service name s3-outposts).
func StreamingSignV4Outposts(req *http.Request, accessKeyID, secretAccessKey, sessionToken,
	region string, dataLen int64, reqTime time.Time, sh256 md5simd.Hasher,
) *http.Request {
	prepareStreamingRequest(req, sessionToken, dataLen, reqTime)
	if req.Body == nil {
		req.Body = io.NopCloser(bytes.NewReader([]byte("")))
	}
	stReader := &StreamingReader{
		baseReadCloser:  req.Body,
		accessKeyID:     accessKeyID,
		secretAccessKey: secretAccessKey,
		sessionToken:    sessionToken,
		region:          region,
		serviceType:     ServiceTypeS3Outposts,
		reqTime:         reqTime,
		chunkBuf:        make([]byte, payloadChunkSize),
		contentLen:      dataLen,
		chunkNum:        1,
		totalChunks:     int((dataLen+payloadChunkSize-1)/payloadChunkSize) + 1,
		lastChunkSize:   int(dataLen % payloadChunkSize),
		sh256:           sh256,
	}
	if len(req.Trailer) > 0 {
		stReader.trailer = req.Trailer
		req.Trailer = nil
	}
	stReader.setSeedSignature(req)
	stReader.setStreamingAuthHeader(req, ServiceTypeS3Outposts)
	stReader.prevSignature = stReader.seedSignature
	req.Body = stReader
	return req
}

// Read - this method performs chunk upload signature providing a
// io.Reader interface.