Documentation
¶
Overview ¶
Package handlers contains functions for converting generic GCP PubSub messages to app-specific messages
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func HandleCreationEvents ¶
func HandleCreationEvents(additions chan *gcppubsub.Message, instanceToClusterMappings cache.Cache, l *zap.SugaredLogger, wg *sync.WaitGroup)
HandleCreationEvents reads from additions and adds the instance ID and corresponding cluster to m
func HandleInterruptionEvents ¶
func HandleInterruptionEvents(interruptions chan *gcppubsub.Message, instanceToClusterMappings cache.Cache, metrics metrics.Client, l *zap.SugaredLogger, wg *sync.WaitGroup)
HandleInterruptionEvents reads from interruptions and increases the interruption event counter of metrics accordingly
Types ¶
This section is empty.
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.