Method getOpenSearchPerRegion

aws/endpoints.go:612–696

(r string, wg *sync.WaitGroup, semaphore chan struct{}, dataReceiver chan Endpoint)

}

func (m *EndpointsModule) getOpenSearchPerRegion(r string, wg *sync.WaitGroup, semaphore chan struct{}, dataReceiver chan Endpoint) {
	defer func() {
		m.CommandCounter.DecrExecuting()
		m.CommandCounter.IncrComplete()
		wg.Done()

	}()
	semaphore <- struct{}{}
	defer func() {
		<-semaphore
	}()
	// m.CommandCounter.IncrTotal()
	m.CommandCounter.DecrPending()
	m.CommandCounter.IncrExecuting()

	DomainNames, err := sdk.CachedOpenSearchListDomainNames(m.OpenSearchClient, aws.ToString(m.Caller.Account), r)
	if err != nil {
		m.modLog.Error(err.Error())
		m.CommandCounter.IncrError()
		return
	}

	for _, domainName := range DomainNames {
		name := aws.ToString(domainName.DomainName)

		DomainStatus, err := sdk.CachedOpenSearchDescribeDomain(m.OpenSearchClient, aws.ToString(m.Caller.Account), r, name)

		if err != nil {
			if errors.As(err, &oe) {
				m.Errors = append(m.Errors, fmt.Sprintf(" Error: Region: %s, Service: %s, Operation: %s", r, oe.Service(), oe.Operation()))
			}
			m.modLog.Error(err.Error())
			m.CommandCounter.IncrError()
			return
		}

		rawEndpoint := DomainStatus.Endpoint
		var endpoint string
		var kibanaEndpoint string

		// This exits the function if an opensearch domain exists but there is no endpoint
		if rawEndpoint == nil {
			return
		} else {
			endpoint = fmt.Sprintf("https://%s", aws.ToString(rawEndpoint))
			kibanaEndpoint = fmt.Sprintf("https://%s/_plugin/kibana/", aws.ToString(rawEndpoint))
		}

		//fmt.Println(endpoint)

		public := "Unknown"
		domainConfig, err := sdk.CachedOpenSearchDescribeDomainConfig(m.OpenSearchClient, aws.ToString(m.Caller.Account), r, name)
		if err != nil {
			m.modLog.Error(err.Error())
			m.CommandCounter.IncrError()
			return
		}
		if aws.ToBool(domainConfig.AdvancedSecurityOptions.Options.Enabled) {