mirror of
https://github.com/hanzoai/volume.git
synced 2026-10-01 00:48:00 +00:00
zeekay
b61441f7d7
A fork of Rancher's local-path-provisioner at v0.0.36. The behaviour is unchanged and deliberately so — a directory on the node a pod lands on is the right thing for a disk. What changes is identity. The provisioner answers to hanzo.ai/volume rather than rancher.io/local-path. That is not branding: two provisioners sharing one name race for the same claims, and a stock k3s carries the upstream one, so a cluster running both would settle our storage by chance. Data lives at /var/lib/hanzo/volume, so reading a Hanzo cluster does not mean learning another vendor's directory. Apache-2.0 as published, unaltered, with Rancher's attribution in NOTICE. The README says what this is not: durability. A volume here dies with its node. That is hanzoai/replicate's question, one layer up, and keeping the two apart is what lets the disk stay this simple.
131 lines
3.3 KiB
Go
131 lines
3.3 KiB
Go
package jsoniter
|
|
|
|
import "fmt"
|
|
|
|
// ReadNil reads a json object as nil and
|
|
// returns whether it's a nil or not
|
|
func (iter *Iterator) ReadNil() (ret bool) {
|
|
c := iter.nextToken()
|
|
if c == 'n' {
|
|
iter.skipThreeBytes('u', 'l', 'l') // null
|
|
return true
|
|
}
|
|
iter.unreadByte()
|
|
return false
|
|
}
|
|
|
|
// ReadBool reads a json object as BoolValue
|
|
func (iter *Iterator) ReadBool() (ret bool) {
|
|
c := iter.nextToken()
|
|
if c == 't' {
|
|
iter.skipThreeBytes('r', 'u', 'e')
|
|
return true
|
|
}
|
|
if c == 'f' {
|
|
iter.skipFourBytes('a', 'l', 's', 'e')
|
|
return false
|
|
}
|
|
iter.ReportError("ReadBool", "expect t or f, but found "+string([]byte{c}))
|
|
return
|
|
}
|
|
|
|
// SkipAndReturnBytes skip next JSON element, and return its content as []byte.
|
|
// The []byte can be kept, it is a copy of data.
|
|
func (iter *Iterator) SkipAndReturnBytes() []byte {
|
|
iter.startCapture(iter.head)
|
|
iter.Skip()
|
|
return iter.stopCapture()
|
|
}
|
|
|
|
// SkipAndAppendBytes skips next JSON element and appends its content to
|
|
// buffer, returning the result.
|
|
func (iter *Iterator) SkipAndAppendBytes(buf []byte) []byte {
|
|
iter.startCaptureTo(buf, iter.head)
|
|
iter.Skip()
|
|
return iter.stopCapture()
|
|
}
|
|
|
|
func (iter *Iterator) startCaptureTo(buf []byte, captureStartedAt int) {
|
|
if iter.captured != nil {
|
|
panic("already in capture mode")
|
|
}
|
|
iter.captureStartedAt = captureStartedAt
|
|
iter.captured = buf
|
|
}
|
|
|
|
func (iter *Iterator) startCapture(captureStartedAt int) {
|
|
iter.startCaptureTo(make([]byte, 0, 32), captureStartedAt)
|
|
}
|
|
|
|
func (iter *Iterator) stopCapture() []byte {
|
|
if iter.captured == nil {
|
|
panic("not in capture mode")
|
|
}
|
|
captured := iter.captured
|
|
remaining := iter.buf[iter.captureStartedAt:iter.head]
|
|
iter.captureStartedAt = -1
|
|
iter.captured = nil
|
|
return append(captured, remaining...)
|
|
}
|
|
|
|
// Skip skips a json object and positions to relatively the next json object
|
|
func (iter *Iterator) Skip() {
|
|
c := iter.nextToken()
|
|
switch c {
|
|
case '"':
|
|
iter.skipString()
|
|
case 'n':
|
|
iter.skipThreeBytes('u', 'l', 'l') // null
|
|
case 't':
|
|
iter.skipThreeBytes('r', 'u', 'e') // true
|
|
case 'f':
|
|
iter.skipFourBytes('a', 'l', 's', 'e') // false
|
|
case '0':
|
|
iter.unreadByte()
|
|
iter.ReadFloat32()
|
|
case '-', '1', '2', '3', '4', '5', '6', '7', '8', '9':
|
|
iter.skipNumber()
|
|
case '[':
|
|
iter.skipArray()
|
|
case '{':
|
|
iter.skipObject()
|
|
default:
|
|
iter.ReportError("Skip", fmt.Sprintf("do not know how to skip: %v", c))
|
|
return
|
|
}
|
|
}
|
|
|
|
func (iter *Iterator) skipFourBytes(b1, b2, b3, b4 byte) {
|
|
if iter.readByte() != b1 {
|
|
iter.ReportError("skipFourBytes", fmt.Sprintf("expect %s", string([]byte{b1, b2, b3, b4})))
|
|
return
|
|
}
|
|
if iter.readByte() != b2 {
|
|
iter.ReportError("skipFourBytes", fmt.Sprintf("expect %s", string([]byte{b1, b2, b3, b4})))
|
|
return
|
|
}
|
|
if iter.readByte() != b3 {
|
|
iter.ReportError("skipFourBytes", fmt.Sprintf("expect %s", string([]byte{b1, b2, b3, b4})))
|
|
return
|
|
}
|
|
if iter.readByte() != b4 {
|
|
iter.ReportError("skipFourBytes", fmt.Sprintf("expect %s", string([]byte{b1, b2, b3, b4})))
|
|
return
|
|
}
|
|
}
|
|
|
|
func (iter *Iterator) skipThreeBytes(b1, b2, b3 byte) {
|
|
if iter.readByte() != b1 {
|
|
iter.ReportError("skipThreeBytes", fmt.Sprintf("expect %s", string([]byte{b1, b2, b3})))
|
|
return
|
|
}
|
|
if iter.readByte() != b2 {
|
|
iter.ReportError("skipThreeBytes", fmt.Sprintf("expect %s", string([]byte{b1, b2, b3})))
|
|
return
|
|
}
|
|
if iter.readByte() != b3 {
|
|
iter.ReportError("skipThreeBytes", fmt.Sprintf("expect %s", string([]byte{b1, b2, b3})))
|
|
return
|
|
}
|
|
}
|