marker

Documentation

Index

• func AddTask(rc redis.Conn, taskGroup string, taskID string) error
• func ClearTasks(rc redis.Conn, taskGroup string) error
• func HasTask(rc redis.Conn, taskGroup string, taskID string) (bool, error)
• func RemoveTask(rc redis.Conn, taskGroup string, taskID string) error

Functions

func AddTask

func AddTask(rc redis.Conn, taskGroup string, taskID string) error

AddTask marks the passed in task

func ClearTasks

func ClearTasks(rc redis.Conn, taskGroup string) error

ClearTasks removes all tasks for the passed in group (mostly useful in unit testing)

func HasTask

func HasTask(rc redis.Conn, taskGroup string, taskID string) (bool, error)

HasTask returns whether the passed in taskID has already been marked for execution

func RemoveTask

func RemoveTask(rc redis.Conn, taskGroup string, taskID string) error

RemoveTask removes the task with the passed in id from our lock