handler

Documentation

Index

• func CreatePausePatch() ([]byte, error)
• func CreateResumePatch() ([]byte, error)
• func CreateResumeTimer(deployment *app.Deployment, clients kube.Clients, namespace string, ...)
• func GetArgoRolloutRollingUpgradeFuncs() callbacks.RollingUpgradeFuncs
• func GetCronJobCreateJobFuncs() callbacks.RollingUpgradeFuncs
• func GetDaemonSetRollingUpgradeFuncs() callbacks.RollingUpgradeFuncs
• func GetDeploymentRollingUpgradeFuncs() callbacks.RollingUpgradeFuncs
• func GetJobCreateJobFuncs() callbacks.RollingUpgradeFuncs
• func GetPauseStartTime(deployment *app.Deployment) (*time.Time, error)
• func GetStatefulSetRollingUpgradeFuncs() callbacks.RollingUpgradeFuncs
• func HandleMissingTimer(deployment *app.Deployment, pauseDuration time.Duration, clients kube.Clients, ...)
• func IsPaused(deployment *app.Deployment) bool
• func IsPausedByReloader(deployment *app.Deployment) bool
• func ParsePauseDuration(pauseIntervalValue string) (time.Duration, error)
• func PauseDeployment(deployment *app.Deployment, clients kube.Clients, ...) (*app.Deployment, error)
• func PerformAction(clients kube.Clients, config common.Config, ...) error
• func ResumeDeployment(deployment *app.Deployment, namespace string, clients kube.Clients)
• type InvokeStrategyResult
• type Patch
• type ResourceCreatedHandler
  • func (r ResourceCreatedHandler) GetConfig() (common.Config, string)
  • func (r ResourceCreatedHandler) Handle() error
• type ResourceDeleteHandler
  • func (r ResourceDeleteHandler) GetConfig() (common.Config, string)
  • func (r ResourceDeleteHandler) Handle() error
• type ResourceHandler
• type ResourceUpdatedHandler
  • func (r ResourceUpdatedHandler) GetConfig() (common.Config, string)
  • func (r ResourceUpdatedHandler) Handle() error

Functions

func CreatePausePatch

func CreatePausePatch() ([]byte, error)

func CreateResumePatch

func CreateResumePatch() ([]byte, error)

func CreateResumeTimer

func CreateResumeTimer(deployment *app.Deployment, clients kube.Clients, namespace string, pauseDuration time.Duration)

CreateResumeTimer creates a timer to resume the deployment after the specified duration

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 GetDeploymentRollingUpgradeFuncs

func GetDeploymentRollingUpgradeFuncs() callbacks.RollingUpgradeFuncs

GetDeploymentRollingUpgradeFuncs returns all callback funcs for a deployment

func GetJobCreateJobFuncs

func GetJobCreateJobFuncs() callbacks.RollingUpgradeFuncs

GetDeploymentRollingUpgradeFuncs returns all callback funcs for a cronjob

func GetPauseStartTime

func GetPauseStartTime(deployment *app.Deployment) (*time.Time, error)

Returns the time, the deployment was paused by reloader, nil otherwise

func GetStatefulSetRollingUpgradeFuncs

func GetStatefulSetRollingUpgradeFuncs() callbacks.RollingUpgradeFuncs

GetStatefulSetRollingUpgradeFuncs returns all callback funcs for a statefulSet

func HandleMissingTimer

func HandleMissingTimer(deployment *app.Deployment, pauseDuration time.Duration, clients kube.Clients, namespace string)

Handles the case where missing timers for deployments that have been paused by reloader. Could occur after new leader election or reloader restart

func IsPaused

func IsPaused(deployment *app.Deployment) bool

Checks if a deployment is currently paused

func IsPausedByReloader

func IsPausedByReloader(deployment *app.Deployment) bool

Deployment paused by reloader ?

func ParsePauseDuration

func ParsePauseDuration(pauseIntervalValue string) (time.Duration, error)

ParsePauseDuration parses the pause interval value and returns a time.Duration

func PauseDeployment

func PauseDeployment(deployment *app.Deployment, clients kube.Clients, namespace, pauseIntervalValue string) (*app.Deployment, error)

Pauses a deployment for a specified duration and creates a timer to resume it after the specified duration

func PerformAction

func PerformAction(clients kube.Clients, config common.Config, upgradeFuncs callbacks.RollingUpgradeFuncs, collectors metrics.Collectors, recorder record.EventRecorder, strategy invokeStrategy) error

PerformAction invokes the deployment if there is any change in configmap or secret data

func ResumeDeployment

func ResumeDeployment(deployment *app.Deployment, namespace string, clients kube.Clients)

ResumeDeployment resumes a deployment that has been paused by reloader

Types

type InvokeStrategyResult

type InvokeStrategyResult struct {
	Result constants.Result
	Patch  *Patch
}

type Patch

type Patch struct {
	Type  patchtypes.PatchType
	Bytes []byte
}

type ResourceCreatedHandler

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

ResourceCreatedHandler contains new objects

func (ResourceCreatedHandler) GetConfig

func (r ResourceCreatedHandler) GetConfig() (common.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 ResourceDeleteHandler

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

ResourceDeleteHandler contains new objects

func (ResourceDeleteHandler) GetConfig

func (r ResourceDeleteHandler) GetConfig() (common.Config, string)

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

func (ResourceDeleteHandler) Handle

func (r ResourceDeleteHandler) Handle() error

Handle processes resources being deleted

type ResourceHandler

type ResourceHandler interface {
	Handle() error
	GetConfig() (common.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() (common.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