tasks

Documentation

Index

• func Routes(r *gin.Engine) *gin.RouterGroup
• func TasksWebsocketEndpoint(c *gin.Context)
• type Task
  • func New(f func(*Task)) *Task
  • func (t *Task) Delay()
  • func (t *Task) Process()
  • func (t *Task) UpdateProgress(progress int)

Functions

func Routes

func Routes(r *gin.Engine) *gin.RouterGroup

func TasksWebsocketEndpoint

func TasksWebsocketEndpoint(c *gin.Context)

Types

type Task

type Task struct {
	ID            uuid.UUID
	Name          string
	Progress      int `json:"-"`
	STAN          stan.Conn
	NATS          *nats.Conn
	TaskFunction  func(*Task) `json:"-"`
	TrackProgress bool        `json:"-"`
	// contains filtered or unexported fields
}

Instance of an executing task on a worker

func New

func New(f func(*Task)) *Task

func New(c stan.Conn, t *Task) string {

func (*Task) Delay

func (t *Task) Delay()

Put this task in a queue Assigns an ID for a queued task

func (*Task) Process

func (t *Task) Process()

func (*Task) UpdateProgress

func (t *Task) UpdateProgress(progress int)