pending_tasks

Documentation

Index

• func AddHandlers(externalRouter chi.Router)
• func DecodeTask(taskJson io.Reader) (task_common.Task, error)
• func EncodeTask(taskJson io.Writer, oldestTask task_common.Task) error
• func GetGCEPendingTaskCount(ctx context.Context) (int, error)
• func GetOldestPendingTask(ctx context.Context) (task_common.Task, error)
• func GetPendingTaskCount(ctx context.Context) (int64, error)
• func ReloadTemplates(resourcesDir string)
• type CompletedTask
• type CompletedTaskResponse

Functions

func AddHandlers

func AddHandlers(externalRouter chi.Router)

func DecodeTask

func DecodeTask(taskJson io.Reader) (task_common.Task, error)

Reads JSON response from ctfeutil.GET_OLDEST_PENDING_TASK_URI and returns either the Task decoded from the response or nil if there are no pending tasks. Returns an error if there is a problem decoding the JSON. Does not close taskJson.

func EncodeTask

func EncodeTask(taskJson io.Writer, oldestTask task_common.Task) error

Writes JSON representation of oldestTask to taskJson. Returns an error if oldestTask's type is unknown, if there was an error encoding to JSON, or there is an error writing to taskJson. Does not close taskJson.

func GetGCEPendingTaskCount

func GetGCEPendingTaskCount(ctx context.Context) (int, error)

GetGCEPendingTaskCount returns count of pending GCE CT tasks from all task types.

func GetOldestPendingTask

func GetOldestPendingTask(ctx context.Context) (task_common.Task, error)

GetOldestPendingTask returns the oldest pending task of any type.

func GetPendingTaskCount

func GetPendingTaskCount(ctx context.Context) (int64, error)

GetPendingTaskCount returns the total number of pending tasks of all types. On error, the first return value will be -1 and the second return value will be non-nil.

func ReloadTemplates

func ReloadTemplates(resourcesDir string)

Types

type CompletedTask

type CompletedTask struct {
	Type        string `json:"type"`
	Username    string `json:"username"`
	Description string `json:"description"`
	TsCompleted int64  `json:"ts_completed"`
}

type CompletedTaskResponse

type CompletedTaskResponse struct {
	UniqueUsers    int             `json:"unique_users"`
	CompletedTasks []CompletedTask `json:"completed_tasks"`
}