translate

Documentation

Index

• func Init()
• func String(str string) (string, error)
• type ComfyWorker
  • func (w ComfyWorker) BlockUntilReady()
  • func (w ComfyWorker) Interrupt()
  • func (w ComfyWorker) Process(payload interface{}) interface{}
  • func (w ComfyWorker) Terminate()

Functions

func Init

func Init()

func String

func String(str string) (string, error)

Types

type ComfyWorker

type ComfyWorker struct {
	// contains filtered or unexported fields
}

func (ComfyWorker) BlockUntilReady

func (w ComfyWorker) BlockUntilReady()

BlockUntilReady is called before each job is processed and must block the calling goroutine until the Worker is ready to process the next job.

func (ComfyWorker) Interrupt

func (w ComfyWorker) Interrupt()

Interrupt is called when a job is cancelled. The worker is responsible for unblocking the Process implementation.

func (ComfyWorker) Process

func (w ComfyWorker) Process(payload interface{}) interface{}

func (ComfyWorker) Terminate

func (w ComfyWorker) Terminate()

Terminate is called when a Worker is removed from the processing pool and is responsible for cleaning up any held resources.