diff options
Diffstat (limited to 'internal/pkg')
-rw-r--r-- | internal/pkg/table/policy.go | 10 | ||||
-rw-r--r-- | internal/pkg/table/policy_test.go | 17 |
2 files changed, 25 insertions, 2 deletions
diff --git a/internal/pkg/table/policy.go b/internal/pkg/table/policy.go index 23c2110c..1f5be006 100644 --- a/internal/pkg/table/policy.go +++ b/internal/pkg/table/policy.go @@ -3566,12 +3566,15 @@ func (r *RoutingPolicy) ReplaceDefinedSet(a DefinedSet) (err error) { return err } -func (r *RoutingPolicy) GetStatement() []*config.Statement { +func (r *RoutingPolicy) GetStatement(name string) []*config.Statement { r.mu.RLock() defer r.mu.RUnlock() l := make([]*config.Statement, 0, len(r.statementMap)) for _, st := range r.statementMap { + if name != "" && name != st.Name { + continue + } l = append(l, st.ToConfig()) } return l @@ -3638,11 +3641,14 @@ func (r *RoutingPolicy) ReplaceStatement(st *Statement) (err error) { return err } -func (r *RoutingPolicy) GetAllPolicy() []*config.PolicyDefinition { +func (r *RoutingPolicy) GetPolicy(name string) []*config.PolicyDefinition { r.mu.RLock() var ps Policies for _, p := range r.policyMap { + if name != "" && name != p.Name { + continue + } ps = append(ps, p) } r.mu.RUnlock() diff --git a/internal/pkg/table/policy_test.go b/internal/pkg/table/policy_test.go index 7f1a1dd9..31889980 100644 --- a/internal/pkg/table/policy_test.go +++ b/internal/pkg/table/policy_test.go @@ -32,6 +32,23 @@ import ( "github.com/stretchr/testify/require" ) +func TestGetStatement(t *testing.T) { + r := NewRoutingPolicy() + r.statementMap["statement1"] = &Statement{Name: "statement1"} + r.statementMap["statement2"] = &Statement{Name: "statement2"} + assert.Equal(t, len(r.GetStatement("")), 2) + assert.Equal(t, len(r.GetStatement("statement1")), 1) + assert.Equal(t, len(r.GetStatement("unknown")), 0) +} + +func TestGetPolicy(t *testing.T) { + r := NewRoutingPolicy() + r.policyMap["p1"] = &Policy{Name: "p1"} + r.policyMap["p2"] = &Policy{Name: "p2"} + assert.Equal(t, len(r.GetPolicy("")), 2) + assert.Equal(t, len(r.GetPolicy("p1")), 1) + assert.Equal(t, len(r.GetPolicy("unknown")), 0) +} func TestPrefixCalcurateNoRange(t *testing.T) { // create path peer := &PeerInfo{AS: 65001, Address: net.ParseIP("10.0.0.1")} |