events

Documentation

Index

• func CheckChaosData(nodeStatus v1alpha13.NodeStatus, ...) (string, *types.ChaosData, error)
• func StrConvTime(time int64) string
• func WorkflowEventWatcher(stopCh chan struct{}, stream chan types.WorkflowEvent)

Functions

func CheckChaosData

func CheckChaosData(nodeStatus v1alpha13.NodeStatus, chaosClient *v1alpha12.LitmuschaosV1alpha1Client) (string, *types.ChaosData, error)

util function, checks if event is a chaos-exp event, if so - extract the chaos data

func StrConvTime

func StrConvTime(time int64) string

converts unix timestamp to string

func WorkflowEventWatcher

func WorkflowEventWatcher(stopCh chan struct{}, stream chan types.WorkflowEvent)

initializes the Argo Workflow event watcher