usecase

package

Go to main page

Versions in this module

v0

v0.6.0

Oct 30, 2026

Changes in this version

+ const MaxSecurityPipelines

+ var ErrImageScanNotFound = errors.New("스캔 결과를 찾지 못했습니다")

+ var ErrPipelineNotStackBound = errors.New("pipeline is not bound to a stack")

+ var ErrScanPipelineNotFound = errors.New("파이프라인을 찾지 못했습니다")

+ var ErrStackClusterMismatch = domain.ErrStackClusterMismatch

+ var ErrTemplateSourceRequiresStack = errors.New(...)

+ func DeployClusterID(ctx context.Context, reader port.StackReader, pipeline *domain.Pipeline) string

+ func MatchStackTarget(stack *port.StackSummary, orgID, requested string) (string, error)

type CreatePipeline

+ func (uc *CreatePipeline) WithScanPolicyPublisher(p ScanPolicyPipelinePublisher) *CreatePipeline

type DeletePipeline

+ func (uc *DeletePipeline) WithCredentialObjectDeleter(d port.PipelineCredentialObjectDeleter) *DeletePipeline

+ func (uc *DeletePipeline) WithPipelineNameLookup(l port.PipelineNameLookup) *DeletePipeline

+ func (uc *DeletePipeline) WithSecretDeleter(d port.ManagedSecretDeleter) *DeletePipeline

+ type ListPipelineSecurity struct

+ func NewListPipelineSecurity(reader port.PipelineSecurityReader) *ListPipelineSecurity

+ func (uc *ListPipelineSecurity) Execute(ctx context.Context, orgID string) (*domain.PipelineSecurityList, error)

type ProvisionAppProject

+ func (uc *ProvisionAppProject) WithSourceArchive(sources port.SourceArchive) *ProvisionAppProject

type ProvisionAppProjectInput

+ DependencyScanEndpoint string

+ ImageScannerEndpoint string

+ ImageScannerJavaDBRepository string

+ RefreshDefinitionOnly bool

+ SASTServerEndpoint string

+ SASTToken string

+ Source *domain.TemplateSource

type ProvisionAppProjectOutput

+ DefinitionRefreshed bool

+ ImportedSource *domain.TemplateSource

+ RepositoryRecreated bool

+ Stages []string

type ProvisionPipelineRepository

+ func (uc *ProvisionPipelineRepository) WithSourceArchive(sources port.SourceArchive) *ProvisionPipelineRepository

type ProvisionPipelineRepositoryInput

+ RefreshDefinitionOnly bool

+ Source *domain.TemplateSource

type ProvisionPipelineRepositoryOutput

+ DefinitionRefreshed bool

+ ImportedSource *domain.TemplateSource

+ RepositoryRecreated bool

+ Stages []string

+ type RefreshPipelineDefinition struct

+ func NewRefreshPipelineDefinition(pipelines port.PipelineRepository, provisioner RepositoryProvisioner) *RefreshPipelineDefinition

+ func (uc *RefreshPipelineDefinition) Execute(ctx context.Context, pipelineID string) (*RefreshPipelineDefinitionOutput, error)

+ func (uc *RefreshPipelineDefinition) WithScanPolicyPublisher(p ScanPolicyPipelinePublisher) *RefreshPipelineDefinition

+ type RefreshPipelineDefinitionOutput struct

+ MissingVariables []string

+ Pipeline *domain.Pipeline

+ RepositoryRecreated bool

+ Stages []string

+ Warnings []string

+ type ScanPolicyPipelinePublisher interface

+ PublishToPipeline func(ctx context.Context, pipeline *domain.Pipeline) *ScanPolicyPush

+ type ScanPolicyPush struct

+ Error string

+ PipelineID string

+ PipelineName string

+ Status ScanPolicyPushStatus

+ type ScanPolicyPushStatus string

+ const ScanPolicyPushApplied

+ const ScanPolicyPushFailed

+ type ScanPolicyService struct

+ func NewScanPolicyService(policies port.ScanPolicyRepository, pipelines port.PipelineRepository, ...) *ScanPolicyService

+ func (s *ScanPolicyService) Get(ctx context.Context, stackID string) (*ScanPolicyView, error)

+ func (s *ScanPolicyService) PublishToPipeline(ctx context.Context, pipeline *domain.Pipeline) *ScanPolicyPush

+ func (s *ScanPolicyService) Update(ctx context.Context, stackID string, policy domain.ScanPolicy, actor string) (*UpdateScanPolicyResult, error)

+ type ScanPolicyView struct

+ IsDefault bool

+ Policy domain.ScanPolicy

+ StackID string

+ type ScanVulnerabilities struct

+ func NewScanVulnerabilities(pipelines port.PipelineRepository, scans port.ImageScanResultRepository, ...) *ScanVulnerabilities

