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.
75 lines
2.1 KiB
Go
75 lines
2.1 KiB
Go
package reflect2
|
|
|
|
import (
|
|
"reflect"
|
|
"unsafe"
|
|
)
|
|
|
|
type UnsafeStructField struct {
|
|
reflect.StructField
|
|
structType *UnsafeStructType
|
|
rtype unsafe.Pointer
|
|
ptrRType unsafe.Pointer
|
|
}
|
|
|
|
func newUnsafeStructField(structType *UnsafeStructType, structField reflect.StructField) *UnsafeStructField {
|
|
return &UnsafeStructField{
|
|
StructField: structField,
|
|
rtype: unpackEFace(structField.Type).data,
|
|
ptrRType: unpackEFace(reflect.PtrTo(structField.Type)).data,
|
|
structType: structType,
|
|
}
|
|
}
|
|
|
|
func (field *UnsafeStructField) Offset() uintptr {
|
|
return field.StructField.Offset
|
|
}
|
|
|
|
func (field *UnsafeStructField) Name() string {
|
|
return field.StructField.Name
|
|
}
|
|
|
|
func (field *UnsafeStructField) PkgPath() string {
|
|
return field.StructField.PkgPath
|
|
}
|
|
|
|
func (field *UnsafeStructField) Type() Type {
|
|
return field.structType.cfg.Type2(field.StructField.Type)
|
|
}
|
|
|
|
func (field *UnsafeStructField) Tag() reflect.StructTag {
|
|
return field.StructField.Tag
|
|
}
|
|
|
|
func (field *UnsafeStructField) Index() []int {
|
|
return field.StructField.Index
|
|
}
|
|
|
|
func (field *UnsafeStructField) Anonymous() bool {
|
|
return field.StructField.Anonymous
|
|
}
|
|
|
|
func (field *UnsafeStructField) Set(obj interface{}, value interface{}) {
|
|
objEFace := unpackEFace(obj)
|
|
assertType("StructField.SetIndex argument 1", field.structType.ptrRType, objEFace.rtype)
|
|
valueEFace := unpackEFace(value)
|
|
assertType("StructField.SetIndex argument 2", field.ptrRType, valueEFace.rtype)
|
|
field.UnsafeSet(objEFace.data, valueEFace.data)
|
|
}
|
|
|
|
func (field *UnsafeStructField) UnsafeSet(obj unsafe.Pointer, value unsafe.Pointer) {
|
|
fieldPtr := add(obj, field.StructField.Offset, "same as non-reflect &v.field")
|
|
typedmemmove(field.rtype, fieldPtr, value)
|
|
}
|
|
|
|
func (field *UnsafeStructField) Get(obj interface{}) interface{} {
|
|
objEFace := unpackEFace(obj)
|
|
assertType("StructField.GetIndex argument 1", field.structType.ptrRType, objEFace.rtype)
|
|
value := field.UnsafeGet(objEFace.data)
|
|
return packEFace(field.ptrRType, value)
|
|
}
|
|
|
|
func (field *UnsafeStructField) UnsafeGet(obj unsafe.Pointer) unsafe.Pointer {
|
|
return add(obj, field.StructField.Offset, "same as non-reflect &v.field")
|
|
}
|