Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NoOpPreProcessor ¶ added in v0.18.4
func NoOpPreProcessor[T utils.ArmadaEvent](msgs []T) ([]T, error)
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
Source Files
Click to show internal directories.
Click to hide internal directories.