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

Point writer behaviour.

Link to this section Summary

Callbacks

Writes a point.

Optional list of workers to be supervised by the connection.

Link to this section Callbacks

Link to this callback

write(payload, opts, conn)

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

Writes a point.

Link to this callback

writer_workers(conn)

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

Optional list of workers to be supervised by the connection.