istio

Documentation

Overview

Package isito provides a datagatherer for Istio.

Index

• type Config
  • func (c *Config) NewDataGatherer(ctx context.Context) (datagatherer.DataGatherer, error)
• type DataGatherer
  • func (g *DataGatherer) Delete() error
  • func (g *DataGatherer) Fetch() (interface{}, error)
  • func (g *DataGatherer) Run(stopCh <-chan struct{}) error
  • func (g *DataGatherer) WaitForCacheSync(stopCh <-chan struct{}) error

Types

type Config

type Config struct {
	// KubeConfigPath is the path to the kubeconfig file. If empty, will assume it runs in-cluster.
	KubeConfigPath string `yaml:"kubeconfig"`
	// IstioNamespace is the Namespace for Istio components, this is usually `istio-system`.
	IstioNamespace string `yaml:"istio-namespace"`
	// ExcludeNamespaces is a list of namespaces to exclude.
	ExcludeNamespaces []string `yaml:"exclude-namespaces"`
	// IncludeNamespaces is a list of namespaces to include.
	IncludeNamespaces []string `yaml:"include-namespaces"`
	// Resources is a list of GroupVersionResources to collect for Istio analysis.
	Resources []schema.GroupVersionResource `yaml:"resources"`
}

Config is the configuration for the Istio DataGatherer.

func (*Config) NewDataGatherer

func (c *Config) NewDataGatherer(ctx context.Context) (datagatherer.DataGatherer, error)

NewDataGatherer creates a new DataGatherer for a cluster.

type DataGatherer

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

DataGatherer is a DataGatherer for Istio.

func (*DataGatherer) Delete

func (g *DataGatherer) Delete() error

func (*DataGatherer) Fetch

func (g *DataGatherer) Fetch() (interface{}, error)

Fetch retrieves resources from the K8s API and runs Istio analysis.

func (*DataGatherer) Run

func (g *DataGatherer) Run(stopCh <-chan struct{}) error

Run starts the istio data gatherer's dynamic informers for resource collection. Returns error if the pod and node data gatherers haven't been correctly initialized

func (*DataGatherer) WaitForCacheSync

func (g *DataGatherer) WaitForCacheSync(stopCh <-chan struct{}) error

WaitForCacheSync waits for the data gatherer's informers cache to sync before collecting the resources.