internal

Documentation

Index

• Constants
• func AtomicDec(addr *uint64)
• func AtomicInc(addr *uint64)
• func AtomicMapEdit[T comparable, U any](key T, value U, map_ map[T]U)
• func HTMLForZucchiniMonitor(taskName string, monitorAddr string) string
• func UnmarshalOrPanic[T any](data []byte) T
• type Task
• type TaskCommand
• type TaskPayload
• type TaskStatus

Constants

const ZUCCHINI_CMD_PREFIX = "zhc:cmd:"

const ZUCCHINI_RES_PREFIX = "zhc:res:"

const ZUCCHINI_TASK_PREFIX = "zhc:task:"

Functions

func AtomicDec

func AtomicDec(addr *uint64)

func AtomicInc

func AtomicInc(addr *uint64)

func AtomicMapEdit

func AtomicMapEdit[T comparable, U any](key T, value U, map_ map[T]U)

func HTMLForZucchiniMonitor

func HTMLForZucchiniMonitor(taskName string, monitorAddr string) string

func UnmarshalOrPanic

func UnmarshalOrPanic[T any](data []byte) T

Types

type Task

type Task[T any] struct {
	Payload TaskPayload[T]
	Status  TaskStatus
	Retries uint
}

type TaskCommand

type TaskCommand struct {
	TaskId  uuid.UUID
	Command string
}

type TaskPayload

type TaskPayload[T any] struct {
	ID       uuid.UUID
	Timeout  time.Duration
	Argument T
}

type TaskStatus

type TaskStatus uint8

const (
	Queued TaskStatus = iota
	Processing
	Failed
	Succeeded
	Cancelled
)