Versions in this module Expand all Collapse all v0 v0.2.0 Feb 15, 2023 v0.1.1 Feb 15, 2023 v0.1.0 Feb 15, 2023 Changes in this version + func Sink(p pipe.Pipeline, input <-chan *write.Point, config flags.InfluxDb2Config) + func Transform(p pipe.Pipeline, input <-chan *ftl.QueryRecord) <-chan *write.Point