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.