controllers

package

v0.0.0-...-db85bb9 Latest Latest Go to latest Published: Dec 11, 2025 License: Apache-2.0 Imports: 35 Imported by: 0

Documentation ¶

Index ¶

Constants
type HeartbeatAgent
- func NewHeartbeatAgent(client client.Client, workerName string, externalIPaddr string, ...) *HeartbeatAgent
- func (a *HeartbeatAgent) Start(ctx context.Context) error
type ProblemEnvironmentReconciler
- func (r *ProblemEnvironmentReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
- func (r *ProblemEnvironmentReconciler) SetupWithManager(mgr ctrl.Manager) error
type SSHServer
- func NewSSHServer(client client.Client, sshAddr string, adminPassword string) *SSHServer
- func (r *SSHServer) SetupWithManager(mgr ctrl.Manager) error
- func (r *SSHServer) Start(ctx context.Context) error
type User

Constants ¶

const (
	CPU_USED_HISTORY_SIZE = 20
	MEM_USED_HISTORY_SIZE = 20
)

View Source

const ProblemEnvironmentFinalizer string = "problemenvironment.netcon.janog.gr.jp"

View Source

const StatusRefreshInterval = 5 * time.Second

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type HeartbeatAgent ¶

type HeartbeatAgent struct {
	client.Client
	// contains filtered or unexported fields
}

func NewHeartbeatAgent ¶

func NewHeartbeatAgent(client client.Client, workerName string, externalIPaddr string, externalPort uint16, heartbeatInterval time.Duration, statusUpdateInterval time.Duration) *HeartbeatAgent

func (*HeartbeatAgent) Start ¶

func (a *HeartbeatAgent) Start(ctx context.Context) error

Start implements manager.Runnable

type ProblemEnvironmentReconciler ¶

type ProblemEnvironmentReconciler struct {
	client.Client
	Scheme   *runtime.Scheme
	Recorder record.EventRecorder

	MaxConcurrentReconciles int

	// WorkerName is the name of worker where nclet places
	WorkerName string

	ProblemEnvironmentDriver drivers.ProblemEnvironmentDriver
}

ProblemEnvironmentReconciler reconciles a ProblemEnvironment object

func (*ProblemEnvironmentReconciler) Reconcile ¶

func (r *ProblemEnvironmentReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state.

func (*ProblemEnvironmentReconciler) SetupWithManager ¶

func (r *ProblemEnvironmentReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

type SSHServer ¶

type SSHServer struct {
	client.Client
	// contains filtered or unexported fields
}

func NewSSHServer ¶

func NewSSHServer(client client.Client, sshAddr string, adminPassword string) *SSHServer

func (*SSHServer) SetupWithManager ¶

func (r *SSHServer) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

func (*SSHServer) Start ¶

func (r *SSHServer) Start(ctx context.Context) error

type User ¶

type User struct {
	ProblemEnvironmentName string
	NodeName               string
	Admin                  bool
}

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
drivers

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