storageconfig

type BackendKind int32

type BackendSpec struct {
	Id              string      `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Kind            BackendKind `protobuf:"varint,2,opt,name=kind,proto3,enum=unbounded.storage.config.BackendKind" json:"kind,omitempty"`
	Endpoint        string      `protobuf:"bytes,3,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	StripeSizeBytes uint64      `protobuf:"varint,4,opt,name=stripe_size_bytes,json=stripeSizeBytes,proto3" json:"stripe_size_bytes,omitempty"`
	HttpConcurrency uint32      `protobuf:"varint,5,opt,name=http_concurrency,json=httpConcurrency,proto3" json:"http_concurrency,omitempty"`
	Bucket          *string     `protobuf:"bytes,6,opt,name=bucket,proto3,oneof" json:"bucket,omitempty"`
	// contains filtered or unexported fields
}

type Config struct {

	// Operator-assigned configuration version. The daemon treats it as an
	// opaque counter: it never drives behavior, but it is tracked as the
	// latest-known and latest-applied config versions so operators can
	// confirm a pushed config has been realized across the process. The
	// proto3 zero value (0) means "unversioned".
	Version   uint64          `protobuf:"varint,6,opt,name=version,proto3" json:"version,omitempty"`
	P2P       *P2PCfg         `protobuf:"bytes,1,opt,name=p2p,proto3" json:"p2p,omitempty"`
	Peers     []*PeerSpec     `protobuf:"bytes,2,rep,name=peers,proto3" json:"peers,omitempty"`
	Disks     []*DiskSpec     `protobuf:"bytes,3,rep,name=disks,proto3" json:"disks,omitempty"`
	Backends  []*BackendSpec  `protobuf:"bytes,4,rep,name=backends,proto3" json:"backends,omitempty"`
	Frontends []*FrontendSpec `protobuf:"bytes,5,rep,name=frontends,proto3" json:"frontends,omitempty"`
	// Startup-fixed settings (memory backing, fabric endpoint/threads, CPU
	// topology placement). Unlike the rest of the config these cannot be
	// hot-reloaded: they are read exactly once when the process starts and
	// changing them requires a restart. They are deliberately excluded from
	// ConfigDiff; operators observe which config version's startup settings
	// are realized via the separately tracked "startup" config version.
	Startup *StartupCfg `protobuf:"bytes,7,opt,name=startup,proto3" json:"startup,omitempty"`
	// contains filtered or unexported fields
}

type DiskKind int32

