upstream

Documentation

Index

• func Init(ctx context.Context)
• func Start(ctx context.Context, statusChan <-chan model.Message)
• type ConfigUpdateJobHandler
  • func (ConfigUpdateJobHandler) GetAction(name string) *actionflow.Action
  • func (h *ConfigUpdateJobHandler) Logger() logr.Logger
  • func (h *ConfigUpdateJobHandler) UpdateNodeTaskStatus(jobName, nodeName string, isFinalAction bool, upmsg taskmsg.UpstreamMessage) error
• type ImagePrePullJobHandler
  • func (ImagePrePullJobHandler) GetAction(name string) *actionflow.Action
  • func (h ImagePrePullJobHandler) Logger() logr.Logger
  • func (h *ImagePrePullJobHandler) UpdateNodeTaskStatus(jobName, nodeName string, isFinalAction bool, upmsg taskmsg.UpstreamMessage) error
• type NodeUpgradeJobHandler
  • func (NodeUpgradeJobHandler) GetAction(name string) *actionflow.Action
  • func (h NodeUpgradeJobHandler) Logger() logr.Logger
  • func (h *NodeUpgradeJobHandler) UpdateNodeTaskStatus(jobName, nodeName string, isFinalAction bool, upmsg taskmsg.UpstreamMessage) error
• type UpstreamHandler

Functions

func Init

func Init(ctx context.Context)

Init registers the upstream handlers.

func Start

func Start(ctx context.Context, statusChan <-chan model.Message)

Start starts the upstream handler.

Types

type ConfigUpdateJobHandler

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

func (ConfigUpdateJobHandler) GetAction

func (ConfigUpdateJobHandler) GetAction(name string) *actionflow.Action

func (*ConfigUpdateJobHandler) Logger

func (h *ConfigUpdateJobHandler) Logger() logr.Logger

func (*ConfigUpdateJobHandler) UpdateNodeTaskStatus

func (h *ConfigUpdateJobHandler) UpdateNodeTaskStatus(
	jobName, nodeName string,
	isFinalAction bool,
	upmsg taskmsg.UpstreamMessage,
) error

type ImagePrePullJobHandler

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

func (ImagePrePullJobHandler) GetAction

func (ImagePrePullJobHandler) GetAction(name string) *actionflow.Action

func (ImagePrePullJobHandler) Logger

func (h ImagePrePullJobHandler) Logger() logr.Logger

func (*ImagePrePullJobHandler) UpdateNodeTaskStatus

func (h *ImagePrePullJobHandler) UpdateNodeTaskStatus(
	jobName, nodeName string,
	isFinalAction bool,
	upmsg taskmsg.UpstreamMessage,
) error

type NodeUpgradeJobHandler

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

func (NodeUpgradeJobHandler) GetAction

func (NodeUpgradeJobHandler) GetAction(name string) *actionflow.Action

func (NodeUpgradeJobHandler) Logger

func (h NodeUpgradeJobHandler) Logger() logr.Logger

func (*NodeUpgradeJobHandler) UpdateNodeTaskStatus

func (h *NodeUpgradeJobHandler) UpdateNodeTaskStatus(
	jobName, nodeName string,
	isFinalAction bool,
	upmsg taskmsg.UpstreamMessage,
) error

type UpstreamHandler

type UpstreamHandler interface {
	// Logger returns the upstream handler logger.
	Logger() logr.Logger

	// GetAction returns the queried action of the node task.
	GetAction(name string) *actionflow.Action

	// UpdateNodeTaskStatus updates the status of node task.
	UpdateNodeTaskStatus(jobName, nodeName string, isFinalAction bool, upmsg taskmsg.UpstreamMessage) error
}