func()

in pkg/discovery/discovery.go [180:199]

• 18 lines of code
• 2 McCabe index (conditional complexity)

func (d *discovery) processService(ctx context.Context, cloudmap *servicediscovery.ServiceDiscovery, ns *servicediscovery.NamespaceSummary, s *servicediscovery.ServiceSummary) *targetgroup.Group {
	tgSourceSpec := targetSourceSpec{
		namespace: aws.StringValue(ns.Name),
		service:   aws.StringValue(s.Name),
	}
	discoveryInput := &servicediscovery.DiscoverInstancesInput{
		NamespaceName: ns.Name,
		ServiceName:   s.Name,
	}
	dio, err := cloudmap.DiscoverInstancesWithContext(ctx, discoveryInput)
	if err != nil {
		level.Error(d.logger).Log("msg", "Error calling DiscoverInstances",
			"service", s.Name, "namespace", ns.Name)

		d.failedSources[tgSourceSpec] = true
		return nil
	}

	return d.processServiceInstances(tgSourceSpec, dio)
}