transform

Documentation

Index

• func RegisterIn[C any, P ParamFor[C]](registry *Registry, name string, configSchema schema.Schema[C], ...) registrar[C, P]
• type Applier
• type Category
  • func (c Category) IsTerminal() bool
• type Composer
• type ConfigProvider
• type Graph
  • func Schedule(reg *Registry, sal StepAtomList) (*Graph, error)
  • func (g *Graph) Run(h db.Context, app db.App, initial asset.Asset) ([]asset.Asset, error)
• type Metadata
• type ParamFor
• type Registry
  • func NewRegistry() *Registry
  • func (r *Registry) DecodeMsg(stepData db.Step) (View, error)
  • func (r *Registry) RegisterComposer(cat Category, composer Composer) *Registry
  • func (r *Registry) ScanFrom(name string, scanner schema.Scanner, copt cfgf.Opt) (View, error)
• type StepAtomList
• type View

Functions

func RegisterIn

func RegisterIn[C any, P ParamFor[C]](
	registry *Registry,
	name string,
	configSchema schema.Schema[C],
	paramsSchema schema.Schema[P]) registrar[C, P]

Types

type Applier

type Applier interface {
	asset.Applier
	EncodeMsg(w *fastbuf.W)
}

type Category

type Category string

const Terminal Category = "Terminal"

func (Category) IsTerminal

func (c Category) IsTerminal() bool

type Composer

type Composer interface {
	Compose(appliers []Applier) (Applier, error)
}

type ConfigProvider

type ConfigProvider interface {
	configq.Provider
	core.WorkspaceConfigProvider
}

type Graph

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

func Schedule

func Schedule(reg *Registry, sal StepAtomList) (*Graph, error)

func (*Graph) Run

func (g *Graph) Run(h db.Context, app db.App, initial asset.Asset) ([]asset.Asset, error)

type Metadata

type Metadata interface {
	// contains filtered or unexported methods
}

type ParamFor

type ParamFor[C any] interface {
	BuildTransform(cfg C) (Applier, error)
}

type Registry

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

func NewRegistry

func NewRegistry() *Registry

func (*Registry) DecodeMsg

func (r *Registry) DecodeMsg(stepData db.Step) (View, error)

func (*Registry) RegisterComposer

func (r *Registry) RegisterComposer(cat Category, composer Composer) *Registry

func (*Registry) ScanFrom

func (r *Registry) ScanFrom(name string, scanner schema.Scanner, copt cfgf.Opt) (View, error)

type StepAtomList

type StepAtomList []*stepAtom

type View

type View interface {
	Name() string
	ConfigHash(ctx db.Context) ref.Sha256
	VisitParams(v schema.Visitor) error
	Build(cp ConfigProvider) (*stepAtom, error)
}