factory

package
v0.14.2 Latest Latest
Warning

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

 Go to latest Published: Apr 23, 2021 License: Apache-2.0 Imports: 41 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, rwsBasicAuth map[string]BasicAuthCredentials, rwsTokens map[string]BearerToken) []string

func CreateOrUpdateAlertManager 

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

func CreateOrUpdateAlertManagerService 

func CreateOrUpdateAlertManagerService(ctx context.Context, cr *victoriametricsv1beta1.VMAlertmanager, rclient client.Client, c *config.BaseOperatorConf) (*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, cr *victoriametricsv1beta1.VMAgent, rclient client.Client) 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)

we assume, that configmaps were created before this function was called

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 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 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, l logr.Logger) (map[string]BasicAuthCredentials, map[string]BearerToken, error)

func MakeVolumeClaimTemplate 

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

func PodIsReady 

func PodIsReady(pod corev1.Pod) bool

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.

type BearerToken 

type BearerToken string

BearerToken represents a bearer token, see https://tools.ietf.org/html/rfc6750.

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.