istio

Documentation

Index

• Constants
• func GetHealthyIstiodPods(kubeCache cache.KubeCache, revision string, namespace string) ([]*corev1.Pod, error)
• func GetLatestPod(pods []*corev1.Pod) *corev1.Pod
• func GetVersion(ctx context.Context, conf *config.Config, client kubernetes.ClientInterface, ...) (*models.ExternalServiceInfo, error)
• type Discovery
  • func NewDiscovery(kialiSAClients map[string]kubernetes.ClientInterface, cache cache.KialiCache, ...) *Discovery
  • func (in *Discovery) Clusters() ([]models.KubeCluster, error)
  • func (in *Discovery) IsRemoteCluster(ctx context.Context, cluster string) bool
  • func (in *Discovery) Mesh(ctx context.Context) (*models.Mesh, error)

Constants

const (
	// DefaultRevisionLabel is the value for the default revision.
	DefaultRevisionLabel = "default"
	// IstioInjectionLabel is the value for the istio injection label on a namespace.
	IstioInjectionLabel = "istio-injection"
)

Functions

func GetHealthyIstiodPods

func GetHealthyIstiodPods(kubeCache cache.KubeCache, revision string, namespace string) ([]*corev1.Pod, error)

func GetLatestPod

func GetLatestPod(pods []*corev1.Pod) *corev1.Pod

func GetVersion

func GetVersion(ctx context.Context, conf *config.Config, client kubernetes.ClientInterface, kubeCache cache.KubeCache, revision string, namespace string) (*models.ExternalServiceInfo, error)

GetVersion returns the latest version of the Istio control plane. If there are multiple healthy istiod pods, the latest one by creation timestamp is returned.

Types

type Discovery

type Discovery struct {
	// contains filtered or unexported fields
}

Discovery detects istio infrastructure and configuration across clusters.

func NewDiscovery

func NewDiscovery(kialiSAClients map[string]kubernetes.ClientInterface, cache cache.KialiCache, conf *config.Config) *Discovery

NewDiscovery initializes a new Discovery.

func (*Discovery) Clusters

func (in *Discovery) Clusters() ([]models.KubeCluster, error)

Clusters resolves the Kubernetes clusters that are hosting the mesh. Resolution is done as best-effort using the resources that are present in the cluster. TODO: should this go in kubernetes package?

func (*Discovery) IsRemoteCluster

func (in *Discovery) IsRemoteCluster(ctx context.Context, cluster string) bool

IsRemoteCluster determines if the cluster has a controlplane or if it's a remote cluster without one. Clusters that do not exist or are not accessible are considered remote clusters.

func (*Discovery) Mesh

func (in *Discovery) Mesh(ctx context.Context) (*models.Mesh, error)

Mesh gathers information about the mesh and controlplanes running in the mesh from various sources e.g. istio configmap, istiod deployment envvars, etc.