type DiskSpec struct {
	Path                     string   `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Kind                     DiskKind `protobuf:"varint,2,opt,name=kind,proto3,enum=unbounded.storage.config.DiskKind" json:"kind,omitempty"`
	Size                     *uint64  `protobuf:"varint,3,opt,name=size,proto3,oneof" json:"size,omitempty"`
	Numa                     *uint32  `protobuf:"varint,4,opt,name=numa,proto3,oneof" json:"numa,omitempty"`
	QueueDepth               *uint32  `protobuf:"varint,5,opt,name=queue_depth,json=queueDepth,proto3,oneof" json:"queue_depth,omitempty"`
	PageSizeBytes            *uint64  `protobuf:"varint,6,opt,name=page_size_bytes,json=pageSizeBytes,proto3,oneof" json:"page_size_bytes,omitempty"`
	BypassAdmission          bool     `protobuf:"varint,7,opt,name=bypass_admission,json=bypassAdmission,proto3" json:"bypass_admission,omitempty"`
	SkipRecoveryScanIfNoMeta bool     `` /* 142-byte string literal not displayed */
	// contains filtered or unexported fields
}

type FabricAddress struct {

	// Numeric IP socket address usable by libfabric/RDMA CM, e.g.
	// "10.0.0.1:9000". On InfiniBand this is usually an IPoIB address;
	// on tcp fallback it is a normal TCP socket address.
	Socket string `protobuf:"bytes,1,opt,name=socket,proto3" json:"socket,omitempty"`
	// Provider-native escape hatch for RDMA deployments without socket
	// addressing. Currently encoded as "hex:<fi_getname-bytes>" so a
	// controller can publish the raw provider address when needed.
	Native string `protobuf:"bytes,2,opt,name=native,proto3" json:"native,omitempty"`
	// contains filtered or unexported fields
}

type FabricCfg struct {

	// Per-shard fabric listen address. "" -> "0.0.0.0:0" (":0" picks a free
	// port).
	ListenAddr string `protobuf:"bytes,1,opt,name=listen_addr,json=listenAddr,proto3" json:"listen_addr,omitempty"`
	// libfabric progress threads per shard. 0 -> 2.
	ProgressThreads uint32 `protobuf:"varint,2,opt,name=progress_threads,json=progressThreads,proto3" json:"progress_threads,omitempty"`
	// Progress-thread busy-poll budget in microseconds. 0 -> 10.
	ProgressPollUs uint32 `protobuf:"varint,3,opt,name=progress_poll_us,json=progressPollUs,proto3" json:"progress_poll_us,omitempty"`
	// Fabric RPC worker threads per shard. 0 -> 4.
	RpcWorkerThreads uint32 `protobuf:"varint,4,opt,name=rpc_worker_threads,json=rpcWorkerThreads,proto3" json:"rpc_worker_threads,omitempty"`
	// Max in-flight fabric operations per shard (back-pressure limit that
	// sizes the completion registry and server-side request cap). 0 -> 1024.
	MaxInflight uint32 `protobuf:"varint,5,opt,name=max_inflight,json=maxInflight,proto3" json:"max_inflight,omitempty"`
	// contains filtered or unexported fields
}

type FrontendKind int32

type FrontendSpec struct {
	Id      string       `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Kind    FrontendKind `protobuf:"varint,2,opt,name=kind,proto3,enum=unbounded.storage.config.FrontendKind" json:"kind,omitempty"`
	Bind    string       `protobuf:"bytes,3,opt,name=bind,proto3" json:"bind,omitempty"`
	Backend string       `protobuf:"bytes,4,opt,name=backend,proto3" json:"backend,omitempty"`
	// contains filtered or unexported fields
}

type MemoryCfg struct {

	// Allocate per-shard backing from the heap instead of 2 MiB hugepages.
	NoHugepages bool `protobuf:"varint,1,opt,name=no_hugepages,json=noHugepages,proto3" json:"no_hugepages,omitempty"`
	// Total backing pool across all serving shards, in bytes. Each serving
	// shard is allocated `memory_total_bytes / serving_shard_count`,
	// NUMA-local, so the host footprint stays fixed regardless of the
	// auto-scaled serving-core count. 0 -> 128 MiB.
	MemoryTotalBytes uint64 `protobuf:"varint,2,opt,name=memory_total_bytes,json=memoryTotalBytes,proto3" json:"memory_total_bytes,omitempty"`
	// contains filtered or unexported fields
}

type MetricsCfg struct {

	// Listen address for the Prometheus metrics exporter (e.g.
	// "0.0.0.0:9100"). "" -> exporter disabled.
	Bind string `protobuf:"bytes,1,opt,name=bind,proto3" json:"bind,omitempty"`
	// contains filtered or unexported fields
}

type P2PCfg struct {
	FingersPerNode uint32   `protobuf:"varint,1,opt,name=fingers_per_node,json=fingersPerNode,proto3" json:"fingers_per_node,omitempty"`
	LocalNodeId    *uint64  `protobuf:"varint,2,opt,name=local_node_id,json=localNodeId,proto3,oneof" json:"local_node_id,omitempty"`
	LocalLabels    []string `protobuf:"bytes,3,rep,name=local_labels,json=localLabels,proto3" json:"local_labels,omitempty"`
	// When set, the daemon uses this precomputed routing table verbatim
	// instead of deriving fingers from the full peer set. This is the
	// "disjoint discovery" mode: a global-view planner selects each
	// node's neighbors and ships them here, so a node only needs to know
	// (and connect to) its direct routing neighbors. When unset, the
	// daemon falls back to building the finger table from `peers` using
	// `fingers_per_node`.
	RoutingPlan *RoutingPlan `protobuf:"bytes,4,opt,name=routing_plan,json=routingPlan,proto3,oneof" json:"routing_plan,omitempty"`
	// contains filtered or unexported fields
}

