Documentation
¶
Index ¶
- type Source
- func (*Source) CanRun() error
- func (*Source) Configure(_ context.Context, _ []byte, _ *log.Entry, _ metrics.AcquisitionMetricsLevel) error
- func (*Source) ConfigureByDSN(_ context.Context, _ string, _ map[string]string, _ *log.Entry, _ string) error
- func (w *Source) Dump() any
- func (*Source) GetAggregMetrics() []prometheus.Collector
- func (*Source) GetMetrics() []prometheus.Collector
- func (*Source) GetMode() string
- func (*Source) GetName() string
- func (*Source) GetUuid() string
- func (*Source) OneShotAcquisition(_ context.Context, _ chan pipeline.Event, _ *tomb.Tomb) error
- func (*Source) StreamingAcquisition(_ context.Context, _ chan pipeline.Event, _ *tomb.Tomb) error
- func (*Source) SupportedModes() []string
- func (*Source) UnmarshalConfig(_ []byte) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Source ¶ added in v1.7.4
type Source struct{}
func (*Source) ConfigureByDSN ¶ added in v1.7.4
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) OneShotAcquisition ¶ added in v1.7.4
func (*Source) StreamingAcquisition ¶ added in v1.7.4
func (*Source) SupportedModes ¶ added in v1.7.4
func (*Source) UnmarshalConfig ¶ added in v1.7.4
Click to show internal directories.
Click to hide internal directories.