diff --git a/config/eescfg.go b/config/eescfg.go index 7207dafb7..5858a13ed 100644 --- a/config/eescfg.go +++ b/config/eescfg.go @@ -723,7 +723,8 @@ func (eeOpts *EventExporterOpts) Clone() *EventExporterOpts { *cln.TLS = *eeOpts.TLS } if eeOpts.ConnIDs != nil { - cln.ConnIDs = utils.SliceStringPointer(*eeOpts.ConnIDs) + cln.ConnIDs = new([]string) + *cln.ConnIDs = *eeOpts.ConnIDs } if eeOpts.RPCConnTimeout != nil { cln.RPCConnTimeout = new(time.Duration) diff --git a/config/erscfg.go b/config/erscfg.go index 1939530a7..a34c21111 100644 --- a/config/erscfg.go +++ b/config/erscfg.go @@ -688,19 +688,19 @@ func (erOpts *EventReaderOpts) Clone() *EventReaderOpts { *cln.AWSToken = *erOpts.AWSToken } if erOpts.AWSRegionProcessed != nil { - cln.AWSRegion = new(string) + cln.AWSRegionProcessed = new(string) *cln.AWSRegionProcessed = *erOpts.AWSRegionProcessed } if erOpts.AWSKeyProcessed != nil { - cln.AWSKey = new(string) + cln.AWSKeyProcessed = new(string) *cln.AWSKeyProcessed = *erOpts.AWSKeyProcessed } if erOpts.AWSSecretProcessed != nil { - cln.AWSSecret = new(string) + cln.AWSSecretProcessed = new(string) *cln.AWSSecretProcessed = *erOpts.AWSSecretProcessed } if erOpts.AWSTokenProcessed != nil { - cln.AWSToken = new(string) + cln.AWSTokenProcessed = new(string) *cln.AWSTokenProcessed = *erOpts.AWSTokenProcessed } if erOpts.SQSQueueID != nil { @@ -780,15 +780,15 @@ func (erOpts *EventReaderOpts) Clone() *EventReaderOpts { *cln.NATSSeedFileProcessed = *erOpts.NATSSeedFileProcessed } if erOpts.NATSCertificateAuthorityProcessed != nil { - cln.NATSCertificateAuthority = new(string) + cln.NATSCertificateAuthorityProcessed = new(string) *cln.NATSCertificateAuthorityProcessed = *erOpts.NATSCertificateAuthorityProcessed } if erOpts.NATSClientCertificateProcessed != nil { - cln.NATSClientCertificate = new(string) + cln.NATSClientCertificateProcessed = new(string) *cln.NATSClientCertificateProcessed = *erOpts.NATSClientCertificateProcessed } if erOpts.NATSClientKeyProcessed != nil { - cln.NATSClientKey = new(string) + cln.NATSClientKeyProcessed = new(string) *cln.NATSClientKeyProcessed = *erOpts.NATSClientKeyProcessed } if erOpts.NATSJetStreamMaxWaitProcessed != nil {