jobrunner

Documentation

Overview

Package taskexecutor defines a "production-ready" task executor.

For local/non-production use, consider looking at cmd/localjobs's task executor

Index

• func CreateTask(ctx context.Context, pool *pgxpool.Pool, task tasks.TaskDefinition) (*types.TaskCreateResponse, error)
• func ExecuteTask(taskId string, task tasks.TaskDefinition)
• type MutLogger
  • func NewTaskLogger(taskId string, pool *pgxpool.Pool, ctx context.Context, baseLogger *zap.Logger) (*zap.Logger, *MutLogger)
  • func (m *MutLogger) Sync() error
  • func (m *MutLogger) Write(p []byte) (n int, err error)
• type TaskState
  • func (TaskState) Context() context.Context
  • func (TaskState) DebugInfo() *debug.BuildInfo
  • func (TaskState) Discord() (*discordgo.Session, *discordgo.User, bool)
  • func (TaskState) OperationMode() string
  • func (TaskState) Transport() *http.Transport

Functions

func CreateTask

func CreateTask(ctx context.Context, pool *pgxpool.Pool, task tasks.TaskDefinition) (*types.TaskCreateResponse, error)

Sets up a task

func ExecuteTask

func ExecuteTask(taskId string, task tasks.TaskDefinition)

Creates a new task on server and executes it

Types

type MutLogger

type MutLogger struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewTaskLogger

func NewTaskLogger(taskId string, pool *pgxpool.Pool, ctx context.Context, baseLogger *zap.Logger) (*zap.Logger, *MutLogger)

func (*MutLogger) Sync

func (m *MutLogger) Sync() error

func (*MutLogger) Write

func (m *MutLogger) Write(p []byte) (n int, err error)

type TaskState

type TaskState struct{}

Implementor of tasks.TaskState

func (TaskState) Context

func (TaskState) Context() context.Context

func (TaskState) DebugInfo

func (TaskState) DebugInfo() *debug.BuildInfo

func (TaskState) Discord

func (TaskState) Discord() (*discordgo.Session, *discordgo.User, bool)

func (TaskState) OperationMode

func (TaskState) OperationMode() string

func (TaskState) Transport

func (TaskState) Transport() *http.Transport