transformers

type BaseTransformer struct {
	gvk.GroupVersionKind
	Spec   interface{} `json:"spec"`
	Status []Status    `json:"status"`
}

type ITransformer interface {
	//Prepare() error
	//Transform(base interface{}) error
	WithSpec(spec interface{}, params map[string]interface{}) (ITransformer, error)
	Execute(ctx context.Context, base map[string]interface{}) (map[string]interface{}, error)
	Result() interface{}
	Status() []Status
	Params() map[string]interface{}
	CreditsConsumed() int
	Deadline() time.Duration
}

type ManifestInfo struct {
	GeneratedAt      time.Time `json:"generatedAt"`
	TransformerCount int       `json:"transformerCount"`
	Runtime          int64     `json:"runtime"`
	ManifestCID      string    `json:"manifestCID"`
}

type NewTransformerFunc = func(spec interface{}, params map[string]interface{}) (ITransformer, error)

type Status struct {
	Name  string      `json:"name"`
	Value interface{} `json:"value"`
}

type TransformerInfo struct {
	New      NewTransformerFunc
	Credits  int
	Deadline time.Duration
}

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