Function getArrayElementBounds

riverlog/river_log.go:274–292

(arrayBytes []byte)

}

func getArrayElementBounds(arrayBytes []byte) ([]arrayElementBounds, error) {
	arrResult := gjson.ParseBytes(arrayBytes)
	if !arrResult.IsArray() {
		return nil, errors.New("expected a JSON array")
	}

	elements := arrResult.Array()
	bounds := make([]arrayElementBounds, len(elements))
	for i, elem := range elements {
		if elem.Index < 0 {
			return nil, errors.New("failed to determine array element index")
		}
		bounds[i] = arrayElementBounds{
			Start: elem.Index,
			End:   elem.Index + len(elem.Raw),
		}
	}
	return bounds, nil
}

func getKeepStart(bounds []arrayElementBounds, newEntryLen, maxTotalBytes int) int {
	if maxTotalBytes <= 0 {