package ingest
import "testing"
// Each node folds the full stream, so two nodes on one store need two
// durable consumers; a shared name would load-balance one copy.
func TestPipelinesOnTwoNodesHaveDistinctDurables(t *testing.T) {
a := NewPipeline(nil, nil, nil, "repo1", "0123456789ab").durable()
b := NewPipeline(nil, nil, nil, "repo1", "ba9876543210").durable()
if a == b {
t.Fatalf("FAIL: two nodes share durable %q", a)
}
if a == NewPipeline(nil, nil, nil, "repo1", "").durable() {
t.Fatalf("FAIL: a named node uses the single-node durable %q", a)
}
}