taskmetadata

README

Get metadata Example

This is a "hello-world" with a Metadata example of LittleHorse using GoLang.

What's Going On

The file workflow.go has two functions defined:

• GetInfo, which is a Task Function (task accepts a struct as an input variable; only pointers to struct are supported).
• MyWorkflowGet, which is the Workflow Function.

Deploy the Task Worker

Before we can create the WfSpec, we need to register the TaskDef. The easiest way to do that is to run the task worker:

go run ./taskmetadata/worker

Leave that process running.

Register the WfSpec

Next, in another terminal, run:

go run ./taskmetadata/deploy

That will create the WfSpec. You can verify that via:

lhctl get wfSpec my-workflow

Run a WfRun

To run a WfRun, you can use lhctl.

 lhctl run my-workflow input '{"foo": 1, "art":{"id":1,"title": "bugia", "content": "lol"}}'

It will print out an ID. You can view the status of that WfRun via:

lhctl get wfRun <the id from the previous step>

Documentation

Index

• func GetInfo(input *InputData, context *common.WorkerContext) string
• func MyWorkflowGet(thread *wflib.ThreadBuilder)
• type Article
• type InputData

Functions

func GetInfo

func GetInfo(input *InputData, context *common.WorkerContext) string

func MyWorkflowGet

func MyWorkflowGet(thread *wflib.ThreadBuilder)

Types

type Article

type Article struct {
	Id      int    `json:"id"`
	Title   string `json:"title,omitempty"`
	Content string `json:"content,omitempty"`
}

type InputData

type InputData struct {
	Foo int     `json:"foo"`
	Art Article `json:"art"`
}