mirror of
https://github.com/featurebasedb/featurebase.git
synced 2026-09-06 16:45:55 +00:00
fd9d4de31d
We had two different, incompatible-with-each-other, and both individually broken, partial implementations of resizing logic. There's the original pre-etcd resize, and then the etcd resize, and neither works, but there's conflicts between the ways they don't work. No attempt to fix this is likely to yield decent results, so instead, we yank them both out entirely, so if we decide to implement resizing (which we will) we won't be confused by stray code pertaining to resizing that's not really hooked up to anything. We're leaving the resize messages in protobuf to avoid renumbering protobuf messages. We rename some of our message types to UNUSED0, etcetera, so that any code still using the old names won't compile, to make sure we get rid of it, but we can't just drop the numbers without breaking rolling restart. The Resize_AddNode tests are removed not just because we don't have resizing, but because they were completely broken anyway and never worked at all. But there's no reason to fix them because they exist to fix the functionality we didn't have and are now removing the vestigial remains of. We also drop the one usage of the AddNode function of Noder, because it was used only by one test code fragment that was creatincg clusters, and that can be done more correctly. There were no other call sites at all. We mark the monitorAntiEntropy function to be ignored by code coverage because it's not actually being covered. There's a separate ticket for removing that entirely.
66 lines
1.6 KiB
Go
66 lines
1.6 KiB
Go
// Copyright 2021 Molecula Corp. All rights reserved.
|
|
package topology
|
|
|
|
import (
|
|
"sort"
|
|
)
|
|
|
|
// Noder is an interface which abstracts the Node slice so that the list of
|
|
// nodes in a cluster can be maintained outside of the cluster struct.
|
|
type Noder interface {
|
|
Nodes() []*Node // Remember: this has to be sorted correctly!!
|
|
PrimaryNodeID(hasher Hasher) string
|
|
}
|
|
|
|
// localNoder is a simple implementation of the Noder interface
|
|
// which maintains an instance of the `nodes` slice.
|
|
type localNoder struct {
|
|
nodes []*Node
|
|
}
|
|
|
|
// NewLocalNoder is a helper function for wrapping an existing slice of Nodes
|
|
// with something which implements Noder.
|
|
func NewLocalNoder(nodes []*Node) *localNoder {
|
|
return &localNoder{
|
|
nodes: nodes,
|
|
}
|
|
}
|
|
|
|
// NewEmptyLocalNoder is an empty Noder used for testing.
|
|
func NewEmptyLocalNoder() *localNoder {
|
|
return &localNoder{}
|
|
}
|
|
|
|
// NewIDNoder is a helper function for wrapping an existing slice of Node IDs
|
|
// with something which implements Noder.
|
|
func NewIDNoder(ids []string) *localNoder {
|
|
nodes := make([]*Node, len(ids))
|
|
for i, id := range ids {
|
|
node := &Node{
|
|
ID: id,
|
|
}
|
|
nodes[i] = node
|
|
}
|
|
|
|
// Nodes must be sorted.
|
|
sort.Sort(ByID(nodes))
|
|
|
|
return &localNoder{
|
|
nodes: nodes,
|
|
}
|
|
}
|
|
|
|
// Nodes implements the Noder interface.
|
|
func (n *localNoder) Nodes() []*Node {
|
|
return n.nodes
|
|
}
|
|
|
|
// PrimaryNodeID implements the Noder interface.
|
|
func (n *localNoder) PrimaryNodeID(hasher Hasher) string {
|
|
snap := NewClusterSnapshot(NewLocalNoder(n.nodes), hasher, "jmp-hash", 1)
|
|
primaryNode := snap.PrimaryFieldTranslationNode()
|
|
if primaryNode == nil {
|
|
return ""
|
|
}
|
|
return primaryNode.ID
|
|
}
|