handlers

Documentation

Overview

Package handlers contains functions for converting generic GCP PubSub messages to app-specific messages

Index

• func HandleCreationEvents(additions chan *gcppubsub.Message, instanceToClusterMappings cache.Cache, ...)
• func HandleInterruptionEvents(interruptions chan *gcppubsub.Message, instanceToClusterMappings cache.Cache, ...)

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