jobs

Documentation

Index

• Variables
• func NewRecipeCooker(id types.StepID, ingredient types.Ingredient, method string, ...) (types.RecipeCooker, error)
• func RegisterAllMethods(step types.RecipeCooker)
• func RegisterEC(conn *nats.EncodedConn)
• type JobRecord
• type MethodProps
• type MethodPropsSet
  • func PropMapToPropSet(pmap map[string]string) (MethodPropsSet, error)
  • func (m MethodPropsSet) ToMap() map[string]string
• type RecordKeeper

Variables

var (
	ErrUnknownIngredient = errors.New("unknown ingredient")
	ErrUnknownMethod     = errors.New("unknown method")
)

Functions

func NewRecipeCooker

func NewRecipeCooker(id types.StepID, ingredient types.Ingredient, method string, params map[string]interface{}) (types.RecipeCooker, error)

func RegisterAllMethods

func RegisterAllMethods(step types.RecipeCooker)

func RegisterEC

func RegisterEC(conn *nats.EncodedConn)

Types

type JobRecord

type JobRecord struct {
	JID        string
	SproutID   string
	Timestamp  time.Time
	Executor   types.Executor
	Completion types.CompletionStatus
}

type MethodProps

type MethodProps struct {
	Key   string
	Type  string
	IsReq bool
}

type MethodPropsSet

type MethodPropsSet []MethodProps

func PropMapToPropSet

func PropMapToPropSet(pmap map[string]string) (MethodPropsSet, error)

func (MethodPropsSet) ToMap

func (m MethodPropsSet) ToMap() map[string]string

type RecordKeeper

type RecordKeeper interface{}