add receivers to allow access to a Status' complete and complete-sink…

… IDs
hashicorp · Oct 27, 2023 · 0aaa4e7 · 0aaa4e7
1 parent 802587e
commit 0aaa4e7
Showing 1 changed file with 10 additions and 0 deletions.
diff --git a/broker.go b/broker.go
@@ -161,6 +161,16 @@ type Status struct {
 	Warnings []error
 }
 
+// Complete returns the IDs of 'filter' and 'sink' type nodes that successfully processed the Event.
+func (s Status) Complete() []NodeID {
+	return s.complete
+}
+
+// CompleteSinks returns the IDs of 'sink' type nodes that successfully processed the Event.
+func (s Status) CompleteSinks() []NodeID {
+	return s.completeSinks
+}
+
 func (s Status) getError(threshold, thresholdSinks int) error {
 	switch {
 	case len(s.complete) < threshold: