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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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 ¶
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 Resources ¶
func Resources(crdResources v1.ResourceRequirements, defaultResources config.Resource, useDefault bool) v1.ResourceRequirements
Resources creates containter resources with conditional defaults values
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
Types ¶
This section is empty.
Source Files