build

Documentation

Index

• func AddExtraArgsOverrideDefaults(args []string, extraArgs map[string]string, dashes string) []string
• func AddStrictSecuritySettingsToContainers(containers []v1.Container, enableStrictSecurity bool) []v1.Container
• func AddStrictSecuritySettingsToPod(p *v1.PodSecurityContext, enableStrictSecurity bool) *v1.PodSecurityContext
• func AdditionalServiceFromDefault(defaultSvc *v1.Service, svcSpec *victoriametricsv1beta1.AdditionalServiceSpec) *v1.Service
• func AddsPortProbesToConfigReloaderContainer(crContainer *v1.Container, c *config.BaseOperatorConf)
• func AppendArgsForInsertPorts(args []string, ip *victoriametricsv1beta1.InsertPorts) []string
• func AppendInsertPorts(ports []v1.ContainerPort, ip *victoriametricsv1beta1.InsertPorts) []v1.ContainerPort
• func AppendInsertPortsToService(ip *victoriametricsv1beta1.InsertPorts, svc *v1.Service)
• func FormatContainerImage(globalRepo string, containerImage string) string
• func HPA(targetRef v2beta2.CrossVersionObjectReference, ...) client.Object
• func PodDisruptionBudget(cr svcBuilderArgs, ...) *policyv1.PodDisruptionBudget
• func Probe(container v1.Container, cr probeCRD) v1.Container
• func Resources(crdResources v1.ResourceRequirements, defaultResources config.Resource, ...) v1.ResourceRequirements
• func Service(cr svcBuilderArgs, defaultPort string, setOptions func(svc *v1.Service)) *v1.Service
• func ServiceAccount(cr objectForServiceAccountBuilder) *v1.ServiceAccount
• func VMBackupManager(ctx context.Context, cr *victoriametricsv1beta1.VMBackup, ...) (*v1.Container, error)
• func VMRestore(cr *victoriametricsv1beta1.VMBackup, c *config.BaseOperatorConf, ...) (*v1.Container, error)
• func VMServiceScrapeForServiceWithSpec(service *v1.Service, ...) *victoriametricsv1beta1.VMServiceScrape

Functions

func AddExtraArgsOverrideDefaults

func AddExtraArgsOverrideDefaults(args []string, extraArgs map[string]string, dashes string) []string

AddExtraArgsOverrideDefaults adds extraArgs for given source args it trims in-place args if it was set via extraArgs no need to check for extraEnvs, it has priority over args at VictoriaMetrics apps dashes is either "-" or "--", depending on the process. altermanager needs two dashes.

func AddStrictSecuritySettingsToContainers

func AddStrictSecuritySettingsToContainers(containers []v1.Container, enableStrictSecurity bool) []v1.Container

AddStrictSecuritySettingsToContainers conditionally adds Security settings to given containers

func AddStrictSecuritySettingsToPod

func AddStrictSecuritySettingsToPod(p *v1.PodSecurityContext, enableStrictSecurity bool) *v1.PodSecurityContext

AddStrictSecuritySettingsToPod conditionally creates security context for pod or returns predefined one

func AdditionalServiceFromDefault

func AdditionalServiceFromDefault(defaultSvc *v1.Service, svcSpec *victoriametricsv1beta1.AdditionalServiceSpec) *v1.Service

AdditionalServiceFromDefault builds service from given exist service and overrides params if needed

func AddsPortProbesToConfigReloaderContainer

func AddsPortProbesToConfigReloaderContainer(crContainer *v1.Container, c *config.BaseOperatorConf)

AddsPortProbesToConfigReloaderContainer conditionally adds readiness and liveness probes to the custom config-reloader image exposes reloader-http port for container

func AppendArgsForInsertPorts

func AppendArgsForInsertPorts(args []string, ip *victoriametricsv1beta1.InsertPorts) []string

AppendArgsForInsertPorts conditionally appends insert ports as flags to the given args

func AppendInsertPorts

func AppendInsertPorts(ports []v1.ContainerPort, ip *victoriametricsv1beta1.InsertPorts) []v1.ContainerPort

AppendInsertPorts conditionally adds ingestPorts to the given ports slice

func AppendInsertPortsToService

func AppendInsertPortsToService(ip *victoriametricsv1beta1.InsertPorts, svc *v1.Service)

AppendInsertPortsToService conditionally appends insert ports to the given service definition

func FormatContainerImage

func FormatContainerImage(globalRepo string, containerImage string) string

FormatContainerImage returns container image with registry prefix if needed.

func HPA

func HPA(targetRef v2beta2.CrossVersionObjectReference, spec *victoriametricsv1beta1.EmbeddedHPA, or []metav1.OwnerReference, lbls map[string]string, namespace string) client.Object

HPA creates HorizontalPodAutoscaler object

func PodDisruptionBudget

func PodDisruptionBudget(cr svcBuilderArgs, spec *victoriametricsv1beta1.EmbeddedPodDisruptionBudgetSpec) *policyv1.PodDisruptionBudget

PodDisruptionBudget creates object for given CRD

func Probe

func Probe(container v1.Container, cr probeCRD) v1.Container

Probe builds probe for container with possible custom values with

func Resources

func Resources(crdResources v1.ResourceRequirements, defaultResources config.Resource, useDefault bool) v1.ResourceRequirements

Resources creates containter resources with conditional defaults values

func Service

func Service(cr svcBuilderArgs, defaultPort string, setOptions func(svc *v1.Service)) *v1.Service

Service builds service for the given args and applies optional callback for it

func ServiceAccount

func ServiceAccount(cr objectForServiceAccountBuilder) *v1.ServiceAccount

ServiceAccount builds service account for CRD

func VMBackupManager

func VMBackupManager(
	ctx context.Context,
	cr *victoriametricsv1beta1.VMBackup,
	c *config.BaseOperatorConf,
	port string,
	storagePath, dataVolumeName string,
	extraArgs map[string]string,
	isCluster bool,
	license *victoriametricsv1beta1.License,
) (*v1.Container, error)

VMBackupManager conditionally creates vmbackupmanager container

func VMRestore

func VMRestore(
	cr *victoriametricsv1beta1.VMBackup,
	c *config.BaseOperatorConf,
	storagePath, dataVolumeName string,
) (*v1.Container, error)

VMRestore conditionally creates vmrestore container

func VMServiceScrapeForServiceWithSpec

func VMServiceScrapeForServiceWithSpec(service *v1.Service, serviceScrapeSpec *victoriametricsv1beta1.VMServiceScrapeSpec, metricPath string, filterPortNames ...string) *victoriametricsv1beta1.VMServiceScrape

VMServiceScrapeForServiceWithSpec build VMServiceScrape for given service with optional spec optionally could filter out ports from service