factory

package
v0.23.1 Latest Latest
Warning

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

 Go to latest Published: Feb 10, 2022 License: Apache-2.0 Imports: 44 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	SecretsDir          = "/etc/vm/secrets"
	ConfigMapsDir       = "/etc/vm/configs"
	RelabelingConfigDir = "/etc/vm/relabeling"
)

Variables

This section is empty.

Functions

func BuildNotifiersArgs added in v0.6.0 

func BuildNotifiersArgs(cr *victoriametricsv1beta1.VMAlert, ntBasicAuth map[string]BasicAuthCredentials) []string

func BuildRemoteWriteSettings added in v0.6.0 

func BuildRemoteWriteSettings(cr *victoriametricsv1beta1.VMAgent) []string

func BuildRemoteWrites 

func BuildRemoteWrites(cr *victoriametricsv1beta1.VMAgent, ssCache *scrapesSecretsCache) []string

func CreateOrUpdateAlertManager 

func CreateOrUpdateAlertManager(ctx context.Context, cr *victoriametricsv1beta1.VMAlertmanager, rclient client.Client, c *config.BaseOperatorConf) error

func CreateOrUpdateAlertManagerService 

func CreateOrUpdateAlertManagerService(ctx context.Context, cr *victoriametricsv1beta1.VMAlertmanager, rclient client.Client) (*v1.Service, error)

func CreateOrUpdateConfigurationSecret 

func CreateOrUpdateConfigurationSecret(ctx context.Context, cr *victoriametricsv1beta1.VMAgent, rclient client.Client, c *config.BaseOperatorConf) error

func CreateOrUpdatePodDisruptionBudget added in v0.12.0 

func CreateOrUpdatePodDisruptionBudget(ctx context.Context, rclient client.Client, cr svcBuilderArgs, kind string, epdb *victoriametricsv1beta1.EmbeddedPodDisruptionBudgetSpec) error

func CreateOrUpdatePodDisruptionBudgetForAlertManager added in v0.12.0 

func CreateOrUpdatePodDisruptionBudgetForAlertManager(ctx context.Context, cr *victoriametricsv1beta1.VMAlertmanager, rclient client.Client) error

func CreateOrUpdatePodDisruptionBudgetForVMAlert added in v0.12.0 

func CreateOrUpdatePodDisruptionBudgetForVMAlert(ctx context.Context, cr *victoriametricsv1beta1.VMAlert, rclient client.Client) error

func CreateOrUpdatePodDisruptionBudgetForVMInsert added in v0.12.0 

func CreateOrUpdatePodDisruptionBudgetForVMInsert(ctx context.Context, cr *v1beta1.VMCluster, rclient client.Client) error

func CreateOrUpdatePodDisruptionBudgetForVMSelect added in v0.12.0 

func CreateOrUpdatePodDisruptionBudgetForVMSelect(ctx context.Context, cr *v1beta1.VMCluster, rclient client.Client) error

func CreateOrUpdatePodDisruptionBudgetForVMStorage added in v0.12.0 

func CreateOrUpdatePodDisruptionBudgetForVMStorage(ctx context.Context, cr *v1beta1.VMCluster, rclient client.Client) error

func CreateOrUpdateRelabelConfigsAssets added in v0.14.0 

func CreateOrUpdateRelabelConfigsAssets(ctx context.Context, cr *victoriametricsv1beta1.VMAgent, rclient client.Client) error

CreateOrUpdateRelabelConfigsAssets builds relabeling configs for vmagent at separate configmap, serialized as yaml

func CreateOrUpdateRuleConfigMaps 

func CreateOrUpdateRuleConfigMaps(ctx context.Context, cr *victoriametricsv1beta1.VMAlert, rclient client.Client) ([]string, error)

func CreateOrUpdateTlsAssets 

func CreateOrUpdateTlsAssets(ctx context.Context, cr *victoriametricsv1beta1.VMAgent, rclient client.Client) error

func CreateOrUpdateTlsAssetsForVMAlert added in v0.1.0 

func CreateOrUpdateTlsAssetsForVMAlert(ctx context.Context, cr *victoriametricsv1beta1.VMAlert, rclient client.Client) error

func CreateOrUpdateVMAgent 

func CreateOrUpdateVMAgent(ctx context.Context, cr *victoriametricsv1beta1.VMAgent, rclient client.Client, c *config.BaseOperatorConf) (reconcile.Result, error)

func CreateOrUpdateVMAgentService 

func CreateOrUpdateVMAgentService(ctx context.Context, cr *victoriametricsv1beta1.VMAgent, rclient client.Client, c *config.BaseOperatorConf) (*corev1.Service, error)

func CreateOrUpdateVMAlert 

func CreateOrUpdateVMAlert(ctx context.Context, cr *victoriametricsv1beta1.VMAlert, rclient client.Client, c *config.BaseOperatorConf, cmNames []string) (reconcile.Result, error)

func CreateOrUpdateVMAlertService 

func CreateOrUpdateVMAlertService(ctx context.Context, cr *victoriametricsv1beta1.VMAlert, rclient client.Client, c *config.BaseOperatorConf) (*corev1.Service, error)

func CreateOrUpdateVMAuth added in v0.15.0 

func CreateOrUpdateVMAuth(ctx context.Context, cr *victoriametricsv1beta1.VMAuth, rclient client.Client, c *config.BaseOperatorConf) error

