handlers

Documentation

Index

• func NewClusterHandler(orchestrations storage.Orchestrations, q *process.Queue, ...) *clusterHandler
• func NewKymaHandler(orchestrations storage.Orchestrations, q *process.Queue, ...) *kymaHandler
• func NewOrchestrationStatusHandler(operations storage.Operations, orchestrations storage.Orchestrations, ...) *orchestrationHandler
• 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

Functions

func NewClusterHandler

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

func NewKymaHandler

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

func NewOrchestrationStatusHandler

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

NewOrchestrationStatusHandler exposes data about orchestrations and allows to manage them

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