statefulsets

package
v0.0.0-...-435c516 Latest Latest
Warning

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

Go to latest
Published: Aug 8, 2023 License: AGPL-3.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

View Source
const CfgVol = "cfg-vol"

CfgVol is the name of the configuration volume we will use

Variables

View Source
var CfgVolumeMount = corev1.VolumeMount{
	Name:      CfgVol,
	MountPath: miniov2.CfgPath,
}

CfgVolumeMount is the volume mount used by `minio`, `sidecar` and `validate-arguments` containers

View Source
var TmpCfgVolumeMount = corev1.VolumeMount{
	Name:      "configuration",
	MountPath: miniov2.TmpPath + "/minio-config",
}

TmpCfgVolumeMount is the temporary location

Functions

func ContainerMatchLabels

func ContainerMatchLabels(t *miniov2.Tenant, pool *miniov2.Pool) *metav1.LabelSelector

ContainerMatchLabels Returns the labels that match the Pods in the statefulset

func GetContainerArgs

func GetContainerArgs(t *miniov2.Tenant, hostsTemplate string) []string

GetContainerArgs returns the arguments that the MinIO container receives

func KESEnvironmentVars

func KESEnvironmentVars(t *miniov2.Tenant) []corev1.EnvVar

KESEnvironmentVars returns the KES environment variables set in configuration.

func KESMetadata

func KESMetadata(t *miniov2.Tenant) metav1.ObjectMeta

KESMetadata Returns the KES pods metadata set in configuration. If a user specifies metadata in the spec we return that metadata.

func KESSelector

func KESSelector(t *miniov2.Tenant) *metav1.LabelSelector

KESSelector Returns the KES pods selector set in configuration.

func KESServerContainer

func KESServerContainer(t *miniov2.Tenant) corev1.Container

KESServerContainer returns the KES container for a KES StatefulSet.

func KESVolumeMounts

func KESVolumeMounts(t *miniov2.Tenant) (volumeMounts []corev1.VolumeMount)

KESVolumeMounts builds the volume mounts for MinIO container.

func NewForKES

func NewForKES(t *miniov2.Tenant, serviceName string) *appsv1.StatefulSet

NewForKES creates a new KES StatefulSet for the given Cluster.

func NewPool

func NewPool(args *NewPoolArgs) *appsv1.StatefulSet

NewPool creates a new StatefulSet for the given Cluster.

func PodMetadata

func PodMetadata(t *miniov2.Tenant, pool *miniov2.Pool) metav1.ObjectMeta

PodMetadata Returns the MinIO pods metadata set in configuration. If a user specifies metadata in the spec we return that metadata.

Types

type NewPoolArgs

type NewPoolArgs struct {
	Tenant          *miniov2.Tenant
	SkipEnvVars     map[string][]byte
	Pool            *miniov2.Pool
	PoolStatus      *miniov2.PoolStatus
	ServiceName     string
	HostsTemplate   string
	OperatorVersion string
	OperatorCATLS   bool
	OperatorImage   string
}

NewPoolArgs arguments used to create a new pool

Jump to

Keyboard shortcuts

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