Skip to content
This repository was archived by the owner on May 29, 2024. It is now read-only.

Commit b29558c

Browse files
committed
Change alert manager's 'Transit' method to 'Ingress' and update manager_test
1 parent 41bc9fb commit b29558c

File tree

2 files changed

+6
-7
lines changed

2 files changed

+6
-7
lines changed

internal/alert/manager.go

+3-4
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,7 @@ import (
1717
// Manager ... Interface for alert manager
1818
type Manager interface {
1919
AddSession(core.UUID, *core.AlertPolicy) error
20-
Transit() chan core.Alert
20+
Ingress() chan core.Alert
2121

2222
core.Subsystem
2323
}
@@ -76,9 +76,8 @@ func (am *alertManager) AddSession(id core.UUID, policy *core.AlertPolicy) error
7676
return am.store.AddAlertPolicy(id, policy)
7777
}
7878

79-
// Transit ... Returns inter-subsystem transit channel for receiving alerts
80-
// TODO - Rename this to ingress()
81-
func (am *alertManager) Transit() chan core.Alert {
79+
// Ingress ... Returns inter-subsystem transit channel for receiving alerts
80+
func (am *alertManager) Ingress() chan core.Alert {
8281
return am.alertTransit
8382
}
8483

internal/alert/manager_test.go

+3-3
Original file line numberDiff line numberDiff line change
@@ -53,7 +53,7 @@ func TestEventLoop(t *testing.T) {
5353
_ = am.Shutdown()
5454
}()
5555

56-
ingress := am.Transit()
56+
ingress := am.Ingress()
5757

5858
cm.SetSNSClient(sns)
5959
cm.SetSlackClients([]client.SlackClient{mocks.NewMockSlackClient(c)}, core.LOW)
@@ -117,7 +117,7 @@ func TestEventLoop(t *testing.T) {
117117
_ = am.Shutdown()
118118
}()
119119

120-
ingress := am.Transit()
120+
ingress := am.Ingress()
121121

122122
cm.SetPagerDutyClients([]client.PagerDutyClient{mocks.NewMockPagerDutyClient(c)}, core.MEDIUM)
123123
cm.SetSNSClient(sns)
@@ -181,7 +181,7 @@ func TestEventLoop(t *testing.T) {
181181
_ = am.Shutdown()
182182
}()
183183

184-
ingress := am.Transit()
184+
ingress := am.Ingress()
185185

186186
cm.SetSlackClients([]client.SlackClient{mocks.NewMockSlackClient(c), mocks.NewMockSlackClient(c)}, core.HIGH)
187187
cm.SetPagerDutyClients([]client.PagerDutyClient{mocks.NewMockPagerDutyClient(c), mocks.NewMockPagerDutyClient(c)}, core.HIGH)

0 commit comments

Comments
 (0)