Documentation ¶
Index ¶
- func NewCompassConnectionClient(k8sConfig *rest.Config) (compass_conn_clientset.CompassConnectionInterface, error)
- type CompassConnectionClientConstructor
- type ConnectAgentStep
- type GardenerClient
- type InstallKymaStep
- type KubeconfigProvider
- type WaitForAgentToConnectStep
- type WaitForClusterCreationStep
- type WaitForClusterDomainStep
- type WaitForInstallationStep
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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 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
Source Files ¶
Click to show internal directories.
Click to hide internal directories.