handler

Documentation

Index

• func GetArgoRolloutRollingUpgradeFuncs() callbacks.RollingUpgradeFuncs
• func GetCronJobCreateJobFuncs() callbacks.RollingUpgradeFuncs
• func GetDaemonSetRollingUpgradeFuncs() callbacks.RollingUpgradeFuncs
• func GetDeploymentConfigRollingUpgradeFuncs() callbacks.RollingUpgradeFuncs
• func GetDeploymentRollingUpgradeFuncs() callbacks.RollingUpgradeFuncs
• func GetStatefulSetRollingUpgradeFuncs() callbacks.RollingUpgradeFuncs
• func PerformRollingUpgrade(clients kube.Clients, config util.Config, ...) error
• type ResourceCreatedHandler
  • func (r ResourceCreatedHandler) GetConfig() (util.Config, string)
  • func (r ResourceCreatedHandler) Handle() error
• type ResourceHandler
• type ResourceUpdatedHandler
  • func (r ResourceUpdatedHandler) GetConfig() (util.Config, string)
  • func (r ResourceUpdatedHandler) Handle() error

Functions

func GetArgoRolloutRollingUpgradeFuncs

func GetArgoRolloutRollingUpgradeFuncs() callbacks.RollingUpgradeFuncs

GetArgoRolloutRollingUpgradeFuncs returns all callback funcs for a rollout

func GetCronJobCreateJobFuncs

func GetCronJobCreateJobFuncs() callbacks.RollingUpgradeFuncs

GetDeploymentRollingUpgradeFuncs returns all callback funcs for a cronjob

func GetDaemonSetRollingUpgradeFuncs

func GetDaemonSetRollingUpgradeFuncs() callbacks.RollingUpgradeFuncs

GetDaemonSetRollingUpgradeFuncs returns all callback funcs for a daemonset

func GetDeploymentConfigRollingUpgradeFuncs

func GetDeploymentConfigRollingUpgradeFuncs() callbacks.RollingUpgradeFuncs

GetDeploymentConfigRollingUpgradeFuncs returns all callback funcs for a deploymentConfig

func GetDeploymentRollingUpgradeFuncs

func GetDeploymentRollingUpgradeFuncs() callbacks.RollingUpgradeFuncs

GetDeploymentRollingUpgradeFuncs returns all callback funcs for a deployment

func GetStatefulSetRollingUpgradeFuncs

func GetStatefulSetRollingUpgradeFuncs() callbacks.RollingUpgradeFuncs

GetStatefulSetRollingUpgradeFuncs returns all callback funcs for a statefulSet

func PerformRollingUpgrade

func PerformRollingUpgrade(clients kube.Clients, config util.Config, upgradeFuncs callbacks.RollingUpgradeFuncs, collectors metrics.Collectors, recorder record.EventRecorder) error

PerformRollingUpgrade upgrades the deployment if there is any change in configmap or secret data

Types

type ResourceCreatedHandler

type ResourceCreatedHandler struct {
	Resource   interface{}
	Collectors metrics.Collectors
	Recorder   record.EventRecorder
}

ResourceCreatedHandler contains new objects

func (ResourceCreatedHandler) GetConfig

func (r ResourceCreatedHandler) GetConfig() (util.Config, string)

GetConfig gets configurations containing SHA, annotations, namespace and resource name

func (ResourceCreatedHandler) Handle

func (r ResourceCreatedHandler) Handle() error

Handle processes the newly created resource

type ResourceHandler

type ResourceHandler interface {
	Handle() error
	GetConfig() (util.Config, string)
}

ResourceHandler handles the creation and update of resources

type ResourceUpdatedHandler

type ResourceUpdatedHandler struct {
	Resource    interface{}
	OldResource interface{}
	Collectors  metrics.Collectors
	Recorder    record.EventRecorder
}

ResourceUpdatedHandler contains updated objects

func (ResourceUpdatedHandler) GetConfig

func (r ResourceUpdatedHandler) GetConfig() (util.Config, string)

GetConfig gets configurations containing SHA, annotations, namespace and resource name

func (ResourceUpdatedHandler) Handle

func (r ResourceUpdatedHandler) Handle() error

Handle processes the updated resource