+ func (uc *ScanVulnerabilities) Execute(ctx context.Context, pipelineID, scanID string, ...) (*shareddomain.VulnerabilityPage, error)

+ func (uc *ScanVulnerabilities) ExecuteInOrg(ctx context.Context, orgID, pipelineID, scanID string, ...) (*shareddomain.VulnerabilityPage, error)

type SyncPipelineRuns

+ func (uc *SyncPipelineRuns) SyncAll(ctx context.Context) (int, error)

+ func (uc *SyncPipelineRuns) WithArtifacts(reader port.CIArtifactReader) *SyncPipelineRuns

+ func (uc *SyncPipelineRuns) WithDependencyScans(repo port.DependencyScanResultRepository) *SyncPipelineRuns

+ func (uc *SyncPipelineRuns) WithImageScans(repo port.ImageScanResultRepository) *SyncPipelineRuns

+ func (uc *SyncPipelineRuns) WithSASTResults(repo port.SASTResultRepository) *SyncPipelineRuns

+ func (uc *SyncPipelineRuns) WithScanPolicies(repo port.ScanPolicyRepository) *SyncPipelineRuns

+ func (uc *SyncPipelineRuns) WithSecretScans(repo port.SecretScanResultRepository) *SyncPipelineRuns

+ func (uc *SyncPipelineRuns) WithSyncablePipelines(lister port.SyncablePipelineLister) *SyncPipelineRuns

type SyncPipelineRunsInput

+ Policy *domain.ScanPolicy

+ PolicyUnavailable bool

+ SASTWebURL string

+ type UpdateScanPolicyResult struct

+ Pushes []ScanPolicyPush

v0.5.0

Aug 31, 2026

Changes in this version

+ const DefaultCommonProjectPath

+ const DeployTokenVariable

+ var ErrStackNotFound = errors.New("referenced stack does not exist")

+ var ErrStackOrgMismatch = errors.New("stack belongs to a different organization")

+ func BuildStepPlan(pipeline *domain.Pipeline, manifestTypes ...[]string) []string

+ func OTLPEndpointFor(ctx context.Context, reader port.StackReader, stackID string) string

+ type CreatePipeline struct

+ func NewCreatePipeline(pipelineRepo port.PipelineRepository, ...) *CreatePipeline

+ func (uc *CreatePipeline) Execute(ctx context.Context, input CreatePipelineInput) (*CreatePipelineOutput, error)

+ func (uc *CreatePipeline) WithRepositoryProvisioner(p RepositoryProvisioner) *CreatePipeline

+ type CreatePipelineInput struct

+ AppType domain.AppType

+ ClusterID string

+ DockerContext string

+ DockerfilePath string

+ EnvVars map[string]string

+ ExecutionMode string

+ GitRepoURL string

+ Name string

+ Namespace string

+ OrgID string

+ Port int32

+ ProvisionRepository bool

+ RegistryCredentials map[string]string

+ Replicas int32

+ RequestedByEmail string

+ StackID string

+ TemplateID string

+ type CreatePipelineOutput struct

+ ArgoApplicationCreated bool

+ MissingVariables []string

+ Pipeline *domain.Pipeline

+ RepositoryPath string

+ ScaffoldSkipped bool

+ StackWarning string

+ Warnings []string

+ type DeletePipeline struct

+ func NewDeletePipeline(pipelines port.PipelineRepository, factory port.SCMBundleFactory, ...) *DeletePipeline

+ func (uc *DeletePipeline) Execute(ctx context.Context, input DeletePipelineInput) (*DeletePipelineOutput, error)

+ func (uc *DeletePipeline) WithWorkloadDeleter(d port.WorkloadDeleter) *DeletePipeline

+ type DeletePipelineInput struct

+ DeleteClusterResources bool

+ DeleteImages bool

+ DeleteRepository bool

+ PipelineID string

+ type DeletePipelineOutput struct

+ ClusterResourcesDeleted bool

+ ImagesDeleted bool

+ RepositoryDeleted bool

+ Warnings []string

+ type DeployOption func(*DeployPipeline)

+ func WithBuildDelegate(d port.BuildDelegate) DeployOption

+ func WithClusterTargetProvider(p port.ClusterTargetProvider) DeployOption

+ func WithDeployTimeout(d time.Duration) DeployOption

+ func WithImagePreparer(p port.ImagePreparer) DeployOption

+ func WithStackReader(r port.StackReader) DeployOption

+ type DeployPipeline struct

+ func NewDeployPipeline(pipelineRepo port.PipelineRepository, deploymentRepo port.DeploymentRepository, ...) *DeployPipeline

+ func (uc *DeployPipeline) ApplyAsync(deploymentID string, manifestTypes ...[]string)

+ func (uc *DeployPipeline) Execute(ctx context.Context, input DeployPipelineInput) (*DeployPipelineOutput, error)

