taskutil

Documentation

Index

• func LoadSpecFromBytes(c *client.Client, buf []byte) (*model.TaskSpec, error)
• func LoadTaskFromYamlFile(ctx context.Context, cl *client.Client, yamlFile string) (string, error)
• func LoadTaskYaml(ctx context.Context, c *client.Client, taskYaml []byte) (uid string, err error)
• func RegisterTaskFunctionFromYaml(ctx context.Context, c *client.Client, taskYaml []byte, fn client.ServiceFn) (string, error)
• func RegisterTaskFunctionFromYamlFile(ctx context.Context, c *client.Client, yamlFile string, fn client.ServiceFn) (string, error)

Functions

func LoadSpecFromBytes

func LoadSpecFromBytes(c *client.Client, buf []byte) (*model.TaskSpec, error)

LoadSpecFromBytes loads and parses a task.yaml file to a *model.TaskSpec type.

func LoadTaskFromYamlFile

func LoadTaskFromYamlFile(ctx context.Context, cl *client.Client, yamlFile string) (string, error)

LoadTaskFromYamlFile registers a service task with a task spec.

func LoadTaskYaml

func LoadTaskYaml(ctx context.Context, c *client.Client, taskYaml []byte) (uid string, err error)

LoadTaskYaml registers a service task with a task spec. It returns the unique identifier of the registered task.

func RegisterTaskFunctionFromYaml

func RegisterTaskFunctionFromYaml(ctx context.Context, c *client.Client, taskYaml []byte, fn client.ServiceFn) (string, error)

RegisterTaskFunctionFromYaml registers a service task with a task spec from YAML. It first loads and parses the task YAML, and then calls the RegisterTaskFunction method on the client object to register the task.

func RegisterTaskFunctionFromYamlFile

func RegisterTaskFunctionFromYamlFile(ctx context.Context, c *client.Client, yamlFile string, fn client.ServiceFn) (string, error)

RegisterTaskFunctionFromYamlFile registers a service task function from a task spec YAML file. It first loads and parses the task YAML, and then calls the RegisterTaskFunction method on the client object to register the task function.