provisioning

Documentation

Index

• func NewCompassConnectionClient(k8sConfig *rest.Config) (compass_conn_clientset.CompassConnectionInterface, error)
• type CompassConnectionClientConstructor
• type ConnectAgentStep
  • func NewConnectAgentStep(configurator runtime.Configurator, nextStage model.OperationStage, ...) *ConnectAgentStep
  • func (s *ConnectAgentStep) Name() model.OperationStage
  • func (s *ConnectAgentStep) Run(cluster model.Cluster, _ model.Operation, _ logrus.FieldLogger) (operations.StageResult, error)
  • func (s *ConnectAgentStep) TimeLimit() time.Duration
• type GardenerClient
• type InstallKymaStep
  • func NewInstallKymaStep(installationClient installation.Service, nextStep model.OperationStage, ...) *InstallKymaStep
  • func (s *InstallKymaStep) Name() model.OperationStage
  • func (s *InstallKymaStep) Run(cluster model.Cluster, _ model.Operation, logger logrus.FieldLogger) (operations.StageResult, error)
  • func (s *InstallKymaStep) TimeLimit() time.Duration
• type KubeconfigProvider
• type WaitForAgentToConnectStep
  • func NewWaitForAgentToConnectStep(ccClientProvider CompassConnectionClientConstructor, ...) *WaitForAgentToConnectStep
  • func (s *WaitForAgentToConnectStep) Name() model.OperationStage
  • func (s *WaitForAgentToConnectStep) Run(cluster model.Cluster, _ model.Operation, logger logrus.FieldLogger) (operations.StageResult, error)
  • func (s *WaitForAgentToConnectStep) TimeLimit() time.Duration
• type WaitForClusterCreationStep
  • func NewWaitForClusterCreationStep(gardenerClient GardenerClient, dbSession dbsession.ReadWriteSession, ...) *WaitForClusterCreationStep
  • func (s *WaitForClusterCreationStep) Name() model.OperationStage
  • func (s *WaitForClusterCreationStep) Run(cluster model.Cluster, operation model.Operation, logger log.FieldLogger) (operations.StageResult, error)
  • func (s *WaitForClusterCreationStep) TimeLimit() time.Duration
• type WaitForClusterDomainStep
  • func NewWaitForClusterDomainStep(gardenerClient GardenerClient, directorClient director.DirectorClient, ...) *WaitForClusterDomainStep
  • func (s *WaitForClusterDomainStep) Name() model.OperationStage
  • func (s *WaitForClusterDomainStep) Run(cluster model.Cluster, _ model.Operation, logger logrus.FieldLogger) (operations.StageResult, error)
  • func (s *WaitForClusterDomainStep) TimeLimit() time.Duration
• type WaitForInstallationStep
  • func NewWaitForInstallationStep(installationClient installation.Service, nextStep model.OperationStage, ...) *WaitForInstallationStep
  • func (s *WaitForInstallationStep) Name() model.OperationStage
  • func (s *WaitForInstallationStep) Run(cluster model.Cluster, _ model.Operation, logger logrus.FieldLogger) (operations.StageResult, error)
  • func (s *WaitForInstallationStep) TimeLimit() time.Duration

Functions

func NewCompassConnectionClient

func NewCompassConnectionClient(k8sConfig *rest.Config) (compass_conn_clientset.CompassConnectionInterface, error)

Types

type CompassConnectionClientConstructor

type CompassConnectionClientConstructor func(k8sConfig *rest.Config) (compass_conn_clientset.CompassConnectionInterface, error)

type ConnectAgentStep

type ConnectAgentStep struct {
	// contains filtered or unexported fields
}

func NewConnectAgentStep

func NewConnectAgentStep(configurator runtime.Configurator, nextStage model.OperationStage, timeLimit time.Duration) *ConnectAgentStep

func (*ConnectAgentStep) Name

func (s *ConnectAgentStep) Name() model.OperationStage

func (*ConnectAgentStep) Run

func (s *ConnectAgentStep) Run(cluster model.Cluster, _ model.Operation, _ logrus.FieldLogger) (operations.StageResult, error)

func (*ConnectAgentStep) TimeLimit

func (s *ConnectAgentStep) TimeLimit() time.Duration

