runner

type AnsibleRunner struct {
	Playbook  string
	Inventory string
	Envs      map[string]string
	Check     bool
}

type App struct {
	Dependencies
	// contains filtered or unexported fields
}

type CallbacksClient interface {
	Callback(executionID uuid.UUID, event string, payload interface{}) error
}

type Catalog []*CatalogCheck

type CatalogCheck struct {
	ID             string `json:"id,omitempty" binding:"required"`
	Name           string `json:"name,omitempty" binding:"required"`
	Group          string `json:"group" binding:"required"`
	Provider       string `json:"provider" binding:"required"`
	Description    string `json:"description,omitempty"`
	Remediation    string `json:"remediation,omitempty"`
	Implementation string `json:"implementation,omitempty"`
	Labels         string `json:"labels,omitempty"`
	Premium        bool   `json:"premium,omitempty"`
}

type Config struct {
	Host          string
	Port          int
	CallbacksUrl  string
	AnsibleFolder string
}

type CustomCommand func(name string, arg ...string) *exec.Cmd

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

type ExecutionEvent struct {
	ExecutionID uuid.UUID `json:"execution_id" binding:"required"`
	ClusterID   uuid.UUID `json:"cluster_id" binding:"required"`
	Provider    string    `json:"provider" binding:"required"`
	Checks      []string  `json:"checks" binding:"required"`
	Hosts       []*Host   `json:"hosts" binding:"required"`
}

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

type Group struct {
	Name  string
	Nodes []*Node
}

type Host struct {
	HostID  uuid.UUID `json:"host_id" binding:"required"`
	Address string    `json:"address" binding:"required"`
	User    string    `json:"user" binding:"required"`
}

type InventoryContent struct {
	Groups []*Group
	Nodes  []*Node // this seems unused
}

type MockRunnerService struct {
	mock.Mock
}

type Node struct {
	Name        string
	AnsibleHost string
	AnsibleUser string
	Variables   map[string]interface{}
}

type RunnerService interface {
	IsCatalogReady() bool
	BuildCatalog() error
	GetCatalog() *Catalog
	GetChannel() chan *ExecutionEvent
	ScheduleExecution(e *ExecutionEvent) error
	Execute(e *ExecutionEvent) error
}