upstream

package
v1.23.0-cx Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 24, 2026 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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) 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) 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
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL