Documentation
¶
Overview ¶
Package isito provides a datagatherer for Istio.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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.
Click to show internal directories.
Click to hide internal directories.