manager

package

v1.1.0 Latest Latest Go to latest Published: Mar 17, 2026 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/NVIDIA/ncx-infra-controller-rest

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
type Config
- func (c *Config) Build(ctx context.Context) (executor.Executor, error)
- func (c *Config) Validate() error
type Manager

Constants ¶

View Source

const (
	WorkflowQueue = "rla-tasks"
)

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Config ¶

type Config struct {
	ClientConf    temporal.Config
	WorkerOptions map[string]worker.Options

	// ComponentManagerRegistry is the registry containing initialized component managers.
	ComponentManagerRegistry *componentmanager.Registry
}

func (*Config) Build ¶

func (c *Config) Build(ctx context.Context) (executor.Executor, error)

func (*Config) Validate ¶

func (c *Config) Validate() error

type Manager ¶

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

func (*Manager) BringUp ¶

func (m *Manager) BringUp(
	ctx context.Context,
	req *task.ExecutionRequest,
	info operations.BringUpTaskInfo,
) (*task.ExecutionResponse, error)

func (*Manager) CheckStatus ¶

func (m *Manager) CheckStatus(
	ctx context.Context,
	encodedExecutionID string,
) (taskcommon.TaskStatus, error)

func (*Manager) FirmwareControl ¶

func (m *Manager) FirmwareControl(
	ctx context.Context,
	req *task.ExecutionRequest,
	info operations.FirmwareControlTaskInfo,
) (*task.ExecutionResponse, error)

func (*Manager) InjectExpectation ¶

func (m *Manager) InjectExpectation(
	ctx context.Context,
	req *task.ExecutionRequest,
	info operations.InjectExpectationTaskInfo,
) (*task.ExecutionResponse, error)

func (*Manager) PowerControl ¶

func (m *Manager) PowerControl(
	ctx context.Context,
	req *task.ExecutionRequest,
	info operations.PowerControlTaskInfo,
) (*task.ExecutionResponse, error)

func (*Manager) Start ¶

func (m *Manager) Start(ctx context.Context) error

func (*Manager) Stop ¶

func (m *Manager) Stop(ctx context.Context) error

func (*Manager) TerminateTask ¶

func (m *Manager) TerminateTask(
	ctx context.Context,
	encodedExecutionID string,
	reason string,
) error

TerminateTask terminates the Temporal workflow backing the given execution ID.

func (*Manager) Type ¶

func (m *Manager) Type() taskcommon.ExecutorType

Source Files ¶

View all Source files

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