Documentation ¶
Index ¶
- Constants
- type ClusterRef
- type Config
- type IntegratedServicesOperatorInstallerActivity
- type IntegratedServicesOperatorInstallerActivityInput
- type IntegratedServicesOperatorInstallerWorkflowInput
- type IntegratedServicesOperatorWorkflow
- type NextClusterIDActivity
- type NextIDProvider
- type SingleClusterIntegratedServiceOperatorInstallerWorkflow
- type SingleClusterIntegratedServiceOperatorInstallerWorkflowInput
Constants ¶
View Source
const ( IntegratedServiceOperatorInstallerActivityName = "integrated-service-operator-installer-activity" GetNextClusterRefActivityName = "get-next-cluster-id-activity" )
View Source
const IntegratedServiceOperatorInstallerWorkflowName = "integrated-service-operator-installer"
View Source
const SingleClusterIntegratedServiceOperatorInstallerWorkflowName = "single-cluster-integrated-service-operator-installer"
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ClusterRef ¶
ClusterRef encapsulates information about the next cluster to be processed
type IntegratedServicesOperatorInstallerActivity ¶
type IntegratedServicesOperatorInstallerActivity struct {
// contains filtered or unexported fields
}
func NewInstallerActivity ¶
func NewInstallerActivity(repoUpdater helm.Service, chartReleaser helm.UnifiedReleaser, config Config) IntegratedServicesOperatorInstallerActivity
func (IntegratedServicesOperatorInstallerActivity) Execute ¶
func (r IntegratedServicesOperatorInstallerActivity) Execute(ctx context.Context, input IntegratedServicesOperatorInstallerActivityInput) error
type IntegratedServicesOperatorInstallerActivityInput ¶
func NewInstallerActivityInput ¶
func NewInstallerActivityInput(orgID uint, clusterID uint) IntegratedServicesOperatorInstallerActivityInput
type IntegratedServicesOperatorInstallerWorkflowInput ¶
type IntegratedServicesOperatorInstallerWorkflowInput struct {
LastClusterID uint
}
type IntegratedServicesOperatorWorkflow ¶
type IntegratedServicesOperatorWorkflow struct {
// contains filtered or unexported fields
}
func NewISOperatorWorkflow ¶
func NewISOperatorWorkflow(config Config) IntegratedServicesOperatorWorkflow
func (IntegratedServicesOperatorWorkflow) Execute ¶
func (w IntegratedServicesOperatorWorkflow) Execute(ctx workflow.Context, input IntegratedServicesOperatorInstallerWorkflowInput) error
type NextClusterIDActivity ¶
type NextClusterIDActivity struct { NextIDProvider NextIDProvider ClusterChecker integratedservices.ClusterService }
func NewNextClusterIDActivity ¶
func NewNextClusterIDActivity(clusterService integratedservices.ClusterService, NextidProvider NextIDProvider) NextClusterIDActivity
func (NextClusterIDActivity) Execute ¶
func (n NextClusterIDActivity) Execute(ctx context.Context, lastClusterID uint) (ClusterRef, error)
type SingleClusterIntegratedServiceOperatorInstallerWorkflow ¶
type SingleClusterIntegratedServiceOperatorInstallerWorkflow struct{}
SingleClusterIntegratedServiceOperatorInstallerWorkflow workflow component struct
func NewSingleClusterIntegratedServiceOperatorInstallerWorkflow ¶
func NewSingleClusterIntegratedServiceOperatorInstallerWorkflow() SingleClusterIntegratedServiceOperatorInstallerWorkflow
func (SingleClusterIntegratedServiceOperatorInstallerWorkflow) Execute ¶
func (s SingleClusterIntegratedServiceOperatorInstallerWorkflow) Execute(ctx workflow.Context, input SingleClusterIntegratedServiceOperatorInstallerWorkflowInput) error
Execute workflow function for installing the integrated service operator to a single cluster
type SingleClusterIntegratedServiceOperatorInstallerWorkflowInput ¶
type SingleClusterIntegratedServiceOperatorInstallerWorkflowInput struct { ClusterID uint OrgID uint }
SingleClusterIntegratedServiceOperatorInstallerWorkflowInput input definition for the SingleClusterIntegratedServiceOperatorInstallerWorkflow
Click to show internal directories.
Click to hide internal directories.