type PeerSpec struct {
	Id      uint64         `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Address *FabricAddress `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	HcaNuma *uint32        `protobuf:"varint,3,opt,name=hca_numa,json=hcaNuma,proto3,oneof" json:"hca_numa,omitempty"`
	Labels  []string       `protobuf:"bytes,4,rep,name=labels,proto3" json:"labels,omitempty"`
	// contains filtered or unexported fields
}

type RoutingPlan struct {

	// Peer ids selected as fingers. The local node id is excluded and
	// the order is irrelevant (routing scans all fingers regardless).
	Fingers []uint64 `protobuf:"varint,1,rep,packed,name=fingers,proto3" json:"fingers,omitempty"`
	// Peer id of the nearest-forward neighbor on the ring.
	Successor *uint64 `protobuf:"varint,2,opt,name=successor,proto3,oneof" json:"successor,omitempty"`
	// Peer id of the nearest-backward neighbor on the ring.
	Predecessor *uint64 `protobuf:"varint,3,opt,name=predecessor,proto3,oneof" json:"predecessor,omitempty"`
	// contains filtered or unexported fields
}

type StartupCfg struct {
	Memory   *MemoryCfg   `protobuf:"bytes,1,opt,name=memory,proto3" json:"memory,omitempty"`
	Fabric   *FabricCfg   `protobuf:"bytes,2,opt,name=fabric,proto3" json:"fabric,omitempty"`
	Topology *TopologyCfg `protobuf:"bytes,3,opt,name=topology,proto3" json:"topology,omitempty"`
	Metrics  *MetricsCfg  `protobuf:"bytes,4,opt,name=metrics,proto3" json:"metrics,omitempty"`
	// contains filtered or unexported fields
}

type TopologyCfg struct {

	// Place shards on SMT sibling CPUs as well as physical cores.
	UseSmtSiblings bool `protobuf:"varint,4,opt,name=use_smt_siblings,json=useSmtSiblings,proto3" json:"use_smt_siblings,omitempty"`
	// Schedule shards onto isolcpus-isolated CPUs too. The proto3 false
	// default preserves the historical "respect isolated CPUs" behavior.
	IgnoreIsolated bool `protobuf:"varint,5,opt,name=ignore_isolated,json=ignoreIsolated,proto3" json:"ignore_isolated,omitempty"`
	// Allow placing a shard on each NUMA node's CPU 0. The proto3 false
	// default preserves the historical "exclude node CPU 0" behavior.
	IncludeNodeCpu0 bool `protobuf:"varint,6,opt,name=include_node_cpu0,json=includeNodeCpu0,proto3" json:"include_node_cpu0,omitempty"`
	// Use HCA ports that are not in the active state. The proto3 false
	// default preserves the historical "require active port" behavior.
	AllowInactivePort bool `protobuf:"varint,7,opt,name=allow_inactive_port,json=allowInactivePort,proto3" json:"allow_inactive_port,omitempty"`
	// Disable RDMA and force the libfabric tcp provider.
	DisableRdma bool `protobuf:"varint,8,opt,name=disable_rdma,json=disableRdma,proto3" json:"disable_rdma,omitempty"`
	// Cap on the number of serving-shard CPUs to pin. 0 -> auto (claim
	// every usable core left after storage and NIC-worker reservations).
	ServingCores uint64 `protobuf:"varint,9,opt,name=serving_cores,json=servingCores,proto3" json:"serving_cores,omitempty"`
	// NIC-worker CPUs to pin per active HCA. 0 -> 4.
	NicWorkers uint64 `protobuf:"varint,10,opt,name=nic_workers,json=nicWorkers,proto3" json:"nic_workers,omitempty"`
	// Maximum number of HCAs to use per NUMA node. 0 -> 1. Raise this to
	// use additional HCAs on a NUMA node. HCAs whose NUMA node is unknown
	// are never capped.
	HcasPerNumaNode uint64 `protobuf:"varint,11,opt,name=hcas_per_numa_node,json=hcasPerNumaNode,proto3" json:"hcas_per_numa_node,omitempty"`
	// contains filtered or unexported fields
}