handlers

Documentation

Index

• func NewClusterHandler(orchestrations storage.Orchestrations, q *process.Queue, ...) *clusterHandler
• func NewClusterRetryer(orchestrations storage.Orchestrations, operations storage.Operations, ...) *clusterRetryer
• func NewKymaHandler(orchestrations storage.Orchestrations, q *process.Queue, ...) *kymaHandler
• func NewKymaRetryer(orchestrations storage.Orchestrations, operations storage.Operations, ...) *kymaRetryer
• func NewOrchestrationStatusHandler(operations storage.Operations, orchestrations storage.Orchestrations, ...) *orchestrationHandler
• func ValidateDeprecatedParameters(params orchestration.Parameters) error
• func ValidateScheduleParameter(params *orchestration.Parameters) error
• type Canceler
  • func NewCanceler(orchestrations storage.Orchestrations, logger logrus.FieldLogger) *Canceler
  • func (c *Canceler) CancelForID(orchestrationID string) error
• type Converter
  • func (c *Converter) OrchestrationListToDTO(orchestrations []internal.Orchestration, count, totalCount int) (orchestration.StatusResponseList, error)
  • func (*Converter) OrchestrationToDTO(o *internal.Orchestration, stats map[string]int) (*orchestration.StatusResponse, error)
  • func (c *Converter) UpgradeClusterOperationListToDTO(ops []internal.UpgradeClusterOperation, count, totalCount int) (orchestration.OperationResponseList, error)
  • func (c *Converter) UpgradeClusterOperationToDTO(op internal.UpgradeClusterOperation) (orchestration.OperationResponse, error)
  • func (c *Converter) UpgradeClusterOperationToDetailDTO(op internal.UpgradeClusterOperation, ...) (orchestration.OperationDetailResponse, error)
  • func (c *Converter) UpgradeKymaOperationListToDTO(ops []internal.UpgradeKymaOperation, count, totalCount int) (orchestration.OperationResponseList, error)
  • func (c *Converter) UpgradeKymaOperationToDTO(op internal.UpgradeKymaOperation) (orchestration.OperationResponse, error)
  • func (c *Converter) UpgradeKymaOperationToDetailDTO(op internal.UpgradeKymaOperation, kymaConfig *gqlschema.KymaConfigInput) (orchestration.OperationDetailResponse, error)
• type Handler
  • func NewOrchestrationHandler(db storage.BrokerStorage, kymaQueue *process.Queue, ...) Handler
• type Retryer

Functions

func NewClusterHandler

func NewClusterHandler(orchestrations storage.Orchestrations, q *process.Queue, log logrus.FieldLogger) *clusterHandler

func NewClusterRetryer

func NewClusterRetryer(orchestrations storage.Orchestrations, operations storage.Operations, q *process.Queue, logger logrus.FieldLogger) *clusterRetryer

func NewKymaHandler

func NewKymaHandler(orchestrations storage.Orchestrations, q *process.Queue, log logrus.FieldLogger) *kymaHandler

func NewKymaRetryer

func NewKymaRetryer(orchestrations storage.Orchestrations, operations storage.Operations, q *process.Queue, logger logrus.FieldLogger) *kymaRetryer

func NewOrchestrationStatusHandler

func NewOrchestrationStatusHandler(operations storage.Operations,
	orchestrations storage.Orchestrations,
	runtimeStates storage.RuntimeStates,
	kymaQueue *process.Queue,
	clusterQueue *process.Queue,
	defaultMaxPage int,
	log logrus.FieldLogger) *orchestrationHandler

NewOrchestrationStatusHandler exposes data about orchestrations and allows to manage them

func ValidateDeprecatedParameters

func ValidateDeprecatedParameters(params orchestration.Parameters) error

ValidateDeprecatedParameters cheks if `maintenanceWindow` parameter is used as schedule.

func ValidateScheduleParameter

func ValidateScheduleParameter(params *orchestration.Parameters) error

ValidateScheduleParameter cheks if the schedule parameter is valid.

Types

type Canceler

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

func NewCanceler

func NewCanceler(orchestrations storage.Orchestrations, logger logrus.FieldLogger) *Canceler

func (*Canceler) CancelForID

func (c *Canceler) CancelForID(orchestrationID string) error

CancelForID cancels orchestration by ID

type Converter

type Converter struct{}

func (*Converter) OrchestrationListToDTO

func (c *Converter) OrchestrationListToDTO(orchestrations []internal.Orchestration, count, totalCount int) (orchestration.StatusResponseList, error)

func (*Converter) OrchestrationToDTO

func (*Converter) OrchestrationToDTO(o *internal.Orchestration, stats map[string]int) (*orchestration.StatusResponse, error)

func (*Converter) UpgradeClusterOperationListToDTO

func (c *Converter) UpgradeClusterOperationListToDTO(ops []internal.UpgradeClusterOperation, count, totalCount int) (orchestration.OperationResponseList, error)

func (*Converter) UpgradeClusterOperationToDTO

func (c *Converter) UpgradeClusterOperationToDTO(op internal.UpgradeClusterOperation) (orchestration.OperationResponse, error)

func (*Converter) UpgradeClusterOperationToDetailDTO

func (c *Converter) UpgradeClusterOperationToDetailDTO(op internal.UpgradeClusterOperation, clusterConfig *gqlschema.GardenerConfigInput) (orchestration.OperationDetailResponse, error)

func (*Converter) UpgradeKymaOperationListToDTO

func (c *Converter) UpgradeKymaOperationListToDTO(ops []internal.UpgradeKymaOperation, count, totalCount int) (orchestration.OperationResponseList, error)

func (*Converter) UpgradeKymaOperationToDTO

func (c *Converter) UpgradeKymaOperationToDTO(op internal.UpgradeKymaOperation) (orchestration.OperationResponse, error)

func (*Converter) UpgradeKymaOperationToDetailDTO

func (c *Converter) UpgradeKymaOperationToDetailDTO(op internal.UpgradeKymaOperation, kymaConfig *gqlschema.KymaConfigInput) (orchestration.OperationDetailResponse, error)

type Handler

type Handler interface {
	AttachRoutes(router *mux.Router)
}

func NewOrchestrationHandler

func NewOrchestrationHandler(db storage.BrokerStorage, kymaQueue *process.Queue, clusterQueue *process.Queue, defaultMaxPage int, log logrus.FieldLogger) Handler

type Retryer

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