type GardenerClient

type GardenerClient interface {
	Get(name string, options v1.GetOptions) (*gardener_types.Shoot, error)
}

type InstallKymaStep

type InstallKymaStep struct {
	// contains filtered or unexported fields
}

func NewInstallKymaStep

func NewInstallKymaStep(installationClient installation.Service, nextStep model.OperationStage, timeLimit time.Duration) *InstallKymaStep

func (*InstallKymaStep) Name

func (s *InstallKymaStep) Name() model.OperationStage

func (*InstallKymaStep) Run

func (s *InstallKymaStep) Run(cluster model.Cluster, _ model.Operation, logger logrus.FieldLogger) (operations.StageResult, error)

func (*InstallKymaStep) TimeLimit

func (s *InstallKymaStep) TimeLimit() time.Duration

type KubeconfigProvider

type KubeconfigProvider interface {
	FetchRaw(shootName string) ([]byte, error)
}

type WaitForAgentToConnectStep

type WaitForAgentToConnectStep struct {
	// contains filtered or unexported fields
}

func NewWaitForAgentToConnectStep

func NewWaitForAgentToConnectStep(
	ccClientProvider CompassConnectionClientConstructor,
	nextStep model.OperationStage,
	timeLimit time.Duration,
	directorClient director.DirectorClient) *WaitForAgentToConnectStep

func (*WaitForAgentToConnectStep) Name

func (s *WaitForAgentToConnectStep) Name() model.OperationStage

func (*WaitForAgentToConnectStep) Run

func (s *WaitForAgentToConnectStep) Run(cluster model.Cluster, _ model.Operation, logger logrus.FieldLogger) (operations.StageResult, error)

func (*WaitForAgentToConnectStep) TimeLimit

func (s *WaitForAgentToConnectStep) TimeLimit() time.Duration

type WaitForClusterCreationStep

type WaitForClusterCreationStep struct {
	// contains filtered or unexported fields
}

func NewWaitForClusterCreationStep

func NewWaitForClusterCreationStep(gardenerClient GardenerClient, dbSession dbsession.ReadWriteSession, kubeconfigProvider KubeconfigProvider, nextStep model.OperationStage, timeLimit time.Duration) *WaitForClusterCreationStep

func (*WaitForClusterCreationStep) Name

func (s *WaitForClusterCreationStep) Name() model.OperationStage

func (*WaitForClusterCreationStep) Run

func (s *WaitForClusterCreationStep) Run(cluster model.Cluster, operation model.Operation, logger log.FieldLogger) (operations.StageResult, error)

func (*WaitForClusterCreationStep) TimeLimit

func (s *WaitForClusterCreationStep) TimeLimit() time.Duration

type WaitForClusterDomainStep

type WaitForClusterDomainStep struct {
	// contains filtered or unexported fields
}

func NewWaitForClusterDomainStep

func NewWaitForClusterDomainStep(gardenerClient GardenerClient, directorClient director.DirectorClient, nextStep model.OperationStage, timeLimit time.Duration) *WaitForClusterDomainStep

func (*WaitForClusterDomainStep) Name

func (s *WaitForClusterDomainStep) Name() model.OperationStage

func (*WaitForClusterDomainStep) Run

func (s *WaitForClusterDomainStep) Run(cluster model.Cluster, _ model.Operation, logger logrus.FieldLogger) (operations.StageResult, error)

func (*WaitForClusterDomainStep) TimeLimit

func (s *WaitForClusterDomainStep) TimeLimit() time.Duration

type WaitForInstallationStep

type WaitForInstallationStep struct {
	// contains filtered or unexported fields
}

func NewWaitForInstallationStep

func NewWaitForInstallationStep(installationClient installation.Service, nextStep model.OperationStage, timeLimit time.Duration) *WaitForInstallationStep

func (*WaitForInstallationStep) Name

func (s *WaitForInstallationStep) Name() model.OperationStage

func (*WaitForInstallationStep) Run

func (s *WaitForInstallationStep) Run(cluster model.Cluster, _ model.Operation, logger logrus.FieldLogger) (operations.StageResult, error)

func (*WaitForInstallationStep) TimeLimit

func (s *WaitForInstallationStep) TimeLimit() time.Duration