istiodata

Documentation

Index

• func GetRevisionTagInfo(ctx context.Context, kubeClient *kubernetes.Clientset) ([]tags.TagDescription, error)
• type IstioData
  • func (r *IstioData) CheckProxiedPods(ctx context.Context, kubeClient *kubernetes.Clientset) ([]corev1.Pod, error)
  • func (id *IstioData) PrintProxyStatusData(ctx context.Context)
  • func (id *IstioData) PrintRevisionTagInfo(ctx context.Context)
  • func (id *IstioData) RefreshIstioData(ctx context.Context, kubeClient *kubernetes.Clientset) error
• type IstioProxyStatusData
  • func GetProxyStatusData(ctx context.Context, kubeClient *kubernetes.Clientset) ([]IstioProxyStatusData, error)

Functions

func GetRevisionTagInfo

func GetRevisionTagInfo(ctx context.Context, kubeClient *kubernetes.Clientset) ([]tags.TagDescription, error)

Types

type IstioData

type IstioData struct {
	ProxyStatuses        []IstioProxyStatusData
	TagInfo              map[string]tags.TagDescription // key is tag name
	LastUpdate           time.Time
	RevisionsByNamespace map[string]string
	// contains filtered or unexported fields
}

func (*IstioData) CheckProxiedPods

func (r *IstioData) CheckProxiedPods(ctx context.Context, kubeClient *kubernetes.Clientset) ([]corev1.Pod, error)

TODO: allow passing namespace to limit search to one namespace? Would be useful to call from namespace controller

func (*IstioData) PrintProxyStatusData

func (id *IstioData) PrintProxyStatusData(ctx context.Context)

func (*IstioData) PrintRevisionTagInfo

func (id *IstioData) PrintRevisionTagInfo(ctx context.Context)

func (*IstioData) RefreshIstioData

func (id *IstioData) RefreshIstioData(ctx context.Context, kubeClient *kubernetes.Clientset) error

type IstioProxyStatusData

type IstioProxyStatusData struct {
	ClusterID           string
	IstiodPodName       string
	IstiodPodNamespace  string
	IstiodRevision      string
	IstiodVersion       string
	ProxiedPodId        string
	ProxiedPodName      string
	ProxiedPodNamespace string
}

func GetProxyStatusData

func GetProxyStatusData(ctx context.Context, kubeClient *kubernetes.Clientset) ([]IstioProxyStatusData, error)

this should be called from the controllers - it will fetch and process the istio data