Versions in this module Expand all Collapse all v0 v0.10.0 Nov 4, 2022 Changes in this version + const BusyboxImage + const BusyboxTag + const CMName + const ConduitPrefixLengthIpv4 + const ConduitPrefixLengthIpv6 + const FeServiceAccountEnv + const ImagePullSecretEnv + const IpamName + const IpamPort + const IpamSvcName + const IpamTargetPort + const LBName + const LogLevelEnv + const NSMRegistryServiceEnv + const NetworkServiceName + const NodePrefixLengthIpv4 + const NodePrefixLengthIpv6 + const NseName + const NspName + const NspPort + const NspServiceAccountEnv + const NspServiceAccountName + const NspSvcName + const NspTargetPort + const Organization + const OrganizationNsm + const PodDisruptionBudgetName + const ProxyName + const Registry + const ResourceNamePrefixEnv + const ResourceRequirementKey + const ResourceRequirementTemplatePath + const SubnetPoolIpv4 + const SubnetPoolIpv6 + const Tag + const VlanNsePort + var LivenessTimer = probeTimer + var ReadinessTimer = probeTimer + var StartUpTimer = probeTimer + func CompileEnvironmentVariables(allEnv []corev1.EnvVar, operatorEnv map[string]string) []corev1.EnvVar + func ConfigMapName(trench *meridiov1alpha1.Trench) string + func FEServiceAccountName() string + func GetContainerResourceRequirements(containerName, templateName string) (*corev1.ResourceRequirements, error) + func GetDaemonsetModel(f string) (*appsv1.DaemonSet, error) + func GetDeploymentModel(f string) (*appsv1.Deployment, error) + func GetExternalInterfaceName(attractor *meridiov1alpha1.Attractor) string + func GetIPFamily(cr *meridiov1alpha1.Trench) string + func GetImagePullSecrets() []corev1.LocalObjectReference + func GetLoadBalancerSysCtl(cr *meridiov1alpha1.Trench) string + func GetLogLevel() string + func GetNSMRegistryService() string + func GetPodDisruptionBudgetModel(f string) (*policyv1.PodDisruptionBudget, error) + func GetPodDisruptionBudgetVersion(client client.Client) (string, error) + func GetPrefixedName(resourceName string) string + func GetProbe(timer probeTimer, command []string) *corev1.Probe + func GetProbeCommand(spiffe bool, addr, svc string) []string + func GetProxySysCtl(cr *meridiov1alpha1.Trench) string + func GetResourceRequirementAnnotation(from *metav1.ObjectMeta) (string, bool) + func GetRoleBindingModel(f string) (*rbacv1.RoleBinding, error) + func GetRoleModel(f string) (*rbacv1.Role, error) + func GetServiceAccountModel(f string) (*corev1.ServiceAccount, error) + func GetServiceModel(f string) (*corev1.Service, error) + func GetStatefulSetModel(f string) (*appsv1.StatefulSet, error) + func GetSuffixedName(resourceName, suffix string) string + func GetTrenchBySelector(e *Executor, selector client.ObjectKey) (*meridiov1alpha1.Trench, error) + func IPAMServiceName(trench *meridiov1alpha1.Trench) string + func IPAMServiceWithPort(cr *meridiov1alpha1.Trench) string + func IPAMStatefulSetName(trench *meridiov1alpha1.Trench) string + func LbFeDeploymentName(attractor *meridiov1alpha1.Attractor) string + func LoadBalancerNsName(conduit, trench, namespace string) string + func NSEDeploymentName(attractor *meridiov1alpha1.Attractor) string + func NSPServiceAccountName() string + func NSPServiceName(trench *meridiov1alpha1.Trench) string + func NSPServiceWithPort(cr *meridiov1alpha1.Trench) string + func NSPStatefulSetName(trench *meridiov1alpha1.Trench) string + func NsName(meta metav1.ObjectMeta) string + func PDBName(attractir *meridiov1alpha1.Attractor) string + func PdbV1Beta1ToV1(pdb *policyv1beta1.PodDisruptionBudget) *policyv1.PodDisruptionBudget + func PdbV1ToV1Beta1(pdb *policyv1.PodDisruptionBudget) *policyv1beta1.PodDisruptionBudget + func ProxyDeploymentName(conduit *meridiov1alpha1.Conduit) string + func ProxyNtwkSvcNsName(cr *meridiov1alpha1.Conduit) string + func SetContainerResourceRequirements(from *metav1.ObjectMeta, container *corev1.Container) error + func SetResourceRequirementAnnotation(from *metav1.ObjectMeta, into *metav1.ObjectMeta) + func VlanNtwkSvcName(attractorCr *meridiov1alpha1.Attractor, trenchCr *meridiov1alpha1.Trench) string + type Action interface + Run func(e *Executor) (string, string, error) + func AppendActions(actions ...Action) []Action + type Executions interface + RunAll func(actions []Action) error + type Executor struct + func NewExecutor(s *runtime.Scheme, c client.Client, ct context.Context, cr client.Object, ...) *Executor + func (e *Executor) AddCreateAction(obj client.Object) + func (e *Executor) AddUpdateAction(obj client.Object) + func (e *Executor) AddUpdateStatusAction(obj client.Object) + func (e *Executor) GetObject(selector client.ObjectKey, obj client.Object) error + func (e *Executor) GetOwner() client.Object + func (e *Executor) ListObject(obj client.ObjectList, opts ...client.ListOption) error + func (e *Executor) LogError(err error, msg string) + func (e *Executor) LogInfo(msg string) + func (e *Executor) RunActions() error + func (e *Executor) SetControllerReference(obj client.Object) error + func (e *Executor) SetOwner(cr client.Object) + func (e *Executor) SetOwnerReference(obj client.Object, owners ...client.Object) error + type NamedResourceRequirements struct + Name string + Resources corev1.ResourceRequirements + type ResourceRequirementTemplates struct + Templates []NamedResourceRequirements