Pipelines that move like the tide.

// examples/transform@0.2.1
// inputs:  { message: string, locale?: string }
// outputs: { message: string, meta: { length: int } }

package transform

import "github.com/cuttlefish/sdk/go/task"

type Input struct {
  Message string `json:"message"`
  Locale  string `json:"locale,omitempty"`
}

func Run(ctx task.Context, in Input) (Output, error) {
  ctx.Log().Info("transforming", "locale", in.Locale)
  return Output{
    Message: strings.ToUpper(in.Message),
    Meta:    Meta{Length: len(in.Message)},
  }, nil
}