provisioning

Documentation

Index

• type ConnectAgentStep
  • func NewConnectAgentStep(configurator runtime.Configurator, ...) *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 CreateBindingsForOperatorsStep
  • func NewCreateBindingsForOperatorsStep(k8sClientProvider k8s.K8sClientProvider, ...) *CreateBindingsForOperatorsStep
  • func (s *CreateBindingsForOperatorsStep) Name() model.OperationStage
  • func (s *CreateBindingsForOperatorsStep) Run(cluster model.Cluster, _ model.Operation, log logrus.FieldLogger) (operations.StageResult, error)
  • func (s *CreateBindingsForOperatorsStep) TimeLimit() time.Duration
• type DynamicKubeconfigProvider
• type GardenerClient
• type OperatorRoleBinding
• type WaitForClusterCreationStep
  • func NewWaitForClusterCreationStep(gardenerClient GardenerClient, dbSession dbsession.ReadWriteSession, ...) *WaitForClusterCreationStep
  • func (s *WaitForClusterCreationStep) Name() model.OperationStage
  • func (s *WaitForClusterCreationStep) Run(cluster model.Cluster, _ 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, log logrus.FieldLogger) (operations.StageResult, error)
  • func (s *WaitForClusterDomainStep) TimeLimit() time.Duration

Types

type ConnectAgentStep

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

func NewConnectAgentStep

func NewConnectAgentStep(
	configurator runtime.Configurator,
	dynamicKubeconfigProvider DynamicKubeconfigProvider,
	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 CreateBindingsForOperatorsStep

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

func NewCreateBindingsForOperatorsStep

func NewCreateBindingsForOperatorsStep(
	k8sClientProvider k8s.K8sClientProvider,
	operatorRoleBindingConfig OperatorRoleBinding,
	dynamicKubeconfigProvider DynamicKubeconfigProvider,
	nextStep model.OperationStage,
	timeLimit time.Duration) *CreateBindingsForOperatorsStep

func (*CreateBindingsForOperatorsStep) Name

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

func (*CreateBindingsForOperatorsStep) Run

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

func (*CreateBindingsForOperatorsStep) TimeLimit

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

type DynamicKubeconfigProvider

type DynamicKubeconfigProvider interface {
	FetchFromRequest(shootName string) ([]byte, error)
}

type GardenerClient

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

type OperatorRoleBinding

type OperatorRoleBinding struct {
	L2SubjectName    string `envconfig:"default=runtimeOperator"`
	L3SubjectName    string `envconfig:"default=runtimeAdmin"`
	CreatingForAdmin bool   `envconfig:"default=false"`
}

type WaitForClusterCreationStep

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

func NewWaitForClusterCreationStep

func NewWaitForClusterCreationStep(gardenerClient GardenerClient, dbSession dbsession.ReadWriteSession, 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, _ 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, log logrus.FieldLogger) (operations.StageResult, error)

func (*WaitForClusterDomainStep) TimeLimit

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