configcheck

Documentation

Index

• Constants
• Variables
• type ConfigCheck
  • func New(config []byte, c client.Client, cs *kubernetes.Clientset, ...) *ConfigCheck
  • func (cc *ConfigCheck) CleanAll(ctx context.Context) error
  • func (cc *ConfigCheck) ConfigReloaderInitContainer() *corev1.Container
  • func (cc *ConfigCheck) Run(ctx context.Context) (string, error)

Constants

const (
	ConfigCheckInitiatorVector    = "VectorInitiator"
	ConfigCheckInitiatorPipieline = "PipelineInitiator"
)

Variables

var (
	ValidationError         = errors.New("config validation error")
	ConfigcheckTimeoutError = errors.New("timeout waiting configcheck pod result")
)

Types

type ConfigCheck

type ConfigCheck struct {
	Config []byte

	Client    client.Client
	ClientSet *kubernetes.Clientset

	Name                     string
	Namespace                string
	Initiator                string
	Image                    string
	ImagePullPolicy          corev1.PullPolicy
	ImagePullSecrets         []corev1.LocalObjectReference
	Envs                     []corev1.EnvVar
	Hash                     string
	Tolerations              []corev1.Toleration
	Resources                corev1.ResourceRequirements
	SecurityContext          *corev1.PodSecurityContext
	ContainerSecurityContext *corev1.SecurityContext
	CompressedConfig         bool
	ConfigReloaderImage      string
	ConfigReloaderResources  corev1.ResourceRequirements
	ConfigCheckTimeout       time.Duration
}

func New

func New(
	config []byte,
	c client.Client,
	cs *kubernetes.Clientset,
	va *vectorv1alpha1.Vector,
	timeout time.Duration,
) *ConfigCheck

func (*ConfigCheck) CleanAll

func (cc *ConfigCheck) CleanAll(ctx context.Context) error

func (*ConfigCheck) ConfigReloaderInitContainer

func (cc *ConfigCheck) ConfigReloaderInitContainer() *corev1.Container

func (*ConfigCheck) Run

func (cc *ConfigCheck) Run(ctx context.Context) (string, error)