plugins

type BasePlugin struct {
	StepDefinitions map[string]*StepDefinition
}

type PluginInterface interface {
	// Init initializes the plugin.
	Init()
	// Primitives returns the plugin primitives.
	Primitives()
	// RunStep runs a step.
	RunStep(context.Context, map[string]any, *Step) ([]*metrics.Metric, error)
	// RegisterStep registers a step.
	RegisterStep(*StepDefinition)
	// StepExists returns true if the step exists.
	StepExists(string) bool
	// GetSteps returns all steps.
	GetSteps() map[string]*StepDefinition
}

type Step struct {
	// Name is the name of the step.
	Name string
	// Args is the arguments of the step.
	Args map[string]string
	// Timeout is the timeout of the step.
	Timeout int
	// Negate is true if the step should be negated.
	Negate bool
}

type StepDefinition struct {
	Name        string      `json:"name"`
	Description string      `json:"description"`
	Params      []StepParam `json:"params"`
	Fn          stepFn      `json:"-"`
}

type StepParam struct {
	Name        string `json:"name"`
	Description string `json:"description"`
	Optional    bool   `json:"optional"`
}