@@ -1465,15 +1465,16 @@ var _ = Describe("ChangeProcessor", func() {
1465
1465
// -- this is done in 'Normal cases of processing changes'
1466
1466
1467
1467
var (
1468
- processor * state.ChangeProcessorImpl
1469
- gcNsName , gwNsName , hrNsName , hr2NsName , rgNsName , svcNsName , sliceNsName types.NamespacedName
1470
- gc , gcUpdated * v1.GatewayClass
1471
- gw1 , gw1Updated , gw2 * v1.Gateway
1472
- hr1 , hr1Updated , hr2 * v1.HTTPRoute
1473
- rg1 , rg1Updated , rg2 * v1beta1.ReferenceGrant
1474
- svc , barSvc , unrelatedSvc * apiv1.Service
1475
- slice , barSlice , unrelatedSlice * discoveryV1.EndpointSlice
1476
- ns , unrelatedNS , testNs , barNs * apiv1.Namespace
1468
+ processor * state.ChangeProcessorImpl
1469
+ gcNsName , gwNsName , hrNsName , hr2NsName , rgNsName , svcNsName , sliceNsName , secretNsName types.NamespacedName
1470
+ gc , gcUpdated * v1.GatewayClass
1471
+ gw1 , gw1Updated , gw2 * v1.Gateway
1472
+ hr1 , hr1Updated , hr2 * v1.HTTPRoute
1473
+ rg1 , rg1Updated , rg2 * v1beta1.ReferenceGrant
1474
+ svc , barSvc , unrelatedSvc * apiv1.Service
1475
+ slice , barSlice , unrelatedSlice * discoveryV1.EndpointSlice
1476
+ ns , unrelatedNS , testNs , barNs * apiv1.Namespace
1477
+ secret , secretUpdated , unrelatedSecret , barSecret , barSecretUpdated * apiv1.Secret
1477
1478
)
1478
1479
1479
1480
BeforeEach (OncePerOrdered , func () {
@@ -1484,6 +1485,48 @@ var _ = Describe("ChangeProcessor", func() {
1484
1485
Scheme : createScheme (),
1485
1486
})
1486
1487
1488
+ secretNsName = types.NamespacedName {Namespace : "test" , Name : "tls-secret" }
1489
+ secret = & apiv1.Secret {
1490
+ ObjectMeta : metav1.ObjectMeta {
1491
+ Name : secretNsName .Name ,
1492
+ Namespace : secretNsName .Namespace ,
1493
+ Generation : 1 ,
1494
+ },
1495
+ Type : apiv1 .SecretTypeTLS ,
1496
+ Data : map [string ][]byte {
1497
+ apiv1 .TLSCertKey : cert ,
1498
+ apiv1 .TLSPrivateKeyKey : key ,
1499
+ },
1500
+ }
1501
+ secretUpdated = secret .DeepCopy ()
1502
+ secretUpdated .Generation ++
1503
+ barSecret = & apiv1.Secret {
1504
+ ObjectMeta : metav1.ObjectMeta {
1505
+ Name : "bar-secret" ,
1506
+ Namespace : "test" ,
1507
+ Generation : 1 ,
1508
+ },
1509
+ Type : apiv1 .SecretTypeTLS ,
1510
+ Data : map [string ][]byte {
1511
+ apiv1 .TLSCertKey : cert ,
1512
+ apiv1 .TLSPrivateKeyKey : key ,
1513
+ },
1514
+ }
1515
+ barSecretUpdated = barSecret .DeepCopy ()
1516
+ barSecretUpdated .Generation ++
1517
+ unrelatedSecret = & apiv1.Secret {
1518
+ ObjectMeta : metav1.ObjectMeta {
1519
+ Name : "unrelated-tls-secret" ,
1520
+ Namespace : "unrelated-ns" ,
1521
+ Generation : 1 ,
1522
+ },
1523
+ Type : apiv1 .SecretTypeTLS ,
1524
+ Data : map [string ][]byte {
1525
+ apiv1 .TLSCertKey : cert ,
1526
+ apiv1 .TLSPrivateKeyKey : key ,
1527
+ },
1528
+ }
1529
+
1487
1530
gcNsName = types.NamespacedName {Name : "test-class" }
1488
1531
1489
1532
gc = & v1.GatewayClass {
@@ -1525,6 +1568,38 @@ var _ = Describe("ChangeProcessor", func() {
1525
1568
},
1526
1569
},
1527
1570
},
1571
+ {
1572
+ Name : "listener-443-1" ,
1573
+ Hostname : nil ,
1574
+ Port : 443 ,
1575
+ Protocol : v1 .HTTPSProtocolType ,
1576
+ TLS : & v1.GatewayTLSConfig {
1577
+ Mode : helpers .GetPointer (v1 .TLSModeTerminate ),
1578
+ CertificateRefs : []v1.SecretObjectReference {
1579
+ {
1580
+ Kind : (* v1 .Kind )(helpers .GetPointer ("Secret" )),
1581
+ Name : v1 .ObjectName (secret .Name ),
1582
+ Namespace : (* v1 .Namespace )(& secret .Namespace ),
1583
+ },
1584
+ },
1585
+ },
1586
+ },
1587
+ {
1588
+ Name : "listener-500-1" ,
1589
+ Hostname : nil ,
1590
+ Port : 500 ,
1591
+ Protocol : v1 .HTTPSProtocolType ,
1592
+ TLS : & v1.GatewayTLSConfig {
1593
+ Mode : helpers .GetPointer (v1 .TLSModeTerminate ),
1594
+ CertificateRefs : []v1.SecretObjectReference {
1595
+ {
1596
+ Kind : (* v1 .Kind )(helpers .GetPointer ("Secret" )),
1597
+ Name : v1 .ObjectName (barSecret .Name ),
1598
+ Namespace : (* v1 .Namespace )(& barSecret .Namespace ),
1599
+ },
1600
+ },
1601
+ },
1602
+ },
1528
1603
},
1529
1604
},
1530
1605
}
@@ -1731,6 +1806,8 @@ var _ = Describe("ChangeProcessor", func() {
1731
1806
processor .CaptureUpsertChange (gw1 )
1732
1807
processor .CaptureUpsertChange (testNs )
1733
1808
processor .CaptureUpsertChange (hr1 )
1809
+ processor .CaptureUpsertChange (secret )
1810
+ processor .CaptureUpsertChange (barSecret )
1734
1811
changed , _ := processor .Process ()
1735
1812
Expect (changed ).To (BeTrue ())
1736
1813
})
@@ -1739,13 +1816,15 @@ var _ = Describe("ChangeProcessor", func() {
1739
1816
processor .CaptureUpsertChange (svc )
1740
1817
processor .CaptureUpsertChange (slice )
1741
1818
processor .CaptureUpsertChange (ns )
1819
+ processor .CaptureUpsertChange (secretUpdated )
1742
1820
changed , _ := processor .Process ()
1743
1821
Expect (changed ).To (BeTrue ())
1744
1822
})
1745
1823
It ("should report not changed after multiple Upserts of unrelated resources" , func () {
1746
1824
processor .CaptureUpsertChange (unrelatedSvc )
1747
1825
processor .CaptureUpsertChange (unrelatedSlice )
1748
1826
processor .CaptureUpsertChange (unrelatedNS )
1827
+ processor .CaptureUpsertChange (unrelatedSecret )
1749
1828
1750
1829
changed , _ := processor .Process ()
1751
1830
Expect (changed ).To (BeFalse ())
@@ -1756,11 +1835,13 @@ var _ = Describe("ChangeProcessor", func() {
1756
1835
processor .CaptureUpsertChange (barSvc )
1757
1836
processor .CaptureUpsertChange (barSlice )
1758
1837
processor .CaptureUpsertChange (barNs )
1838
+ processor .CaptureUpsertChange (barSecretUpdated )
1759
1839
1760
1840
// there are non-changing changes
1761
1841
processor .CaptureUpsertChange (unrelatedSvc )
1762
1842
processor .CaptureUpsertChange (unrelatedSlice )
1763
1843
processor .CaptureUpsertChange (unrelatedNS )
1844
+ processor .CaptureUpsertChange (unrelatedSecret )
1764
1845
1765
1846
changed , _ := processor .Process ()
1766
1847
Expect (changed ).To (BeTrue ())
@@ -1772,11 +1853,13 @@ var _ = Describe("ChangeProcessor", func() {
1772
1853
processor .CaptureDeleteChange (& apiv1.Service {}, svcNsName )
1773
1854
processor .CaptureDeleteChange (& discoveryV1.EndpointSlice {}, sliceNsName )
1774
1855
processor .CaptureDeleteChange (& apiv1.Namespace {}, types.NamespacedName {Name : "ns" })
1856
+ processor .CaptureDeleteChange (& apiv1.Secret {}, secretNsName )
1775
1857
1776
1858
// these are non-changing changes
1777
1859
processor .CaptureUpsertChange (unrelatedSvc )
1778
1860
processor .CaptureUpsertChange (unrelatedSlice )
1779
1861
processor .CaptureUpsertChange (unrelatedNS )
1862
+ processor .CaptureUpsertChange (unrelatedSecret )
1780
1863
1781
1864
changed , _ := processor .Process ()
1782
1865
Expect (changed ).To (BeTrue ())
@@ -1796,6 +1879,7 @@ var _ = Describe("ChangeProcessor", func() {
1796
1879
processor .CaptureUpsertChange (svc )
1797
1880
processor .CaptureUpsertChange (slice )
1798
1881
processor .CaptureUpsertChange (ns )
1882
+ processor .CaptureUpsertChange (secret )
1799
1883
1800
1884
changed , _ := processor .Process ()
1801
1885
Expect (changed ).To (BeTrue ())
@@ -1805,6 +1889,7 @@ var _ = Describe("ChangeProcessor", func() {
1805
1889
processor .CaptureUpsertChange (unrelatedSvc )
1806
1890
processor .CaptureUpsertChange (unrelatedSlice )
1807
1891
processor .CaptureUpsertChange (unrelatedNS )
1892
+ processor .CaptureUpsertChange (unrelatedSecret )
1808
1893
1809
1894
changed , _ := processor .Process ()
1810
1895
Expect (changed ).To (BeFalse ())
@@ -1821,6 +1906,7 @@ var _ = Describe("ChangeProcessor", func() {
1821
1906
processor .CaptureUpsertChange (unrelatedSvc )
1822
1907
processor .CaptureUpsertChange (unrelatedSlice )
1823
1908
processor .CaptureUpsertChange (unrelatedNS )
1909
+ processor .CaptureUpsertChange (unrelatedSecret )
1824
1910
1825
1911
changed , _ := processor .Process ()
1826
1912
Expect (changed ).To (BeTrue ())
0 commit comments