Documentation
¶
Index ¶
- Constants
- type Configuration
- type Source
- func (*Source) CanRun() error
- func (s *Source) Configure(_ context.Context, yamlConfig []byte, logger *log.Entry, ...) error
- func (s *Source) Dump() any
- func (*Source) GetAggregMetrics() []prometheus.Collector
- func (*Source) GetMetrics() []prometheus.Collector
- func (s *Source) GetMode() string
- func (*Source) GetName() string
- func (s *Source) GetUuid() string
- func (s *Source) Stream(ctx context.Context, out chan pipeline.Event) error
- func (s *Source) UnmarshalConfig(yamlConfig []byte) error
Constants ¶
View Source
const ModuleName = "kubernetes"
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Configuration ¶
type Configuration struct {
configuration.DataSourceCommonCfg `yaml:",inline"`
Selector string `yaml:"selector"`
Namespace string `yaml:"namespace"`
KubeConfigFile string `yaml:"kube_config,omitempty"`
KubeContext string `yaml:"kube_context,omitempty"`
}
func ConfigurationFromYAML ¶
func ConfigurationFromYAML(yamlConfig []byte) (Configuration, error)
func (*Configuration) SetDefaults ¶
func (c *Configuration) SetDefaults()
func (*Configuration) Validate ¶
func (c *Configuration) Validate() error
type Source ¶
type Source struct {
// contains filtered or unexported fields
}
func (*Source) GetAggregMetrics ¶
func (*Source) GetAggregMetrics() []prometheus.Collector
func (*Source) GetMetrics ¶
func (*Source) GetMetrics() []prometheus.Collector
func (*Source) UnmarshalConfig ¶
Source Files
Click to show internal directories.
Click to hide internal directories.