controllers

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
)

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

const StatusRefreshInterval = 5 * time.Second

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
}