Documentation
¶
Index ¶
- type Configuration
- type Source
- func (*Source) CanRun() error
- func (s *Source) Configure(_ context.Context, config []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) StreamingAcquisition(ctx context.Context, out chan pipeline.Event, t *tomb.Tomb) error
- func (s *Source) UnmarshalConfig(yamlConfig []byte) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Configuration ¶ added in v1.7.4
type Configuration struct {
ListenAddr string `yaml:"listen_addr"`
ListenPort int `yaml:"listen_port"`
WebhookPath string `yaml:"webhook_path"`
configuration.DataSourceCommonCfg `yaml:",inline"`
}
type Source ¶ added in v1.7.4
type Source struct {
// contains filtered or unexported fields
}
func (*Source) GetAggregMetrics ¶ added in v1.7.4
func (*Source) GetAggregMetrics() []prometheus.Collector
func (*Source) GetMetrics ¶ added in v1.7.4
func (*Source) GetMetrics() []prometheus.Collector
func (*Source) StreamingAcquisition ¶ added in v1.7.4
func (*Source) UnmarshalConfig ¶ added in v1.7.4
Source Files
Click to show internal directories.
Click to hide internal directories.