utils

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

type Event struct {
	Name    string
	Payload Payload
}

type LogDefinition struct {
	Level       string `yaml:"level" json:"level"`
	Type        string `yaml:"type" json:"type"`
	Format      string `yaml:"format" json:"format"`
	Destination string `yaml:"destination" json:"destination"`
}

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

type LoggingContext struct {
	Workflow *Workflow
	Step     *Step
}

type Payload struct {
	EventUUID string
	Spinner   *Spinner
	Step      Step
	Extras    interface{}
}

type Preflight struct {
	Command string         `yaml:"command" json:"command"`
	Message string         `yaml:"message" json:"message"`
	Workdir string         `yaml:"workdir" json:"workdir"`
	Timeout *time.Duration `yaml:"timeout" json:"timeout"`
	// contains filtered or unexported fields
}

type Probe struct {
	Command string `yaml:"command" json:"command"`
	Workdir string `yaml:"workdir" json:"workdir"`
	// contains filtered or unexported fields
}

type Spinner struct {
	UUID string
	Name string
	// contains filtered or unexported fields
}

type Step struct {
	Metadata       map[string]string `yaml:"metadata" json:"metadata"`
	Name           string            `yaml:"name" json:"name"`
	Command        string            `yaml:"command" json:"command"`
	ContinueOnFail bool              `yaml:"continue_on_fail" json:"continue_on_fail"`
	Timeout        *time.Duration    `yaml:"timeout" json:"timeout"`
	Workdir        string            `yaml:"workdir" json:"workdir"`
	Env            []string          `yaml:"env" json:"env"`
	Probe          *Probe            `yaml:"probe" json:"probe"`
	DependsOn      []string          `yaml:"depends_on" json:"depends_on"`
	Preflights     []Preflight       `yaml:"preflights" json:"preflights"`
	AskToProceed   bool              `yaml:"ask_to_proceed" json:"ask_to_proceed"`
	ShowCommand    bool              `yaml:"show_command" json:"show_command"`
	Disabled       bool              `yaml:"disabled" json:"disabled"`
	Logger         *LogDefinition    `yaml:"logger" json:"logger"`
	SessionID      string
	// contains filtered or unexported fields
}

type StepOptions struct {
	Notifier func(ctx context.Context, logger *logrus.Logger, event *Event) error
}

type Workflow struct {
	Version  string            `yaml:"version" json:"version"`
	Metadata map[string]string `yaml:"metadata" json:"metadata"`
	Steps    []*Step           `yaml:"steps" json:"steps"`
	Logger   *LogDefinition    `yaml:"logger" json:"logger"`
	// contains filtered or unexported fields
}

type WorkflowOptions struct {
	Notifier    func(ctx context.Context, logger *logrus.Logger, event *Event) error
	Concurrency int
	Timeout     time.Duration
	Metadata    map[string]string
}