worker

package

v1.4.8 Latest Latest Go to latest Published: Jul 24, 2025 License: Apache-2.0 Imports: 18 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/metal-toolbox/flasher

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func RunInband(ctx context.Context, dryrun, faultInjection bool, facilityCode string, ...)
func RunOutofband(ctx context.Context, dryrun, faultInjection bool, repository store.Repository, ...)
type InbandConditionTaskHandler
- func (h *InbandConditionTaskHandler) HandleTask(ctx context.Context, genericTask *rctypes.Task[any, any], ...) error
type OobConditionTaskHandler
- func (h *OobConditionTaskHandler) HandleTask(ctx context.Context, genericTask *rctypes.Task[any, any], ...) error

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	ErrSaveTask          = errors.New("error in saveTask transition handler")
	ErrTaskTypeAssertion = errors.New("error asserting Task type")
)

Functions ¶

func RunInband ¶ added in v1.1.0

func RunInband(
	ctx context.Context,
	dryrun,
	faultInjection bool,
	facilityCode string,
	repository store.Repository,
	nc *ctrl.HTTPController,
	logger *logrus.Logger,
)

RunInband initializes the inband installer

func RunOutofband ¶ added in v1.1.0

func RunOutofband(
	ctx context.Context,
	dryrun,
	faultInjection bool,
	repository store.Repository,
	nc *ctrl.NatsController,
	logger *logrus.Logger,
)

RunOutofband initializes the Out of band Condition handler and listens for events

Types ¶

type InbandConditionTaskHandler ¶ added in v1.1.0

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

implements the controller.TaskHandler interface

func (*InbandConditionTaskHandler) HandleTask ¶ added in v1.1.0

func (h *InbandConditionTaskHandler) HandleTask(
	ctx context.Context,
	genericTask *rctypes.Task[any, any],
	publisher ctrl.Publisher,
) error

Handle implements the controller.ConditionHandler interface

type OobConditionTaskHandler ¶ added in v1.1.0

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

func (*OobConditionTaskHandler) HandleTask ¶ added in v1.1.0

func (h *OobConditionTaskHandler) HandleTask(
	ctx context.Context,
	genericTask *rctypes.Task[any, any],
	statusPublisher ctrl.Publisher,
) error

HandleTask implements the ctrl.TaskHandler interface

Source Files ¶

View all Source files

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