signal

Documentation

Overview

Package signal manages signal channel required by sending/receiving request for executing scheduled association

Index

• func ExecuteAssociation(log log.T)
• func InitializeAssociationSignalService(log log.T, task func(log log.T))
• func ResetWaitTimerForNextScheduledAssociation(log log.T, targetDate time.Time)
• func Stop()
• func StopExecutionSignal()
• func StopWaitTimerForNextScheduledAssociation()
• type AssociationExecutionSignal

Functions

func ExecuteAssociation

func ExecuteAssociation(log log.T)

ExecuteAssociation sends out signal to the worker to process next scheduled association

func InitializeAssociationSignalService

func InitializeAssociationSignalService(log log.T, task func(log log.T))

InitializeAssociationSignalService creates goroutine to handle signals

func ResetWaitTimerForNextScheduledAssociation

func ResetWaitTimerForNextScheduledAssociation(log log.T, targetDate time.Time)

ResetWaitTimerForNextScheduledAssociation stops old wait timer and creates new one with updated target date It will wait until the target date then sends the signal for executing next scheduled association

func Stop

func Stop()

Stop close the channel and stop the timers

func StopExecutionSignal

func StopExecutionSignal()

StopExecutionSignal stops the signal channel, which stops the association execution

func StopWaitTimerForNextScheduledAssociation

func StopWaitTimerForNextScheduledAssociation()

StopWaitTimerForNextScheduledAssociation stops the timer so it will not get triggered and send signal for the next scheduled association

Types

type AssociationExecutionSignal

type AssociationExecutionSignal struct {
	// contains filtered or unexported fields
}

AssociationExecutionSignal uses to manage the channel required by sending/receiving signals for executing scheduled association