queue

Documentation

Index

• type DeprovisioningTimeouts
• type Executor
• type OperationQueue
  • func CreateDeprovisioningQueue(timeouts DeprovisioningTimeouts, factory dbsession.Factory, ...) OperationQueue
  • func CreateProvisioningQueue(timeouts ProvisioningTimeouts, factory dbsession.Factory, ...) OperationQueue
  • func CreateUpgradeQueue(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 {
	ClusterCleanup            time.Duration `envconfig:"default=20m"`
	ClusterDeletion           time.Duration `envconfig:"default=30m"`
	WaitingForClusterDeletion time.Duration `envconfig:"default=60m"`
}

type Executor

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

type OperationQueue

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

func CreateDeprovisioningQueue

func CreateDeprovisioningQueue(
	timeouts DeprovisioningTimeouts,
	factory dbsession.Factory,
	installationClient installation.Service,
	directorClient director.DirectorClient,
	shootClient gardener_apis.ShootInterface,
	deleteDelay time.Duration) OperationQueue

func CreateProvisioningQueue

func CreateProvisioningQueue(
	timeouts ProvisioningTimeouts,
	factory dbsession.Factory,
	installationClient installation.Service,
	configurator runtime.Configurator,
	ccClientConstructor provisioning.CompassConnectionClientConstructor,
	directorClient director.DirectorClient,
	shootClient gardener_apis.ShootInterface,
	secretsClient v1core.SecretInterface) OperationQueue

func CreateUpgradeQueue

func CreateUpgradeQueue(
	timeouts ProvisioningTimeouts,
	factory dbsession.Factory,
	directorClient director.DirectorClient,
	installationClient installation.Service) OperationQueue

type ProvisioningTimeouts

type ProvisioningTimeouts struct {
	ClusterCreation    time.Duration `envconfig:"default=60m"`
	Installation       time.Duration `envconfig:"default=60m"`
	Upgrade            time.Duration `envconfig:"default=60m"`
	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{})