adjuster

package
v0.0.0-...-797dec0 Latest Latest
Warning

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

Go to latest
Published: Aug 11, 2025 License: Apache-2.0 Imports: 25 Imported by: 0

Documentation

Index

Constants

View Source
const (
	// Component names
	DiagnosticFluentdName = "diagnostics-fluentd"
	VSystemVrepStsName    = "vsystem-vrep"

	// Volume and mount names
	VolumeName              = "exports-mask"
	FluentdDockerVolumeName = "varlibdockercontainers"

	// Annotation keys
	AnnotationKey = "openshift.io/node-selector"

	// Namespace names
	DataHubSystemNamespace = "datahub-system"

	// API Group and version constants
	DataHubAPIGroup   = "installers.datahub.sap.com"
	DataHubAPIVersion = "v1alpha1"
	DataHubKind       = "DataHub"
	VoraClusterKind   = "VoraCluster"

	// Default values
	DefaultRequeueInterval    = 1 * time.Minute
	DefaultGracePeriodSeconds = int64(1)

	// Security context constants
	DefaultPrivileged = true

	// Label keys
	ControllerRevisionHashLabel = "controller-revision-hash"
)

Variables

View Source
var (
	SDIServiceAccounts = map[string][]string{
		"3.2": {
			"diagnostics-fluentd",
			"elasticsearch",
			"mlf-deployment-api",
			"pipeline-modeler",
			"storagegateway",
			"vsystem",
		},
		"3.3": {
			"diagnostics-fluentd",
			"elasticsearch",
			"mlf-deployment-api",
			"pipeline-modeler",
			"storagegateway",
			"vsystem",
			"backup-agent",
		},
	}
)

Service account names by SDI version

Functions

This section is empty.

Types

type Actioner

type Actioner interface {
	AdjustNodes(a *Adjuster, ctx context.Context) error
	AdjustSDINetwork(a *Adjuster, ctx context.Context) error
	AdjustSLCBNetwork(a *Adjuster, ctx context.Context) error
	AdjustStorage(a *Adjuster, ctx context.Context) error
	AdjustSDIConfig(a *Adjuster, ctx context.Context) error
}

type Adjuster

type Adjuster struct {
	Name      string
	Namespace string
	Client    client.Client
	Scheme    *runtime.Scheme
	// contains filtered or unexported fields
}

func New

func New(name, namespace string, c client.Client, scheme *runtime.Scheme, logger logr.Logger) *Adjuster

New creates a new Adjuster with the provided parameters.

func (*Adjuster) Adjust

func (a *Adjuster) Adjust(ac Actioner, ctx context.Context) error

Adjust performs a series of adjustments using the provided Actioner.

func (*Adjuster) AdjustNamespaceAnnotation

func (a *Adjuster) AdjustNamespaceAnnotation(ns, nodeSelector string, ctx context.Context) error

func (*Adjuster) AdjustRoute

func (a *Adjuster) AdjustRoute(ns, name string, managementState sdiv1alpha1.RouteManagementState, routeFile, svcName string, obs *sdiv1alpha1.SDIObserver, ctx context.Context, handleCA bool) error

AdjustRoute manages the route based on its management state.

func (*Adjuster) AdjustSDIDiagnosticsFluentdDaemonsetContainerPrivilege

func (a *Adjuster) AdjustSDIDiagnosticsFluentdDaemonsetContainerPrivilege(ns string, obs *sdiv1alpha1.SDIObserver, ctx context.Context) error

func (*Adjuster) AdjustSDINodes

func (a *Adjuster) AdjustSDINodes(obs *sdiv1alpha1.SDIObserver, ctx context.Context) error

func (*Adjuster) AdjustSDIRbac

func (a *Adjuster) AdjustSDIRbac(ns string, _ *sdiv1alpha1.SDIObserver, ctx context.Context) error

func (*Adjuster) AdjustSDIVSystemVrepStatefulSets

func (a *Adjuster) AdjustSDIVSystemVrepStatefulSets(ns string, obs *sdiv1alpha1.SDIObserver, ctx context.Context) error

func (*Adjuster) AdjustSDIVsystemRoute

func (a *Adjuster) AdjustSDIVsystemRoute(ns string, obs *sdiv1alpha1.SDIObserver, ctx context.Context) error

AdjustSDIVsystemRoute adjusts the VSystem route.

func (*Adjuster) AdjustSLCBRoute

func (a *Adjuster) AdjustSLCBRoute(ns string, obs *sdiv1alpha1.SDIObserver, ctx context.Context) error

AdjustSLCBRoute adjusts the SLCB route.

func (*Adjuster) Logger

func (a *Adjuster) Logger() logr.Logger

Logger returns the logger instance associated with the Adjuster.

type KubeletConfigData

type KubeletConfigData struct {
	PodPidsLimit int32 `json:"podPidsLimit"`
}

Define a struct to unmarshal the Kubelet configuration from the RawExtension

Jump to

Keyboard shortcuts

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