mirror of
https://github.com/hanzoai/volume.git
synced 2026-11-03 04:24:40 +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.
112 lines
3.5 KiB
Go
112 lines
3.5 KiB
Go
// Copyright 2019 The Go Authors. All rights reserved.
|
|
// Use of this source code is governed by a BSD-style
|
|
// license that can be found in the LICENSE file.
|
|
|
|
package proto
|
|
|
|
import (
|
|
"google.golang.org/protobuf/encoding/protowire"
|
|
"google.golang.org/protobuf/internal/encoding/messageset"
|
|
"google.golang.org/protobuf/reflect/protoreflect"
|
|
"google.golang.org/protobuf/runtime/protoiface"
|
|
)
|
|
|
|
// Size returns the size in bytes of the wire-format encoding of m.
|
|
//
|
|
// Note that Size might return more bytes than Marshal will write in the case of
|
|
// lazily decoded messages that arrive in non-minimal wire format: see
|
|
// https://protobuf.dev/reference/go/size/ for more details.
|
|
func Size(m Message) int {
|
|
return MarshalOptions{}.Size(m)
|
|
}
|
|
|
|
// Size returns the size in bytes of the wire-format encoding of m.
|
|
//
|
|
// Note that Size might return more bytes than Marshal will write in the case of
|
|
// lazily decoded messages that arrive in non-minimal wire format: see
|
|
// https://protobuf.dev/reference/go/size/ for more details.
|
|
func (o MarshalOptions) Size(m Message) int {
|
|
// Treat a nil message interface as an empty message; nothing to output.
|
|
if m == nil {
|
|
return 0
|
|
}
|
|
|
|
return o.size(m.ProtoReflect())
|
|
}
|
|
|
|
// size is a centralized function that all size operations go through.
|
|
// For profiling purposes, avoid changing the name of this function or
|
|
// introducing other code paths for size that do not go through this.
|
|
func (o MarshalOptions) size(m protoreflect.Message) (size int) {
|
|
methods := protoMethods(m)
|
|
if methods != nil && methods.Size != nil {
|
|
out := methods.Size(protoiface.SizeInput{
|
|
Message: m,
|
|
Flags: o.flags(),
|
|
})
|
|
return out.Size
|
|
}
|
|
if methods != nil && methods.Marshal != nil {
|
|
// This is not efficient, but we don't have any choice.
|
|
// This case is mainly used for legacy types with a Marshal method.
|
|
out, _ := methods.Marshal(protoiface.MarshalInput{
|
|
Message: m,
|
|
Flags: o.flags(),
|
|
})
|
|
return len(out.Buf)
|
|
}
|
|
return o.sizeMessageSlow(m)
|
|
}
|
|
|
|
func (o MarshalOptions) sizeMessageSlow(m protoreflect.Message) (size int) {
|
|
if messageset.IsMessageSet(m.Descriptor()) {
|
|
return o.sizeMessageSet(m)
|
|
}
|
|
m.Range(func(fd protoreflect.FieldDescriptor, v protoreflect.Value) bool {
|
|
size += o.sizeField(fd, v)
|
|
return true
|
|
})
|
|
size += len(m.GetUnknown())
|
|
return size
|
|
}
|
|
|
|
func (o MarshalOptions) sizeField(fd protoreflect.FieldDescriptor, value protoreflect.Value) (size int) {
|
|
num := fd.Number()
|
|
switch {
|
|
case fd.IsList():
|
|
return o.sizeList(num, fd, value.List())
|
|
case fd.IsMap():
|
|
return o.sizeMap(num, fd, value.Map())
|
|
default:
|
|
return protowire.SizeTag(num) + o.sizeSingular(num, fd.Kind(), value)
|
|
}
|
|
}
|
|
|
|
func (o MarshalOptions) sizeList(num protowire.Number, fd protoreflect.FieldDescriptor, list protoreflect.List) (size int) {
|
|
sizeTag := protowire.SizeTag(num)
|
|
|
|
if fd.IsPacked() && list.Len() > 0 {
|
|
content := 0
|
|
for i, llen := 0, list.Len(); i < llen; i++ {
|
|
content += o.sizeSingular(num, fd.Kind(), list.Get(i))
|
|
}
|
|
return sizeTag + protowire.SizeBytes(content)
|
|
}
|
|
|
|
for i, llen := 0, list.Len(); i < llen; i++ {
|
|
size += sizeTag + o.sizeSingular(num, fd.Kind(), list.Get(i))
|
|
}
|
|
return size
|
|
}
|
|
|
|
func (o MarshalOptions) sizeMap(num protowire.Number, fd protoreflect.FieldDescriptor, mapv protoreflect.Map) (size int) {
|
|
sizeTag := protowire.SizeTag(num)
|
|
|
|
mapv.Range(func(key protoreflect.MapKey, value protoreflect.Value) bool {
|
|
size += sizeTag
|
|
size += protowire.SizeBytes(o.sizeField(fd.MapKey(), key.Value()) + o.sizeField(fd.MapValue(), value))
|
|
return true
|
|
})
|
|
return size
|
|
}
|