operator-list-ingress.go

package main

import (
	"fmt"

	"k8s.io/client-go/kubernetes"
	"k8s.io/client-go/rest"
	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
)

func main() {
	client := newClient()

	// Fetch every ingress in any namespace
	ingresses, err := client.Extensions().Ingresses(metav1.NamespaceAll).List(metav1.ListOptions{})
	if err != nil {
		panic(err.Error())
	}

	// Print out the Host for each Ingress' Rule
	for _, ingress := range ingresses.Items {
		for _, rule := range ingress.Spec.Rules {
			fmt.Printf("Ingress found for %s", rule.Host)
		}
	}
}

func newClient() *kubernetes.Clientset {
	var err error
	var config *rest.Config
	config, err = rest.InClusterConfig()
	check(err)
	client, err := kubernetes.NewForConfig(config)
	check(err)
	return client
}