INNER CODE UNIT · Go

IsElasticsearchOperatorAvailable

jaegertracing/jaeger-operator · pkg/autodetect/main.go:452

func IsElasticsearchOperatorAvailable(apiList []*metav1.APIResourceList) bool {
	for _, r := range apiList {
		if strings.HasPrefix(r.GroupVersion, "logging.openshift.io") {
			for _, api := range r.APIResources {
				if api.Kind == "Elasticsearch" {
					return true
				}
			}
		}
	}
	return false
}

func isKafkaOperatorAvailable(apiList []*metav1.APIResourceList) bool {
	for _, r := range apiList {
		if strings.HasPrefix(r.GroupVersion, "kafka.strimzi.io") {
			return true
		}

View source record →