tasks

Documentation

Index

• Constants
• func CreateArchivalTask(c context.Context, id coordinator.HashID, tag logdog.ArchiveDispatchTask_Tag, ...) error
• func DeleteArchiveStreamExpiredTask(c context.Context, id coordinator.HashID) error
• func InstallHandlers(r *router.Router, base router.MiddlewareChain)

Constants

const (
	// ArchivalTaskQueue is the name of the archival task queue.
	ArchivalTaskQueue = "archival"
)

Functions

func CreateArchivalTask

func CreateArchivalTask(c context.Context, id coordinator.HashID, tag logdog.ArchiveDispatchTask_Tag,
	delay time.Duration, params *coordinator.ArchivalParams) error

CreateArchivalTask adds a task to the task queue to initiate archival on an stream. The task will be delayed by "delay".

func DeleteArchiveStreamExpiredTask

func DeleteArchiveStreamExpiredTask(c context.Context, id coordinator.HashID) error

DeleteArchiveStreamExpiredTask deletes stream EXPIRED task associated with id. If the task has already been deleted, this will do nothing.

func InstallHandlers

func InstallHandlers(r *router.Router, base router.MiddlewareChain)

InstallHandlers registers task processing handlers into the supplied router.