This commit is contained in:
Ben Johnson 2020-01-02 09:19:35 -07:00
parent a189477ba3
commit bdfdeb1291
2 changed files with 3 additions and 4 deletions

View file

@ -30,7 +30,9 @@ func TestExecutor_TranslateGroupByCall(t *testing.T) {
cluster := newCluster()
cluster.holder = holder
cluster.Node = &Node{ID: "node1", URI: NewTestURIFromHostPort("node1", 0)}
cluster.addNode(cluster.Node)
if err := cluster.addNode(cluster.Node); err != nil {
t.Fatal(err)
}
e := &executor{
Holder: holder,

View file

@ -81,9 +81,6 @@ type Holder struct {
snapshotQueue snapshotQueue
// Manages replication from the primary node.
primaryTranslateNode *Node
// Instantiates new translation stores
OpenTranslateStore OpenTranslateStoreFunc
OpenTranslateReader OpenTranslateReaderFunc