@@ -520,6 +520,30 @@ func TestAddMonitoringTls(t *testing.T) {
520520 "sslTrustedServerCertificates" : util .CAFilePathInContainer ,
521521 }
522522
523+ expectedMonitoringVersions := []interface {}{
524+ map [string ]interface {}{"hostname" : "my-rs-0.some.host" , "name" : MonitoringAgentDefaultVersion , "additionalParams" : expectedAdditionalParams },
525+ map [string ]interface {}{"hostname" : "my-rs-1.some.host" , "name" : MonitoringAgentDefaultVersion , "additionalParams" : expectedAdditionalParams },
526+ map [string ]interface {}{"hostname" : "my-rs-2.some.host" , "name" : MonitoringAgentDefaultVersion , "additionalParams" : expectedAdditionalParams },
527+ }
528+ assert .Equal (t , expectedMonitoringVersions , d .getMonitoringVersions ())
529+
530+ // adding again - nothing changes
531+ d .AddMonitoring (zap .S (), true , util .CAFilePathInContainer )
532+ assert .Equal (t , expectedMonitoringVersions , d .getMonitoringVersions ())
533+ }
534+
535+ func TestAddMonitoringTLSDisable (t * testing.T ) {
536+ d := NewDeployment ()
537+
538+ rs0 := buildRsByProcesses ("my-rs" , createReplicaSetProcessesCount (3 , "my-rs" ))
539+ d .MergeReplicaSet (rs0 , nil , nil , zap .S ())
540+ d .AddMonitoring (zap .S (), true , util .CAFilePathInContainer )
541+
542+ // verify TLS is present in additionalParams
543+ expectedAdditionalParams := map [string ]string {
544+ "useSslForAllConnections" : "true" ,
545+ "sslTrustedServerCertificates" : util .CAFilePathInContainer ,
546+ }
523547 expectedMonitoringVersionsWithTls := []interface {}{
524548 map [string ]interface {}{"hostname" : "my-rs-0.some.host" , "name" : MonitoringAgentDefaultVersion , "additionalParams" : expectedAdditionalParams },
525549 map [string ]interface {}{"hostname" : "my-rs-1.some.host" , "name" : MonitoringAgentDefaultVersion , "additionalParams" : expectedAdditionalParams },
0 commit comments