operator

package
v0.0.0-...-e7c744b Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 21, 2023 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

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

type ClusterRef struct {
	ID       uint
	OrgID    uint
	NotFound bool
}

ClusterRef encapsulates information about the next cluster to be processed

type Config

type Config struct {
	// repoName/ChartName format
	Chart     string `json:"chart"`
	Release   string `json:"release"`
	Version   string `json:"version"`
	Namespace string `json:"namespace"`
	BatchSize int    `json:"batchSize"`
}

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

type IntegratedServicesOperatorInstallerActivityInput

type IntegratedServicesOperatorInstallerActivityInput struct {
	OrgID     uint
	ClusterID uint
}

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

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 NextIDProvider

type NextIDProvider func(uint) (uint, uint, error)

type SingleClusterIntegratedServiceOperatorInstallerWorkflow

type SingleClusterIntegratedServiceOperatorInstallerWorkflow struct{}

SingleClusterIntegratedServiceOperatorInstallerWorkflow workflow component struct

func (SingleClusterIntegratedServiceOperatorInstallerWorkflow) Execute

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

Jump to

Keyboard shortcuts

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