utils

Documentation

Index

• Constants
• func BasicMeshInfo(mainPod *kubernetes.Pod, discoverySelector map[string]string, meshType string) *v1.Mesh
• func GetActiveInstalls(installs v1.InstallList, filterFunc InstallFilterFunc) v1.InstallList
• func GetMeshes(meshes v1.MeshList, filterFunc MeshFilterFunc) v1.MeshList
• func GetUpstreamsForInjectedPods(pods kubernetes.PodList, upstreams gloov1.UpstreamList) gloov1.UpstreamList
• func GetVersionFromPodWithMatchers(pod *kubernetes.Pod, podStringMatchers []string) (string, error)
• func ImageVersion(image string) (string, error)
• func InjectedPodsByNamespace(pods kubernetes.PodList, proxyContainerName string) kubernetes.PodsByNamespace
• func MeshWriteNamespace() string
• func SelectRunningPods(pods kubernetes.PodList) kubernetes.PodList
• type InstallFilterFunc
• type MeshFilterFunc

Constants

const (
	SelectorDiscoveredByPrefix = "discovered_by"
	SelectorCreatedByPrefix    = "created_by"
	SelectorCreatedByValue     = "mesh-discovery"
)

Functions

func BasicMeshInfo

func BasicMeshInfo(mainPod *kubernetes.Pod, discoverySelector map[string]string, meshType string) *v1.Mesh

func GetActiveInstalls

func GetActiveInstalls(installs v1.InstallList, filterFunc InstallFilterFunc) v1.InstallList

func GetMeshes

func GetMeshes(meshes v1.MeshList, filterFunc MeshFilterFunc) v1.MeshList

func GetUpstreamsForInjectedPods

func GetUpstreamsForInjectedPods(pods kubernetes.PodList, upstreams gloov1.UpstreamList) gloov1.UpstreamList

func GetVersionFromPodWithMatchers

func GetVersionFromPodWithMatchers(pod *kubernetes.Pod, podStringMatchers []string) (string, error)

func ImageVersion

func ImageVersion(image string) (string, error)

func InjectedPodsByNamespace

func InjectedPodsByNamespace(pods kubernetes.PodList, proxyContainerName string) kubernetes.PodsByNamespace

func MeshWriteNamespace

func MeshWriteNamespace() string

func SelectRunningPods

func SelectRunningPods(pods kubernetes.PodList) kubernetes.PodList

Types

type InstallFilterFunc

type InstallFilterFunc func(install *v1.Install) bool

var IstioInstallFilterFunc InstallFilterFunc = func(install *v1.Install) bool {
	meshInstall := install.GetMesh()
	if meshInstall == nil {
		return false
	}
	if istioMeshInstall := meshInstall.GetIstio(); istioMeshInstall != nil {
		return true
	}
	return false
}

var LinkerdInstallFilterFunc InstallFilterFunc = func(install *v1.Install) bool {
	meshInstall := install.GetMesh()
	if meshInstall == nil {
		return false
	}
	if linkerdMeshInstall := meshInstall.GetLinkerd(); linkerdMeshInstall != nil {
		return true
	}
	return false
}

type MeshFilterFunc

type MeshFilterFunc func(mesh *v1.Mesh) bool

var IstioMeshFilterFunc MeshFilterFunc = func(mesh *v1.Mesh) bool {
	if istioMesh := mesh.GetIstio(); istioMesh != nil {
		return true
	}
	return false
}

var LinkerdMeshFilterFunc MeshFilterFunc = func(mesh *v1.Mesh) bool {
	if linkerdMesh := mesh.GetLinkerd(); linkerdMesh != nil {
		return true
	}
	return false
}