Versions in this module Expand all Collapse all v0 v0.0.1 Nov 20, 2023 Changes in this version + type AlertManagerCommander struct + func (c *AlertManagerCommander) GetCommandType() CommandType + func (c *AlertManagerCommander) ParseCommand(command *service.StepCommand) error + func (c *AlertManagerCommander) Run() (string, error) + type CommandType int + const CommandTypeAlertManager + const CommandTypeGrafana + const CommandTypeHelm + const CommandTypeJq + const CommandTypeK8s + const CommandTypeOpenstack + const CommandTypeP8s + const CommandTypeSynapseagent + func (ct CommandType) String() string + type Commander interface + GetCommandType func() CommandType + Run func() (string, error) + func NewAlertManagerCommander(command *service.StepCommand) (Commander, error) + func NewCommander(command *service.StepCommand) (Commander, error) + func NewGrafanaCommander(command *service.StepCommand) (Commander, error) + func NewHelmCommander(command *service.StepCommand) (Commander, error) + func NewJqCommander(command *service.StepCommand) (Commander, error) + func NewK8sCommander(command *service.StepCommand) (Commander, error) + func NewOpenstackCommander(command *service.StepCommand) (Commander, error) + func NewP8sCommander(command *service.StepCommand) (Commander, error) + func NewSynapseagentCommander(command *service.StepCommand) (Commander, error) + type GrafanaCommander struct + func (c *GrafanaCommander) GetCommandType() CommandType + func (c *GrafanaCommander) ParseCommand(command *service.StepCommand) error + func (c *GrafanaCommander) Run() (string, error) + type HelmCommander struct + func (c *HelmCommander) GetCommandType() CommandType + func (c *HelmCommander) ParseCommand(command *service.StepCommand) error + func (c *HelmCommander) Run() (string, error) + type JqCommander struct + func (c *JqCommander) GetCommandType() CommandType + func (c *JqCommander) ParseCommand(command *service.StepCommand) error + func (c *JqCommander) Run() (string, error) + type K8sCommander struct + func (c *K8sCommander) GetCommandType() CommandType + func (c *K8sCommander) ParseCommand(command *service.StepCommand) error + func (c *K8sCommander) Run() (string, error) + type OpenstackCommander struct + func (c *OpenstackCommander) GetCommandType() CommandType + func (c *OpenstackCommander) ParseCommand(command *service.StepCommand) error + func (c *OpenstackCommander) Run() (string, error) + type P8sCommander struct + func (c *P8sCommander) GetCommandType() CommandType + func (c *P8sCommander) ParseCommand(command *service.StepCommand) error + func (c *P8sCommander) Run() (string, error) + type ServiceExecutor struct + func NewServiceExecutor(service service.ServiceV1, updateChannel chan<- service.ServiceUpdateInterface) *ServiceExecutor + func (se *ServiceExecutor) Execute() (err error) + func (se *ServiceExecutor) SendServiceStatusUpdate(seq int, status service.StepStatus, result string, st, et time.Time) + type ServiceExecutorV2 struct + func NewServiceExecutorV2(service service.ServiceV2, updateChannel chan<- service.ServiceUpdateInterface) *ServiceExecutorV2 + func (se *ServiceExecutorV2) Execute() (err error) + func (se *ServiceExecutorV2) SendServiceStatusUpdate(seq int, status service.StepStatus, result string, st, et time.Time) + type StepExecutor struct + func NewStepExecutor(step service.Step) (*StepExecutor, error) + func (se *StepExecutor) Execute() service.Result + type StepExecutorV2 struct + func NewStepExecutorV2(step *service.FlowStep) (*StepExecutorV2, error) + func (se *StepExecutorV2) Execute() service.Result + type SynapseagentCommander struct + func (c *SynapseagentCommander) GetCommandType() CommandType + func (c *SynapseagentCommander) ParseCommand(command *service.StepCommand) error + func (c *SynapseagentCommander) Run() (string, error)