factory

Documentation

Index

• func BuildRemoteWrites(remoteTargets []victoriametricsv1beta1.VMAgentRemoteWriteSpec, ...) []string
• func CreateOrUpdateAlertManager(ctx context.Context, cr *victoriametricsv1beta1.VMAlertmanager, ...) (*appsv1.StatefulSet, error)
• func CreateOrUpdateAlertManagerService(ctx context.Context, cr *victoriametricsv1beta1.VMAlertmanager, ...) (*v1.Service, error)
• func CreateOrUpdateConfigurationSecret(ctx context.Context, cr *victoriametricsv1beta1.VMAgent, rclient client.Client, ...) error
• func CreateOrUpdateRuleConfigMaps(ctx context.Context, cr *victoriametricsv1beta1.VMAlert, rclient client.Client) ([]string, error)
• func CreateOrUpdateTlsAssets(ctx context.Context, cr *victoriametricsv1beta1.VMAgent, rclient client.Client) error
• func CreateOrUpdateVMAgent(ctx context.Context, cr *victoriametricsv1beta1.VMAgent, rclient client.Client, ...) (reconcile.Result, error)
• func CreateOrUpdateVMAgentService(ctx context.Context, cr *victoriametricsv1beta1.VMAgent, rclient client.Client, ...) (*corev1.Service, error)
• func CreateOrUpdateVMAlert(ctx context.Context, cr *victoriametricsv1beta1.VMAlert, rclient client.Client, ...) (reconcile.Result, error)
• func CreateOrUpdateVMAlertService(ctx context.Context, cr *victoriametricsv1beta1.VMAlert, rclient client.Client, ...) (*corev1.Service, error)
• func CreateOrUpdateVMCluster(ctx context.Context, cr *v1beta1.VMCluster, rclient client.Client, ...) (string, error)
• func CreateOrUpdateVMInsertService(ctx context.Context, cr *v1beta1.VMCluster, rclient client.Client, ...) (*corev1.Service, error)
• func CreateOrUpdateVMSelectService(ctx context.Context, cr *v1beta1.VMCluster, rclient client.Client, ...) (*corev1.Service, error)
• func CreateOrUpdateVMSingle(ctx context.Context, cr *victoriametricsv1beta1.VMSingle, ...) (*appsv1.Deployment, error)
• func CreateOrUpdateVMSingleService(ctx context.Context, cr *victoriametricsv1beta1.VMSingle, ...) (*corev1.Service, error)
• func CreateOrUpdateVMStorageService(ctx context.Context, cr *v1beta1.VMCluster, rclient client.Client, ...) (*corev1.Service, error)
• func CreateVMServiceScrapeFromService(ctx context.Context, rclient client.Client, service *v1.Service, ...) error
• func CreateVMStorage(ctx context.Context, cr *victoriametricsv1beta1.VMSingle, ...) (*corev1.PersistentVolumeClaim, error)
• func GenVMStorageSpec(cr *v1beta1.VMCluster, c *conf.BaseOperatorConf) (*appsv1.StatefulSet, error)
• func LoadRemoteWriteSecrets(ctx context.Context, cr *victoriametricsv1beta1.VMAgent, rclient client.Client, ...) (map[string]BasicAuthCredentials, map[string]BearerToken, error)
• func MakeVolumeClaimTemplate(e victoriametricsv1beta1.EmbeddedPersistentVolumeClaim) *v1.PersistentVolumeClaim
• func MergePatchContainers(base, patches []v1.Container) ([]v1.Container, error)
• func PodIsReady(pod corev1.Pod) bool
• func SanitizeVolumeName(name string) string
• func SelectPodMonitors(ctx context.Context, cr *victoriametricsv1beta1.VMAgent, rclient client.Client) (map[string]*victoriametricsv1beta1.VMPodScrape, error)
• func SelectRules(ctx context.Context, cr *victoriametricsv1beta1.VMAlert, rclient client.Client) (map[string]string, error)
• func SelectServiceMonitors(ctx context.Context, cr *victoriametricsv1beta1.VMAgent, rclient client.Client) (map[string]*victoriametricsv1beta1.VMServiceScrape, error)
• type BasicAuthCredentials
• type BearerToken

Functions

func BuildRemoteWrites

func BuildRemoteWrites(remoteTargets []victoriametricsv1beta1.VMAgentRemoteWriteSpec, rwsBasicAuth map[string]BasicAuthCredentials, rwsTokens map[string]BearerToken) []string

func CreateOrUpdateAlertManager

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

func CreateOrUpdateAlertManagerService

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

func CreateOrUpdateConfigurationSecret

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

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 CreateOrUpdateVMAgent

func CreateOrUpdateVMAgent(ctx context.Context, cr *victoriametricsv1beta1.VMAgent, rclient client.Client, c *conf.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 *conf.BaseOperatorConf) (*corev1.Service, error)

func CreateOrUpdateVMAlert

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

func CreateOrUpdateVMAlertService

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

func CreateOrUpdateVMCluster

func CreateOrUpdateVMCluster(ctx context.Context, cr *v1beta1.VMCluster, rclient client.Client, c *conf.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 *conf.BaseOperatorConf) (*corev1.Service, error)

func CreateOrUpdateVMSelectService

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

func CreateOrUpdateVMSingle

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

func CreateOrUpdateVMSingleService

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

func CreateOrUpdateVMStorageService

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

func CreateVMServiceScrapeFromService

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

func CreateVMStorage

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

func GenVMStorageSpec

func GenVMStorageSpec(cr *v1beta1.VMCluster, c *conf.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 MergePatchContainers

func MergePatchContainers(base, patches []v1.Container) ([]v1.Container, error)

MergePatchContainers adds patches to base using a strategic merge patch and iterating by container name, failing on the first error

func PodIsReady

func PodIsReady(pod corev1.Pod) bool

func SanitizeVolumeName

func SanitizeVolumeName(name string) string

func SelectPodMonitors

func SelectPodMonitors(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 SelectServiceMonitors

func SelectServiceMonitors(ctx context.Context, cr *victoriametricsv1beta1.VMAgent, rclient client.Client) (map[string]*victoriametricsv1beta1.VMServiceScrape, 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.