+ func (uc *DeployPipeline) Start(ctx context.Context, input DeployPipelineInput) (*DeployPipelineOutput, error)

+ type DeployPipelineInput struct

+ DeployedBy string

+ ManifestTypes []string

+ PipelineID string

+ Version string

+ type DeployPipelineOutput struct

+ Deployment *domain.Deployment

+ type ListPipelines struct

+ func NewListPipelines(pipelineRepo port.PipelineRepository) *ListPipelines

+ func (uc *ListPipelines) Execute(ctx context.Context, input ListPipelinesInput) (*ListPipelinesOutput, error)

+ type ListPipelinesInput struct

+ OrgID string

+ StackID string

+ type ListPipelinesOutput struct

+ Pipelines []*domain.Pipeline

+ type ProvisionAppProject struct

+ func NewProvisionAppProject(scm port.SCMProvisioner, pipeline port.PipelineConfigurator, ...) *ProvisionAppProject

+ func (uc *ProvisionAppProject) Execute(ctx context.Context, input ProvisionAppProjectInput) (*ProvisionAppProjectOutput, error)

+ func (uc *ProvisionAppProject) WithCIJobs(jobs port.CIJobProvisioner, webhooks port.SCMWebhookProvisioner, ...) *ProvisionAppProject

+ func (uc *ProvisionAppProject) WithCredentialPlane(plane port.PipelineCredentialPlane) *ProvisionAppProject

+ type ProvisionAppProjectInput struct

+ AccessDomain string

+ AppName string

+ AppType domain.AppType

+ GatewayName string

+ GatewayNamespace string

+ GroupID string

+ GroupPath string

+ Namespace string

+ Platform port.SCMPlatform

+ Port int32

+ RegistryCredentials map[string]string

+ Replicas int32

+ RepoAccessToken string

+ SharedAccessToken string

+ StackID string

+ TemplateID string

+ type ProvisionAppProjectOutput struct

+ ArgoReadToken string

+ CIJobURL string

+ CredentialManifests []string

+ ImageTarget *port.ImageTarget

+ MissingVariables []string

+ Project *port.SCMProject

+ ScaffoldSkipped bool

+ Warnings []string

+ type ProvisionCommonProject struct

+ func NewProvisionCommonProject(scm port.SCMProvisioner) *ProvisionCommonProject

+ func (uc *ProvisionCommonProject) Execute(ctx context.Context, input ProvisionCommonProjectInput) (*ProvisionCommonProjectOutput, error)

+ type ProvisionCommonProjectInput struct

+ GroupName string

+ GroupPath string

+ Platform port.SCMPlatform

+ ProjectPath string

+ type ProvisionCommonProjectOutput struct

+ DocsSkipped bool

+ Group *port.SCMGroup

+ Project *port.SCMProject

+ type ProvisionPipelineRepository struct

+ func NewProvisionPipelineRepository(factory port.SCMBundleFactory, applier port.ManifestApplier, ...) *ProvisionPipelineRepository

+ func (uc *ProvisionPipelineRepository) Execute(ctx context.Context, input ProvisionPipelineRepositoryInput) (*ProvisionPipelineRepositoryOutput, error)

+ type ProvisionPipelineRepositoryInput struct

+ AppName string

+ AppType domain.AppType

+ CommonProjectPath string

+ Namespace string

+ Port int32

+ RegistryCredentials map[string]string

+ Replicas int32

+ RequestedByEmail string

+ StackID string

+ TemplateID string

+ type ProvisionPipelineRepositoryOutput struct

+ ArgoApplicationCreated bool

+ CommonProject *port.SCMProject

+ ImageRepository string

+ MissingVariables []string

+ Project *port.SCMProject

+ RepoURL string

+ ScaffoldSkipped bool

+ Warnings []string

+ type RepositoryProvisioner interface

+ Execute func(ctx context.Context, input ProvisionPipelineRepositoryInput) (*ProvisionPipelineRepositoryOutput, error)

+ type SyncPipelineRuns struct

+ func NewSyncPipelineRuns(builds port.CIBuildReader, deployments port.DeploymentRepository) *SyncPipelineRuns

+ func (uc *SyncPipelineRuns) Execute(ctx context.Context, input SyncPipelineRunsInput) (int, error)

+ func (uc *SyncPipelineRuns) ForPipeline(ctx context.Context, pipelineID string) (int, error)

+ func (uc *SyncPipelineRuns) WithBundleFactory(factory port.SCMBundleFactory, pipelines port.PipelineRepository) *SyncPipelineRuns

+ type SyncPipelineRunsInput struct

+ Branch string

+ JobName string

+ Limit int

+ PipelineID string

v0.4.1

Aug 9, 2026

v0.4.0-alpha

Aug 9, 2026

v0.3.0-alpha

Jul 27, 2026

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL