Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type KeyRetriever ¶
type KeyRetriever[T utils.ArmadaEvent] func(T) string
KeyRetriever retrieves the pulsar message key given the event being published
type PreProcessor ¶
type PreProcessor[T utils.ArmadaEvent] func([]T) ([]T, error)
PreProcessor applies any pre-processing to events before they're published
Click to show internal directories.
Click to hide internal directories.