Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Downsampler ¶
type Downsampler struct {
// contains filtered or unexported fields
}
Downsampler consumes lines from one or more NATS subjects, and applies downsampling to the InfluxDB measurements received from them.
func StartDownsampler ¶
func StartDownsampler(c *config.Config) (_ *Downsampler, err error)
StartDownsampler creates and configures a Downsampler.
func (*Downsampler) Stop ¶
func (ds *Downsampler) Stop()
Stop aborts all goroutines belonging to the Downsampler and closes its connection to NATS. It will be block until all Downsampler goroutines have stopped.
Source Files
Click to show internal directories.
Click to hide internal directories.