gearcmd

Documentation

Index

• type TaskConfig
  • func (conf *TaskConfig) Process(job baseworker.Job) (b []byte, returnErr error)
  • func (conf *TaskConfig) ProcessWithErrorBackoff(job baseworker.Job) (b []byte, returnErr error)

Types

type TaskConfig

type TaskConfig struct {
	FunctionName            string
	FunctionCmd             string
	WarningLines            int
	ParseArgs               bool
	CmdTimeout              time.Duration
	RetryCount              int
	Halt                    chan struct{}
	LastResults             *ring.Ring
	ErrorResultsBackoffRate time.Duration
	SigtermGracePeriod      time.Duration
	// contains filtered or unexported fields
}

TaskConfig defines the configuration for the task. Use constructor for a new struct

func (*TaskConfig) Process

func (conf *TaskConfig) Process(job baseworker.Job) (b []byte, returnErr error)

Process runs the Gearman job by running the configured task. We need to implement the Task interface so we return (byte[], error) though the byte[] is always nil.

func (*TaskConfig) ProcessWithErrorBackoff

func (conf *TaskConfig) ProcessWithErrorBackoff(job baseworker.Job) (b []byte, returnErr error)

ProcessWithErrorBackoff calls Process and sleeps if the last N jobs returned an error