View Source Instream.Writer behaviour (Instream v2.2.1)

Point writer behaviour.

Link to this section Summary

Writes a point.

writer_workers(conn)

Optional list of workers to be supervised by the connection.

@callback write(
  payload :: [Instream.Encoder.Line.point()],
  opts :: Keyword.t(),
  conn :: module()
) ::
  Instream.HTTPClient.response()

Writes a point.

(optional)

@callback writer_workers(conn :: module()) :: [
  :supervisor.child_spec() | {module(), term()} | module()
]

Optional list of workers to be supervised by the connection.