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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ExecuteAssociation ¶
ExecuteAssociation sends out signal to the worker to process next scheduled association
func InitializeAssociationSignalService ¶
InitializeAssociationSignalService creates goroutine to handle signals
func ResetWaitTimerForNextScheduledAssociation ¶
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 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
Source Files