Directories
¶
| Path | Synopsis |
|---|---|
|
cmd
|
|
|
pqproof
command
|
|
|
docker
|
|
|
admin_integration
command
|
|
|
other
|
|
|
admin/view/app
templ: version: v0.3.1001
|
templ: version: v0.3.1001 |
|
admin/view/components
templ: version: v0.3.1001
|
templ: version: v0.3.1001 |
|
admin/view/layout
templ: version: v0.3.1001
|
templ: version: v0.3.1001 |
|
filer/foundationdb
Package foundationdb provides a FoundationDB-based filer store for Hanzo.
|
Package foundationdb provides a FoundationDB-based filer store for Hanzo. |
|
filer/luxdb
Package luxdb implements the filer metadata store over luxfi/database, the lux-canonical key-value abstraction.
|
Package luxdb implements the filer metadata store over luxfi/database, the lux-canonical key-value abstraction. |
|
filer/posixlock
Package posixlock implements the conflict, coalescing, and range-split logic for POSIX advisory file locks — fcntl byte-range and flock whole-file — as a pure per-inode lock set with no concurrency control of its own.
|
Package posixlock implements the conflict, coalescing, and range-split logic for POSIX advisory file locks — fcntl byte-range and flock whole-file — as a pure per-inode lock set with no concurrency control of its own. |
|
filer/sqlite
Package sqlite is for sqlite filer store.
|
Package sqlite is for sqlite filer store. |
|
glog
Package glog implements logging analogous to the Google-internal C++ INFO/ERROR/V setup.
|
Package glog implements logging analogous to the Google-internal C++ INFO/ERROR/V setup. |
|
iam/utils
Package utils provides utility functions for AWS IAM ARN parsing and role extraction.
|
Package utils provides utility functions for AWS IAM ARN parsing and role extraction. |
|
kms/lux
Package lux is the KMS provider backed by luxfi/kms — the one place Hanzo and Lux keep secrets.
|
Package lux is the KMS provider backed by luxfi/kms — the one place Hanzo and Lux keep secrets. |
|
mq/agent/agentconv
Package agentconv transcodes the schema_pb messages that ride inside the HanzoMessagingAgent RPCs (Topic, RecordType, RecordValue, PartitionOffset) between their protobuf form — still the lingua franca of the broker/topic/ pub_client/sub_client layers — and their ZAP wire form (mq_schemawire).
|
Package agentconv transcodes the schema_pb messages that ride inside the HanzoMessagingAgent RPCs (Topic, RecordType, RecordValue, PartitionOffset) between their protobuf form — still the lingua franca of the broker/topic/ pub_client/sub_client layers — and their ZAP wire form (mq_schemawire). |
|
mq/broker/brokerpb
Package brokerpb transcodes the mq_pb broker-domain messages that ride inside the HanzoMessaging RPCs (DataMessage, BrokerPartitionAssignment, the SubscribeMessage and SubscriberToSubCoordinator stream frames) between their protobuf form — still the in-memory model of the broker/topic/publisher/ subscriber layers — and their ZAP wire form (mq_brokerwire).
|
Package brokerpb transcodes the mq_pb broker-domain messages that ride inside the HanzoMessaging RPCs (DataMessage, BrokerPartitionAssignment, the SubscribeMessage and SubscriberToSubCoordinator stream frames) between their protobuf form — still the in-memory model of the broker/topic/publisher/ subscriber layers — and their ZAP wire form (mq_brokerwire). |
|
mq/kafka
Package kafka provides Kafka protocol implementation for Hanzo MQ
|
Package kafka provides Kafka protocol implementation for Hanzo MQ |
|
pb/filerstub
Package filerstub provides embeddable, do-nothing implementations of the generated server interfaces (filer_pb.HanzoFilerServer, master_pb.HanzoServer) for tests.
|
Package filerstub provides embeddable, do-nothing implementations of the generated server interfaces (filer_pb.HanzoFilerServer, master_pb.HanzoServer) for tests. |
|
pb/rpc
Package rpc holds the grpc-free streaming contracts shared by the generated *_pb packages.
|
Package rpc holds the grpc-free streaming contracts shared by the generated *_pb packages. |
|
plugin/worker/handlers
Package handlers is an aggregator that blank-imports every plugin worker handler subpackage so their init() functions register with the handler registry.
|
Package handlers is an aggregator that blank-imports every plugin worker handler subpackage so their init() functions register with the handler registry. |
|
replication/filerclient
Package filerclient is the replication subsystem's strangler seam onto the native ZAP transport for the HanzoFiler service.
|
Package filerclient is the replication subsystem's strangler seam onto the native ZAP transport for the HanzoFiler service. |
|
s3api
Package s3api implements the S3 API for Hanzo.
|
Package s3api implements the S3 API for Hanzo. |
|
s3api/lifecycle_xml
Package lifecycle_xml is the XML wire-form for S3 BucketLifecycleConfiguration: the structs S3 PutBucketLifecycleConfiguration accepts and GetBucketLifecycleConfiguration returns.
|
Package lifecycle_xml is the XML wire-form for S3 BucketLifecycleConfiguration: the structs S3 PutBucketLifecycleConfiguration accepts and GetBucketLifecycleConfiguration returns. |
|
s3api/s3lifecycle/bootstrap
Package bootstrap is the bucket-level lifecycle walker.
|
Package bootstrap is the bucket-level lifecycle walker. |
|
s3api/s3lifecycle/dailyrun
Package dailyrun implements the daily-replay s3 lifecycle worker described in s3/s3api/s3lifecycle/DESIGN.md.
|
Package dailyrun implements the daily-replay s3 lifecycle worker described in s3/s3api/s3lifecycle/DESIGN.md. |
|
s3api/s3lifecycle/engine
Package engine compiles per-bucket lifecycle rules into a CompiledAction snapshot.
|
Package engine compiles per-bucket lifecycle rules into a CompiledAction snapshot. |
|
s3api/s3lifecycle/lifecycletest
Package lifecycletest provides reusable test doubles for the lifecycle worker pipeline.
|
Package lifecycletest provides reusable test doubles for the lifecycle worker pipeline. |
|
security/certreload
Package certreload provides a native, gRPC-free reloading X.509 keypair so both TLS servers (s3/security) and TLS clients (s3/util/http/client) can share one hot-reload implementation without an import cycle between them.
|
Package certreload provides a native, gRPC-free reloading X.509 keypair so both TLS servers (s3/security) and TLS clients (s3/util/http/client) can share one hot-reload implementation without an import cycle between them. |
|
sftpd
sftp_helpers.go
|
sftp_helpers.go |
|
sftpd/auth
Package auth provides authentication and authorization functionality for the SFTP server
|
Package auth provides authentication and authorization functionality for the SFTP server |
|
sftpd/user
Package user provides user management functionality for the SFTP server
|
Package user provides user management functionality for the SFTP server |
|
storage/backend/all
Package all registers every tiered-storage backend factory.
|
Package all registers every tiered-storage backend factory. |
|
storage/erasure_coding/distribution
Package distribution provides EC shard distribution algorithms with configurable EC ratios.
|
Package distribution provides EC shard distribution algorithms with configurable EC ratios. |
|
storage/erasure_coding/ecbalancer
Package ecbalancer holds the EC-shard rebalancing policy shared by the shell ec.balance command and the admin EC balance worker.
|
Package ecbalancer holds the EC-shard rebalancing policy shared by the shell ec.balance command and the admin EC balance worker. |
|
storage/volume_replica
Package volume_replica reconciles regular (non-EC) volume replicas: it reads per-replica status, builds the union of all live entries onto the most-complete replica, and returns that replica.
|
Package volume_replica reconciles regular (non-EC) volume replicas: it reads per-replica status, builds the union of all live entries onto the most-complete replica, and returns that replica. |
|
svc/filer
Package filerzap is the gRPC→ZAP migration layer for the filer service: it converts the protobuf filer aggregate types (filer_pb) to and from their zero-copy ZAP wire encodings (filerwire), so the filer can serve and be called over the canonical github.com/zap-proto/go transport instead of gRPC.
|
Package filerzap is the gRPC→ZAP migration layer for the filer service: it converts the protobuf filer aggregate types (filer_pb) to and from their zero-copy ZAP wire encodings (filerwire), so the filer can serve and be called over the canonical github.com/zap-proto/go transport instead of gRPC. |
|
svc/object
Package object is S3's native ZAP service — the interface internal Hanzo services use to talk to S3 over the mesh (zero-copy ZAP, never HTTP).
|
Package object is S3's native ZAP service — the interface internal Hanzo services use to talk to S3 over the mesh (zero-copy ZAP, never HTTP). |
|
util/fla9
Package flag implements command-line flag parsing.
|
Package flag implements command-line flag parsing. |
|
util/httpdown
Package httpdown provides http.ConnState enabled graceful termination of http.Server.
|
Package httpdown provides http.ConnState enabled graceful termination of http.Server. |
|
util/pgxutil
Package pgxutil holds shared helpers for opening *sql.DB handles backed by jackc/pgx, used by the postgres filer and credential stores so they stay consistent on connection setup, mTLS handling and PgBouncer compatibility.
|
Package pgxutil holds shared helpers for opening *sql.DB handles backed by jackc/pgx, used by the postgres filer and credential stores so they stay consistent on connection setup, mTLS handling and PgBouncer compatibility. |
|
wire/iamadapt
Package iamadapt bridges the protobuf iam_pb domain structs and the zero-copy iamwire ZAP messages for the HanzoS3IamCache RPC.
|
Package iamadapt bridges the protobuf iam_pb domain structs and the zero-copy iamwire ZAP messages for the HanzoS3IamCache RPC. |
|
wire/mq_schema
Package mq_schemawire holds the native ZAP schemas for mq_schema.proto — zero-copy, protobuf-free, no _pb.
|
Package mq_schemawire holds the native ZAP schemas for mq_schema.proto — zero-copy, protobuf-free, no _pb. |
|
wire/plugin/zapbridge
Package pluginzapbridge converts the two PluginControlService.WorkerStream frame types between their protobuf domain form (s3/pb/plugin_pb) and their ZAP wire form (s3/wire/plugin).
|
Package pluginzapbridge converts the two PluginControlService.WorkerStream frame types between their protobuf domain form (s3/pb/plugin_pb) and their ZAP wire form (s3/wire/plugin). |
|
worker/wirebridge
Package wirebridge is the single, orthogonal seam between the worker protobuf message tree (worker_pb) and the native ZAP wire envelopes (workerwire) carried over the zap-proto transport.
|
Package wirebridge is the single, orthogonal seam between the worker protobuf message tree (worker_pb) and the native ZAP wire envelopes (workerwire) carried over the zap-proto transport. |
|
s3-volume
|
|
|
tools
command
|
|
|
telemetry
|
|
|
test
command
|
|
|
server
module
|
|
|
test
|
|
|
mq/consumer
command
|
|
|
mq/producer
command
|
|
|
postgres
command
|
|
|
s3/multipart
command
|
|
|
s3/remote_cache/utils
command
|
|
|
s3/s3client
command
|
|
|
testutil
Package testutil provides shared test utilities for Hanzo integration tests.
|
Package testutil provides shared test utilities for Hanzo integration tests. |
|
kafka
module
|
|
|
kafka/kafka-client-loadtest
module
|
|
|
s3/iam
module
|
|
|
unmaintained
|
|
|
change_superblock
command
|
|
|
check_disk_size
command
|
|
|
compact_leveldb
command
|
|
|
diff_volume_servers
command
|
|
|
disk
command
|
|
|
fix_dat
command
|
|
|
load_test/load_test_leveldb
command
|
|
|
load_test/load_test_meta_tail
command
|
|
|
remove_duplicate_fids
command
|
|
|
repeated_vacuum
command
|
|
|
s3/presigned_put
command
|
|
|
see_dat
command
|
|
|
see_idx
command
|
|
|
see_log_entry
command
|
|
|
see_meta
command
|
|
|
stream_read_volume
command
|
|
|
stress
command
|
|
|
stress_filer_upload/write_files
command
|
|
|
volume_tailer
command
|
Click to show internal directories.
Click to hide internal directories.