queue

Documentation

Index

• type DeprovisioningTimeouts
• type Executor
• type HibernationTimeouts
• type KubeconfigProvider
• type OperationQueue
  • func CreateDeprovisioningQueue(timeouts DeprovisioningTimeouts, factory dbsession.Factory, ...) OperationQueue
  • func CreateProvisioningQueue(timeouts ProvisioningTimeouts, factory dbsession.Factory, ...) OperationQueue
  • func CreateProvisioningQueueWithoutRegistration(timeouts ProvisioningTimeouts, factory dbsession.Factory, ...) OperationQueue
  • func CreateShootUpgradeQueue(timeouts ProvisioningTimeouts, factory dbsession.Factory, ...) OperationQueue
• type ProvisioningTimeouts
• type Queue
  • func NewQueue(executor Executor) *Queue
  • func (q *Queue) Add(operationId string)
  • func (q *Queue) Run(stop <-chan struct{})

Types

type DeprovisioningTimeouts

type DeprovisioningTimeouts struct {
	ClusterDeletion           time.Duration `envconfig:"default=30m"`
	WaitingForClusterDeletion time.Duration `envconfig:"default=60m"`
}

type Executor

type Executor interface {
	Execute(operationID string) operations.ProcessingResult
}

type HibernationTimeouts

type HibernationTimeouts struct {
	WaitingForClusterHibernation time.Duration `envconfig:"default=60m"`
}

type KubeconfigProvider

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

type OperationQueue

type OperationQueue interface {
	Add(processId string)
	Run(stop <-chan struct{})
}

func CreateDeprovisioningQueue

func CreateDeprovisioningQueue(
	timeouts DeprovisioningTimeouts,
	factory dbsession.Factory,
	directorClient director.DirectorClient,
	shootClient gardener_apis.ShootInterface,
) OperationQueue

func CreateProvisioningQueue

func CreateProvisioningQueue(
	timeouts ProvisioningTimeouts,
	factory dbsession.Factory,
	directorClient director.DirectorClient,
	shootClient gardener_apis.ShootInterface,
	operatorRoleBindingConfig provisioning.OperatorRoleBinding,
	k8sClientProvider k8s.K8sClientProvider,
	configurator runtime.Configurator,
	kubeconfigProvider KubeconfigProvider) OperationQueue

func CreateProvisioningQueueWithoutRegistration

func CreateProvisioningQueueWithoutRegistration(
	timeouts ProvisioningTimeouts,
	factory dbsession.Factory,
	shootClient gardener_apis.ShootInterface,
	operatorRoleBindingConfig provisioning.OperatorRoleBinding,
	k8sClientProvider k8s.K8sClientProvider,
	kubeconfigProvider KubeconfigProvider) OperationQueue

func CreateShootUpgradeQueue

func CreateShootUpgradeQueue(
	timeouts ProvisioningTimeouts,
	factory dbsession.Factory,
	directorClient director.DirectorClient,
	shootClient gardener_apis.ShootInterface,
	operatorRoleBindingConfig provisioning.OperatorRoleBinding,
	k8sClientProvider k8s.K8sClientProvider,
	kubeconfigProvider KubeconfigProvider,
) OperationQueue

type ProvisioningTimeouts

type ProvisioningTimeouts struct {
	ClusterCreation        time.Duration `envconfig:"default=60m"`
	ClusterDomains         time.Duration `envconfig:"default=10m"`
	BindingsCreation       time.Duration `envconfig:"default=5m"`
	InstallationTriggering time.Duration `envconfig:"default=20m"`
	Installation           time.Duration `envconfig:"default=60m"`
	Upgrade                time.Duration `envconfig:"default=60m"`
	UpgradeTriggering      time.Duration `envconfig:"default=20m"`
	ShootUpgrade           time.Duration `envconfig:"default=30m"`
	ShootRefresh           time.Duration `envconfig:"default=5m"`
	AgentConfiguration     time.Duration `envconfig:"default=15m"`
	AgentConnection        time.Duration `envconfig:"default=15m"`
}

type Queue

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

func NewQueue

func NewQueue(executor Executor) *Queue

func (*Queue) Add

func (q *Queue) Add(operationId string)

func (*Queue) Run

func (q *Queue) Run(stop <-chan struct{})