builder

package
v1.0.5 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 30, 2026 License: Apache-2.0 Imports: 33 Imported by: 0

Documentation

Index

Constants

View Source
const (
	JwtHs256KeyFile = "jwt_hs256.key"
)
View Source
const (
	LoginPort = 22
)
View Source
const (
	SlurmctldPort = 6817
)
View Source
const (
	SlurmdPort = 6818
)
View Source
const (
	SlurmdbdPort = 6819
)
View Source
const (
	SlurmrestdPort = 6820
)

Variables

This section is empty.

Functions

func GetSlurmNodeSetName

func GetSlurmNodeSetName(nodeset *slinkyv1beta1.NodeSet) string

GetSlurmNodeSetName returns the Slurm NodeSet name.

Types

type Builder

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

func New

func New(c client.Client) *Builder

func (*Builder) BuildAccounting

func (b *Builder) BuildAccounting(accounting *slinkyv1beta1.Accounting) (*appsv1.StatefulSet, error)

func (*Builder) BuildAccountingConfig

func (b *Builder) BuildAccountingConfig(accounting *slinkyv1beta1.Accounting) (*corev1.Secret, error)

func (*Builder) BuildAccountingService

func (b *Builder) BuildAccountingService(accounting *slinkyv1beta1.Accounting) (*corev1.Service, error)

func (*Builder) BuildClusterWorkerPodDisruptionBudget

func (b *Builder) BuildClusterWorkerPodDisruptionBudget(nodeset *slinkyv1beta1.NodeSet) (*policyv1.PodDisruptionBudget, error)

BuildClusterWorkerPodDisruptionBudget creates a single PodDisruptionBudget for ALL worker NodeSets in the same Slurm cluster The PodDisruptionBudget name is derived from the Slurm cluster name to support hybrid deployments

func (*Builder) BuildClusterWorkerService

func (b *Builder) BuildClusterWorkerService(nodeset *slinkyv1beta1.NodeSet) (*corev1.Service, error)

BuildClusterWorkerService creates a single headless service for ALL worker NodeSets in the same Slurm cluster

func (*Builder) BuildConfigMap

func (b *Builder) BuildConfigMap(opts ConfigMapOpts, owner metav1.Object) (*corev1.ConfigMap, error)

func (*Builder) BuildContainer

func (b *Builder) BuildContainer(opts ContainerOpts) corev1.Container

func (*Builder) BuildController

func (b *Builder) BuildController(controller *slinkyv1beta1.Controller) (*appsv1.StatefulSet, error)

func (*Builder) BuildControllerConfig

func (b *Builder) BuildControllerConfig(controller *slinkyv1beta1.Controller) (*corev1.ConfigMap, error)

func (*Builder) BuildControllerConfigExternal

func (b *Builder) BuildControllerConfigExternal(controller *slinkyv1beta1.Controller) (*corev1.ConfigMap, error)

BuildControllerConfigExternal returns a minimal slurm.conf for slurmrestd (lacks configless).

func (*Builder) BuildControllerService

func (b *Builder) BuildControllerService(controller *slinkyv1beta1.Controller) (*corev1.Service, error)

func (*Builder) BuildControllerServiceMonitor

func (b *Builder) BuildControllerServiceMonitor(controller *slinkyv1beta1.Controller) (*monitoringv1.ServiceMonitor, error)

func (*Builder) BuildLogin

func (b *Builder) BuildLogin(loginset *slinkyv1beta1.LoginSet) (*appsv1.Deployment, error)

func (*Builder) BuildLoginService

func (b *Builder) BuildLoginService(loginset *slinkyv1beta1.LoginSet) (*corev1.Service, error)

func (*Builder) BuildLoginSshConfig

func (b *Builder) BuildLoginSshConfig(loginset *slinkyv1beta1.LoginSet) (*corev1.ConfigMap, error)

func (*Builder) BuildLoginSshHostKeys

func (b *Builder) BuildLoginSshHostKeys(loginset *slinkyv1beta1.LoginSet) (*corev1.Secret, error)

func (*Builder) BuildPodDisruptionBudget

func (b *Builder) BuildPodDisruptionBudget(opts PodDisruptionBudgetOpts, owner metav1.Object) (*policyv1.PodDisruptionBudget, error)

func (*Builder) BuildRestapi

func (b *Builder) BuildRestapi(restapi *slinkyv1beta1.RestApi) (*appsv1.Deployment, error)

func (*Builder) BuildRestapiService

func (b *Builder) BuildRestapiService(restapi *slinkyv1beta1.RestApi) (*corev1.Service, error)

func (*Builder) BuildSecret

func (b *Builder) BuildSecret(opts SecretOpts, owner metav1.Object) (*corev1.Secret, error)

func (*Builder) BuildService

func (b *Builder) BuildService(opts ServiceOpts, owner metav1.Object) (*corev1.Service, error)

func (*Builder) BuildServiceMonitor

func (b *Builder) BuildServiceMonitor(opts ServiceMonitorOpts, owner metav1.Object) (*monitoringv1.ServiceMonitor, error)

func (*Builder) BuildTokenSecret

func (b *Builder) BuildTokenSecret(token *slinkyv1beta1.Token) (*corev1.Secret, error)

func (*Builder) BuildWorkerPodTemplate

func (b *Builder) BuildWorkerPodTemplate(nodeset *slinkyv1beta1.NodeSet, controller *slinkyv1beta1.Controller) corev1.PodTemplateSpec

type ConfigMapOpts

type ConfigMapOpts struct {
	Key        types.NamespacedName
	Metadata   slinkyv1beta1.Metadata
	Data       map[string]string
	BinaryData map[string][]byte
	Immutable  bool
}

type ContainerOpts

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

type PodDisruptionBudgetOpts

type PodDisruptionBudgetOpts struct {
	Key      types.NamespacedName
	Metadata slinkyv1beta1.Metadata
	policyv1.PodDisruptionBudgetSpec
}

type PodTemplateOpts

type PodTemplateOpts struct {
	Key      types.NamespacedName
	Metadata slinkyv1beta1.Metadata
	// contains filtered or unexported fields
}

type SecretOpts

type SecretOpts struct {
	Key        types.NamespacedName
	Metadata   slinkyv1beta1.Metadata
	Data       map[string][]byte
	StringData map[string]string
	Immutable  bool
}

type ServiceMonitorOpts

type ServiceMonitorOpts struct {
	Key      types.NamespacedName
	Metadata slinkyv1beta1.Metadata
	// contains filtered or unexported fields
}

type ServiceOpts

type ServiceOpts struct {
	Key      types.NamespacedName
	Metadata slinkyv1beta1.Metadata
	corev1.ServiceSpec
	Selector map[string]string
	Headless bool
}

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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