Documentation
¶
Index ¶
- func AcquireSchedulerLock(interval, timeout int) bool
- func AddJob(job string)
- func AddNotification(notification string)
- func FetchBatch() (result []string)
- func FetchNotifications() (results []string)
- func FetchResults() (results []string)
- func InitQueue(redisServer string)
- func ReleaseSchedulerLock()
- func WriteResult(result string)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AcquireSchedulerLock ¶
func AddNotification ¶
func AddNotification(notification string)
func FetchBatch ¶
func FetchBatch() (result []string)
func FetchNotifications ¶
func FetchNotifications() (results []string)
func FetchResults ¶
func FetchResults() (results []string)
func ReleaseSchedulerLock ¶
func ReleaseSchedulerLock()
func WriteResult ¶
func WriteResult(result string)
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.