mirror of
https://github.com/hanzoai/volume.git
synced 2026-10-30 14:55:30 +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.
82 lines
2.5 KiB
Go
82 lines
2.5 KiB
Go
// Copyright 2018 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 impl
|
|
|
|
import (
|
|
"bytes"
|
|
"compress/gzip"
|
|
"io"
|
|
"sync"
|
|
|
|
"google.golang.org/protobuf/internal/filedesc"
|
|
"google.golang.org/protobuf/reflect/protoreflect"
|
|
"google.golang.org/protobuf/reflect/protoregistry"
|
|
)
|
|
|
|
// Every enum and message type generated by protoc-gen-go since commit 2fc053c5
|
|
// on February 25th, 2016 has had a method to get the raw descriptor.
|
|
// Types that were not generated by protoc-gen-go or were generated prior
|
|
// to that version are not supported.
|
|
//
|
|
// The []byte returned is the encoded form of a FileDescriptorProto message
|
|
// compressed using GZIP. The []int is the path from the top-level file
|
|
// to the specific message or enum declaration.
|
|
type (
|
|
enumV1 interface {
|
|
EnumDescriptor() ([]byte, []int)
|
|
}
|
|
messageV1 interface {
|
|
Descriptor() ([]byte, []int)
|
|
}
|
|
)
|
|
|
|
var legacyFileDescCache sync.Map // map[*byte]protoreflect.FileDescriptor
|
|
|
|
// legacyLoadFileDesc unmarshals b as a compressed FileDescriptorProto message.
|
|
//
|
|
// This assumes that b is immutable and that b does not refer to part of a
|
|
// concatenated series of GZIP files (which would require shenanigans that
|
|
// rely on the concatenation properties of both protobufs and GZIP).
|
|
// File descriptors generated by protoc-gen-go do not rely on that property.
|
|
func legacyLoadFileDesc(b []byte) protoreflect.FileDescriptor {
|
|
// Fast-path: check whether we already have a cached file descriptor.
|
|
if fd, ok := legacyFileDescCache.Load(&b[0]); ok {
|
|
return fd.(protoreflect.FileDescriptor)
|
|
}
|
|
|
|
// Slow-path: decompress and unmarshal the file descriptor proto.
|
|
zr, err := gzip.NewReader(bytes.NewReader(b))
|
|
if err != nil {
|
|
panic(err)
|
|
}
|
|
b2, err := io.ReadAll(zr)
|
|
if err != nil {
|
|
panic(err)
|
|
}
|
|
|
|
fd := filedesc.Builder{
|
|
RawDescriptor: b2,
|
|
FileRegistry: resolverOnly{protoregistry.GlobalFiles}, // do not register back to global registry
|
|
}.Build().File
|
|
if fd, ok := legacyFileDescCache.LoadOrStore(&b[0], fd); ok {
|
|
return fd.(protoreflect.FileDescriptor)
|
|
}
|
|
return fd
|
|
}
|
|
|
|
type resolverOnly struct {
|
|
reg *protoregistry.Files
|
|
}
|
|
|
|
func (r resolverOnly) FindFileByPath(path string) (protoreflect.FileDescriptor, error) {
|
|
return r.reg.FindFileByPath(path)
|
|
}
|
|
func (r resolverOnly) FindDescriptorByName(name protoreflect.FullName) (protoreflect.Descriptor, error) {
|
|
return r.reg.FindDescriptorByName(name)
|
|
}
|
|
func (resolverOnly) RegisterFile(protoreflect.FileDescriptor) error {
|
|
return nil
|
|
}
|