Documentation
¶
Index ¶
- Constants
- Variables
- type WorkflowService
- type WorkflowServiceImpl
- func (impl *WorkflowServiceImpl) GetWorkflow(executorType cdWorkflow.WorkflowExecutorType, name string, namespace string, ...) (*unstructured.UnstructuredList, error)
- func (impl *WorkflowServiceImpl) GetWorkflowStatus(executorType cdWorkflow.WorkflowExecutorType, name string, namespace string, ...) (*types.WorkflowStatus, error)
- func (impl *WorkflowServiceImpl) SubmitWorkflow(workflowRequest *types.WorkflowRequest) (*unstructured.UnstructuredList, string, error)
- func (impl *WorkflowServiceImpl) TerminateDanglingWorkflows(cancelWfDtoRequest *types.CancelWfRequestDto) error
- func (impl *WorkflowServiceImpl) TerminateWorkflow(cancelWfDtoRequest *types.CancelWfRequestDto) error
Constants ¶
View Source
const (
CI_NODE_SELECTOR_APP_LABEL_KEY = "devtron.ai/node-selector"
)
Variables ¶
View Source
var ExecutorWireSet = wire.NewSet( NewWorkflowServiceImpl, wire.Bind(new(WorkflowService), new(*WorkflowServiceImpl)), )
Functions ¶
This section is empty.
Types ¶
type WorkflowService ¶
type WorkflowService interface { SubmitWorkflow(workflowRequest *types.WorkflowRequest) (*unstructured.UnstructuredList, string, error) // DeleteWorkflow(wfName string, namespace string) error GetWorkflow(executorType cdWorkflow.WorkflowExecutorType, name string, namespace string, restConfig *rest.Config) (*unstructured.UnstructuredList, error) GetWorkflowStatus(executorType cdWorkflow.WorkflowExecutorType, name string, namespace string, restConfig *rest.Config) (*types.WorkflowStatus, error) // ListAllWorkflows(namespace string) (*v1alpha1.WorkflowList, error) // UpdateWorkflow(wf *v1alpha1.Workflow) (*v1alpha1.Workflow, error) TerminateWorkflow(cancelWfDtoRequest *types.CancelWfRequestDto) error TerminateDanglingWorkflows(cancelWfDtoRequest *types.CancelWfRequestDto) error }
type WorkflowServiceImpl ¶
type WorkflowServiceImpl struct { Logger *zap.SugaredLogger // contains filtered or unexported fields }
func NewWorkflowServiceImpl ¶
func NewWorkflowServiceImpl(Logger *zap.SugaredLogger, envRepository repository2.EnvironmentRepository, ciCdConfig *types.CiCdConfig, configMapService read.ConfigReadService, globalCMCSService pipeline.GlobalCMCSService, argoWorkflowExecutor executors.ArgoWorkflowExecutor, systemWorkflowExecutor executors.SystemWorkflowExecutor, k8sCommonService k8s2.K8sCommonService, infraProvider infraProviders.InfraProvider, ucid ucid.Service, k8sUtil *k8s.K8sServiceImpl, ) (*WorkflowServiceImpl, error)
func (*WorkflowServiceImpl) GetWorkflow ¶
func (impl *WorkflowServiceImpl) GetWorkflow(executorType cdWorkflow.WorkflowExecutorType, name string, namespace string, restConfig *rest.Config) (*unstructured.UnstructuredList, error)
func (*WorkflowServiceImpl) GetWorkflowStatus ¶
func (impl *WorkflowServiceImpl) GetWorkflowStatus(executorType cdWorkflow.WorkflowExecutorType, name string, namespace string, restConfig *rest.Config) (*types.WorkflowStatus, error)
func (*WorkflowServiceImpl) SubmitWorkflow ¶
func (impl *WorkflowServiceImpl) SubmitWorkflow(workflowRequest *types.WorkflowRequest) (*unstructured.UnstructuredList, string, error)
func (*WorkflowServiceImpl) TerminateDanglingWorkflows ¶
func (impl *WorkflowServiceImpl) TerminateDanglingWorkflows(cancelWfDtoRequest *types.CancelWfRequestDto) error
func (*WorkflowServiceImpl) TerminateWorkflow ¶
func (impl *WorkflowServiceImpl) TerminateWorkflow(cancelWfDtoRequest *types.CancelWfRequestDto) error
Click to show internal directories.
Click to hide internal directories.