statefulsets

Documentation

Index

• Constants
• Variables
• func ContainerMatchLabels(t *miniov2.Tenant, pool *miniov2.Pool) *metav1.LabelSelector
• func GetContainerArgs(t *miniov2.Tenant, hostsTemplate string) []string
• func KESEnvironmentVars(t *miniov2.Tenant) []corev1.EnvVar
• func KESMetadata(t *miniov2.Tenant) metav1.ObjectMeta
• func KESSelector(t *miniov2.Tenant) *metav1.LabelSelector
• func KESServerContainer(t *miniov2.Tenant) corev1.Container
• func KESVolumeMounts(t *miniov2.Tenant) (volumeMounts []corev1.VolumeMount)
• func NewForKES(t *miniov2.Tenant, serviceName string) *appsv1.StatefulSet
• func NewPool(args *NewPoolArgs) *appsv1.StatefulSet
• func PodMetadata(t *miniov2.Tenant, pool *miniov2.Pool) metav1.ObjectMeta
• type NewPoolArgs

Constants

const CfgVol = "cfg-vol"

CfgVol is the name of the configuration volume we will use

const (

	// ReclaimStorageLabel - pvc with this label and the value is `true` means when tenant is being deleted the pvc will be deleted.
	ReclaimStorageLabel = "reclaimStorage"
)

Variables

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

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

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