CreateOrUpdateVMAuth - handles VMAuth deployment reconciliation.

func CreateOrUpdateVMAuthIngress added in v0.15.0 

func CreateOrUpdateVMAuthIngress(ctx context.Context, rclient client.Client, cr *victoriametricsv1beta1.VMAuth) error

CreateOrUpdateVMAuthIngress handles ingress for vmauth.

func CreateOrUpdateVMAuthService added in v0.15.0 

func CreateOrUpdateVMAuthService(ctx context.Context, cr *victoriametricsv1beta1.VMAuth, rclient client.Client) (*corev1.Service, error)

CreateOrUpdateVMAuthService creates service for VMAuth

func CreateOrUpdateVMCluster 

func CreateOrUpdateVMCluster(ctx context.Context, cr *v1beta1.VMCluster, rclient client.Client, c *config.BaseOperatorConf) (string, error)

CreateOrUpdateVMCluster reconciled cluster object with order first we check status of vmStorage and waiting for its readiness then vmSelect and wait for it readiness as well and last one is vmInsert we manually handle statefulsets rolling updates needed in update checked by revesion status its controlled by k8s controller-manager

func CreateOrUpdateVMInsertService 

func CreateOrUpdateVMInsertService(ctx context.Context, cr *v1beta1.VMCluster, rclient client.Client, c *config.BaseOperatorConf) (*corev1.Service, error)

CreateOrUpdateVMInsertService reconciles vminsert services.

func CreateOrUpdateVMSelectService 

func CreateOrUpdateVMSelectService(ctx context.Context, cr *v1beta1.VMCluster, rclient client.Client, c *config.BaseOperatorConf) (*corev1.Service, error)

func CreateOrUpdateVMSingle 

func CreateOrUpdateVMSingle(ctx context.Context, cr *victoriametricsv1beta1.VMSingle, rclient client.Client, c *config.BaseOperatorConf) (*appsv1.Deployment, error)

func CreateOrUpdateVMSingleService 

func CreateOrUpdateVMSingleService(ctx context.Context, cr *victoriametricsv1beta1.VMSingle, rclient client.Client, c *config.BaseOperatorConf) (*corev1.Service, error)

func CreateOrUpdateVMStorageService 

func CreateOrUpdateVMStorageService(ctx context.Context, cr *v1beta1.VMCluster, rclient client.Client, c *config.BaseOperatorConf) (*corev1.Service, error)

func CreateVMServiceScrapeFromService 

func CreateVMServiceScrapeFromService(ctx context.Context, rclient client.Client, service *v1.Service, metricPath string, filterPortNames ...string) error

func CreateVMSingleStorage added in v0.10.0 

func CreateVMSingleStorage(ctx context.Context, cr *victoriametricsv1beta1.VMSingle, rclient client.Client, c *config.BaseOperatorConf) (*corev1.PersistentVolumeClaim, error)

func FetchCRDCache added in v0.15.0 

func FetchCRDCache(ctx context.Context, rclient client.Client, users []*v1beta1.VMUser) (map[string]string, error)

func GenVMStorageSpec 

func GenVMStorageSpec(cr *v1beta1.VMCluster, c *config.BaseOperatorConf) (*appsv1.StatefulSet, error)

func LoadRemoteWriteSecrets 

func LoadRemoteWriteSecrets(ctx context.Context, cr *victoriametricsv1beta1.VMAgent, rclient client.Client) (*scrapesSecretsCache, error)

func MakeVolumeClaimTemplate 

func MakeVolumeClaimTemplate(e victoriametricsv1beta1.EmbeddedPersistentVolumeClaim) *v1.PersistentVolumeClaim

func SelectPodScrapes added in v0.1.0 

func SelectPodScrapes(ctx context.Context, cr *victoriametricsv1beta1.VMAgent, rclient client.Client) (map[string]*victoriametricsv1beta1.VMPodScrape, error)

func SelectRules 

func SelectRules(ctx context.Context, cr *victoriametricsv1beta1.VMAlert, rclient client.Client) (map[string]string, error)

func SelectServiceScrapes added in v0.1.0 

func SelectServiceScrapes(ctx context.Context, cr *victoriametricsv1beta1.VMAgent, rclient client.Client) (map[string]*victoriametricsv1beta1.VMServiceScrape, error)

func SelectStaticScrapes added in v0.10.0 

func SelectStaticScrapes(ctx context.Context, cr *victoriametricsv1beta1.VMAgent, rclient client.Client) (map[string]*victoriametricsv1beta1.VMStaticScrape, error)

func SelectVMNodeScrapes added in v0.6.0 

func SelectVMNodeScrapes(ctx context.Context, cr *victoriametricsv1beta1.VMAgent, rclient client.Client) (map[string]*victoriametricsv1beta1.VMNodeScrape, error)

func SelectVMProbes added in v0.2.0 

func SelectVMProbes(ctx context.Context, cr *victoriametricsv1beta1.VMAgent, rclient client.Client) (map[string]*victoriametricsv1beta1.VMProbe, error)

Types

type BasicAuthCredentials 

type BasicAuthCredentials struct {
	// contains filtered or unexported fields
}

BasicAuthCredentials represents a username password pair to be used with basic http authentication, see https://tools.ietf.org/html/rfc7617.

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.