wehub-resource-sync
74 lines
2.1 KiB
Go
74 lines
2.1 KiB
Go
// Copyright 2019 Dolthub, Inc.
|
|
//
|
|
// Licensed under the Apache License, Version 2.0 (the "License");
|
|
// you may not use this file except in compliance with the License.
|
|
// You may obtain a copy of the License at
|
|
//
|
|
// http://www.apache.org/licenses/LICENSE-2.0
|
|
//
|
|
// Unless required by applicable law or agreed to in writing, software
|
|
// distributed under the License is distributed on an "AS IS" BASIS,
|
|
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
// See the License for the specific language governing permissions and
|
|
// limitations under the License.
|
|
|
|
package blobstore
|
|
|
|
import (
|
|
"fmt"
|
|
)
|
|
|
|
// BlobRange represents a segment of a blob of data. Offset is the beginning of
|
|
// the range and Length is the size. If Length is 0 that means all data beyond
|
|
// offset will be read. Lengths cannot be negative. Negative offsets indicate
|
|
// distance from the end of the end of the blob.
|
|
type BlobRange struct {
|
|
offset int64
|
|
length int64
|
|
}
|
|
|
|
// NewBlobRange creates a BlobRange with a given offset and length
|
|
func NewBlobRange(offset, length int64) BlobRange {
|
|
if length < 0 {
|
|
panic("BlobRanges cannot have 0 length")
|
|
}
|
|
|
|
return BlobRange{offset, length}
|
|
}
|
|
|
|
// IsAllRange is true if it represents the entire blob from index 0 to the end
|
|
// and false if it is any subset of the data
|
|
func (br BlobRange) isAllRange() bool {
|
|
return br.offset == 0 && br.length == 0
|
|
}
|
|
|
|
// PositiveRange returns a BlobRange which represents the same range but with
|
|
// negative offsets replaced with actual values
|
|
func (br BlobRange) positiveRange(size int64) BlobRange {
|
|
offset := br.offset
|
|
length := br.length
|
|
|
|
if offset < 0 {
|
|
offset = size + offset
|
|
}
|
|
|
|
if offset+length > size || length == 0 {
|
|
length = size - offset
|
|
}
|
|
|
|
return BlobRange{offset, length}
|
|
}
|
|
|
|
func (br BlobRange) asHttpRangeHeader() string {
|
|
if br.isAllRange() {
|
|
return ""
|
|
}
|
|
if br.length == 0 || br.offset < 0 {
|
|
return fmt.Sprintf("bytes=%d", br.offset)
|
|
}
|
|
return fmt.Sprintf("bytes=%d-%d", br.offset, br.offset+br.length-1)
|
|
}
|
|
|
|
// AllRange is a BlobRange instance covering all values
|
|
var AllRange = NewBlobRange(0, 0)
|