task

Documentation

Index

• Constants
• func NoOpHandlerFunc(context.Context, EventType, *tork.Task) error
• type EventType
• type HandlerFunc
  • func ApplyMiddleware(h HandlerFunc, mws []MiddlewareFunc) HandlerFunc
• type HostEnv
  • func NewHostEnv(vars ...string) (*HostEnv, error)
  • func (m *HostEnv) Execute(next HandlerFunc) HandlerFunc
• type MiddlewareFunc
  • func Redact(redacter *redact.Redacter) MiddlewareFunc
  • func Webhook(ds datastore.Datastore) MiddlewareFunc

Constants

const (
	// Started event occurs when the Worker notifies
	// the Coordinator that the task began processing.
	Started = "STARTED"
	// StateChange occurs when a task's state changes.
	// Handler can inspect the job's State property
	// in order to determine what state the task is at.
	StateChange = "STATE_CHANGE"
	// Read occurs when a Task is read by the client
	// through the API.
	Read = "READ"
)

Functions

func NoOpHandlerFunc

func NoOpHandlerFunc(context.Context, EventType, *tork.Task) error

Types

type EventType

type EventType string

type HandlerFunc

type HandlerFunc func(context.Context, EventType, *tork.Task) error

func ApplyMiddleware

func ApplyMiddleware(h HandlerFunc, mws []MiddlewareFunc) HandlerFunc

type HostEnv

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

func NewHostEnv

func NewHostEnv(vars ...string) (*HostEnv, error)

func (*HostEnv) Execute

func (m *HostEnv) Execute(next HandlerFunc) HandlerFunc

type MiddlewareFunc

type MiddlewareFunc func(next HandlerFunc) HandlerFunc

func Redact

func Redact(redacter *redact.Redacter) MiddlewareFunc

func Webhook

func Webhook(ds datastore.Datastore) MiddlewareFunc