node

Documentation

Index

• type Manager
  • func NewManager(logProcessor hephaestus.LogProcessingService, ...) *Manager
  • func (m *Manager) CreateSystemNode(ctx context.Context, config *hephaestus.SystemConfiguration) (*hephaestus.SystemNode, error)
  • func (m *Manager) DeleteSystemNode(ctx context.Context, nodeID string) error
  • func (m *Manager) GetSystemNode(ctx context.Context, nodeID string) (*hephaestus.SystemNode, error)
  • func (m *Manager) UpdateNodeOperationalStatus(ctx context.Context, nodeID string, status hephaestus.NodeStatus) error

Types

type Manager

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

Manager implements the NodeLifecycleManager interface

func NewManager

func NewManager(
	logProcessor hephaestus.LogProcessingService,
	modelService hephaestus.ModelServiceProvider,
	remoteRepoService hephaestus.RemoteRepositoryService,
	metricsCollector hephaestus.MetricsCollectionService,
) *Manager

NewManager creates a new instance of the node manager

func (*Manager) CreateSystemNode

func (m *Manager) CreateSystemNode(ctx context.Context, config *hephaestus.SystemConfiguration) (*hephaestus.SystemNode, error)

CreateSystemNode creates a new node with the provided configuration

func (*Manager) DeleteSystemNode

func (m *Manager) DeleteSystemNode(ctx context.Context, nodeID string) error

DeleteSystemNode removes a node from the system

func (*Manager) GetSystemNode

func (m *Manager) GetSystemNode(ctx context.Context, nodeID string) (*hephaestus.SystemNode, error)

GetSystemNode retrieves a node by its identifier

func (*Manager) UpdateNodeOperationalStatus

func (m *Manager) UpdateNodeOperationalStatus(ctx context.Context, nodeID string, status hephaestus.NodeStatus) error

UpdateNodeOperationalStatus updates the operational status of a node