PacketFlow.Stream.Transform behaviour (packetflow v0.1.0)

Summary

Callbacks

transform(event, context, state)

transform_batch(events, context, state)

Callbacks

transform(event, context, state)

@callback transform(event :: any(), context :: any(), state :: any()) ::
  {:ok, transformed_event :: any(), new_state :: any()}

transform_batch(events, context, state)

@callback transform_batch(events :: [any()], context :: any(), state :: any()) ::
  {:ok, transformed_events :: [any()], new_state :: any()}