utils

package

Go to main page

Versions in this module

v0

v0.15.0

Oct 18, 2024

v0.14.0

Jun 24, 2024

v0.13.0

Feb 21, 2024

v0.12.0

Sep 26, 2023

v0.11.0

May 26, 2023

Changes in this version

+ func IsReadySubscription(clReader client.Reader, hub bool) bool

v0.10.0

Feb 7, 2023

v0.9.0

Oct 21, 2022

Changes in this version

+ func GetCheckSum(kubeconfigfile string) ([32]byte, error)

v0.8.0

Jul 10, 2022

v0.7.0

Mar 31, 2022

Changes in this version

+ const Error

+ var PlacementDecisionPredicateFunctions = predicate.Funcs

+ func CreateClusterManagementAddon(clt client.Client)

+ func GetClientConfigFromKubeConfig(kubeconfigFile string) (*rest.Config, error)

+ func IsReadyManagedClusterView(clReader client.Reader) bool

+ func UpdateLastUpdateTime(clt client.Client, instance *appv1.Subscription)

v0.6.0

Jan 18, 2022

Changes in this version

+ const ClientCert

+ const ClientKey

+ func DetectPlacementDecision(ctx context.Context, clReader client.Reader)

+ func IsReadyPlacementDecision(clReader client.Reader) bool

type ChannelConnectionCfg

+ ClientCert []byte

+ ClientKey []byte

v0.5.0

Nov 1, 2021

Changes in this version

+ var AppSubSummaryPredicateFunc = predicate.Funcs

+ var ConfigMapKindStr = "ConfigMap"

+ var SecretKindStr = "Secret"

+ var SercertReferredMarker = "IsReferredBySub-"

+ var SubscriptionGVK = schema.GroupVersionKind

+ func Base64StringDecode(encodedStr string) string

+ func CompareManifestWork(oldManifestWork, newManifestWork *manifestWorkV1.ManifestWork) bool

+ func CreateFailedAppsubReportResult(client client.Client, cluster string, appsubNs, appsubName, statusMsg string) error

+ func CreateHelmCRManifest(repoURL string, packageName string, chartVersions repo.ChartVersions, ...) (*unstructured.Unstructured, error)

+ func DeleteReferredObjects(clt client.Client, rq types.NamespacedName, gvk schema.GroupVersionKind) error

+ func FetchChannelReferences(clt client.Client, chn chnv1.Channel) (sec *corev1.Secret, cm *corev1.ConfigMap)

+ func GetAllowDenyLists(subscription appv1.Subscription) (map[string]map[string]string, map[string]map[string]string)

+ func GetHostSubscriptionNSFromObject(clusterNsManagedSubStatusName string) (string, string)

+ func GetTestGitRepoURLFromEnvVar() string

+ func IsHostingAppsub(appsub *appv1.Subscription) bool

+ func IsResourceAllowed(resource unstructured.Unstructured, allowlist map[string]map[string]string, ...) bool

+ func IsResourceDenied(resource unstructured.Unstructured, denyList map[string]map[string]string, ...) bool

+ func ListAndDeployReferredObject(clt client.Client, instance *appv1.Subscription, gvk schema.GroupVersionKind, ...) error

+ func ParseAPIVersion(apiVersion string) (string, string)

+ func ParseNamespacedName(namespacedName string) (string, string)

+ type ChannelConnectionCfg struct

+ CaCerts string

+ InsecureSkipVerify bool

+ Passphrase []byte

+ Password string

+ RepoURL string

+ SSHKey []byte

+ User string

+ func GetChannelConnectionConfig(secret *corev1.Secret, configmap *corev1.ConfigMap) (connCfg *ChannelConnectionCfg, err error)

type GitCloneOption

+ PrimaryConnectionOption *ChannelConnectionCfg

+ SecondaryConnectionOption *ChannelConnectionCfg

v0.4.0

Aug 26, 2021

Changes in this version

+ const AccessToken

+ const MIDNIGHT

+ const NoiseLogLel

+ const Passphrase

+ const QuiteLogLel

+ const SSHKey

+ const UserID

+ const VeryNoisy

+ var ChannelPredicateFunctions = predicate.Funcs

+ var DefaultRepos = map[string]map[string]string

+ var DeployablePredicateFunctions = predicate.Funcs

+ var PlacementRulePredicateFunctions = predicate.Funcs

+ var ServiceAccountPredicateFunctions = predicate.Funcs

+ var SubscriptionPredicateFunctions = predicate.Funcs

+ func AddPartOfLabel(s *appv1.Subscription, m map[string]string) map[string]string

+ func AllowApplyTemplate(localClient client.Client, template *unstructured.Unstructured) bool

+ func BuildKubeClient(kubeConfigPath string) (*kubernetes.Clientset, error)

+ func CanPassPackageFilter(filter *appv1.PackageFilter, obj objAnno) bool

+ func CheckAndInstallCRD(crdconfig *rest.Config, pathname string) error

+ func CheckPackageOverride(ov *appv1.Overrides) error

+ func CloneGitRepo(cloneOptions *GitCloneOption) (commitID string, err error)

+ func ConvertLabels(labelSelector *metav1.LabelSelector) (labels.Selector, error)

+ func CreateHelmCRDeployable(repoURL string, packageName string, chartVersions repo.ChartVersions, ...) (*dplv1.Deployable, error)

+ func CreateOrUpdateHelmChart(packageName string, releaseCRName string, chartVersions repo.ChartVersions, ...) (helmRelease *releasev1.HelmRelease, err error)

+ func DeleteDeployableCRD(runtimeClient client.Client, crdx *clientsetx.Clientset)

+ func DeleteHelmReleaseCRD(runtimeClient client.Client, crdx *clientsetx.Clientset)

+ func DeleteInClusterPackageStatus(substatus *appv1.SubscriptionStatus, pkgname string, pkgerr error, ...)

+ func DeleteSubscriptionCRD(runtimeClient client.Client, crdx *clientsetx.Clientset)

+ func DplArrayToDplPointers(dplList []dplv1alpha1.Deployable) []*dplv1alpha1.Deployable

+ func EnterFnString() string

+ func ExitFuString(s string)

+ func FilterCharts(sub *appv1.Subscription, indexFile *repo.IndexFile) error

+ func FilterOutTimeRelatedFields(in *appv1.Subscription) *appv1.Subscription

+ func GenerateHelmIndexFile(sub *appv1.Subscription, repoRoot string, chartDirs map[string]string) (*repo.IndexFile, error)

+ func GenerateServerCerts(dir string) error

+ func GenerateVersionSet(dplPointers []*dplv1alpha1.Deployable, vsub string) map[string]VersionRep

+ func GetChannelConfigMap(client client.Client, chn *chnv1.Channel) *corev1.ConfigMap

+ func GetChannelSecret(client client.Client, chn *chnv1.Channel) (string, string, []byte, []byte, error)

+ func GetClusterFromResourceObject(obj metav1.Object) *types.NamespacedName

+ func GetComponentNamespace() (string, error)

+ func GetFnName() string

+ func GetHostDeployable(hostAnnotation string) *types.NamespacedName

+ func GetHostDeployableFromObject(obj metav1.Object) *types.NamespacedName

+ func GetHostSubscriptionFromObject(obj metav1.Object) *types.NamespacedName

+ func GetKubeIgnore(resourcePath string) *gitignore.GitIgnore

+ func GetLatestCommitID(url, branch string, clt ...*github.Client) (string, error)

+ func GetLocalGitFolder(chn *chnv1.Channel, sub *appv1.Subscription) string

+ func GetPackageAlias(sub *appv1.Subscription, packageName string) string

+ func GetPauseLabel(instance *appv1.Subscription) bool

+ func GetReconcileInterval(reconcileRate, chType string) (time.Duration, time.Duration, int)

+ func GetReconcileRate(chnAnnotations, subAnnotations map[string]string) string

+ func GetReleaseName(base string) (string, error)

+ func GetSourceFromObject(obj metav1.Object) string

+ func GetSubscriptionBranch(sub *appv1.Subscription) plumbing.ReferenceName

+ func GetSubscriptionBranchRef(b string) plumbing.ReferenceName

+ func IsClusterAdmin(client client.Client, sub *appv1.Subscription, eventRecorder *EventRecorder) bool

+ func IsDeployableInVersionSet(vMap map[string]VersionRep, dpl *dplv1alpha1.Deployable) bool

+ func IsEqualSubScriptionStatus(o, n *appv1.SubscriptionStatus) bool

+ func IsGitChannel(chType string) bool

+ func IsHub(config *rest.Config) bool

+ func IsHubRelatedStatusChanged(old, nnew *appv1.SubscriptionStatus) bool

+ func IsInWindow(tw *appv1alpha1.TimeWindow, t time.Time) bool

+ func IsLocalDeployable(instance *dplv1.Deployable) bool

+ func IsResourceOwnedByCluster(obj metav1.Object, cluster types.NamespacedName) bool

+ func IsSubscriptionBasicChanged(o, n *appv1.Subscription) bool

+ func IsSubscriptionBeDeleted(clt client.Client, subKey types.NamespacedName) bool

+ func IsSubscriptionResourceChanged(oSub, nSub *appv1.Subscription) bool

+ func IsURL(str string) bool

+ func KeywordsChecker(labelSelector *metav1.LabelSelector, ks []string) bool

+ func KubeResourceParser(file []byte, cond Kube) [][]byte

+ func LabelChecker(ls *metav1.LabelSelector, dplls map[string]string) bool

+ func LabelsChecker(labelSelector *metav1.LabelSelector, ls map[string]string) bool

+ func MatchLabelForSubAndDpl(ls *metav1.LabelSelector, dplls map[string]string) bool

+ func NamespacedNameFormat(str string) types.NamespacedName

+ func NextStartPoint(tw *appv1alpha1.TimeWindow, t time.Time) time.Duration

+ func NextStatusReconcile(tw *appv1alpha1.TimeWindow, t time.Time) time.Duration

+ func Override(helmRelease *releasev1.HelmRelease, sub *appv1.Subscription) error

+ func OverrideKustomize(pov appv1.PackageOverride, kustomizeDir string) error

+ func OverrideResourceBySubscription(template *unstructured.Unstructured, pkgName string, ...) (*unstructured.Unstructured, error)

+ func OverrideTemplate(template *unstructured.Unstructured, overrides []appv1alpha1.ClusterOverride) (*unstructured.Unstructured, error)

+ func ParseChannelSecret(secret *corev1.Secret) (string, string, []byte, []byte, error)

+ func ParseKubeResoures(file []byte) [][]byte

+ func ParseYAML(fileContent []byte) []string

+ func PkgToReleaseCRName(sub *appv1.Subscription, packageName string) (string, error)

+ func PrepareOverrides(cluster types.NamespacedName, instance *appv1alpha1.Deployable) ([]appv1alpha1.ClusterOverride, error)

+ func PrintSubscriptionStatus(a *subv1.SubscriptionStatus)

+ func RemoveSubAnnotations(obj *unstructured.Unstructured) *unstructured.Unstructured

+ func RemoveSubOwnerRef(obj *unstructured.Unstructured) *unstructured.Unstructured

+ func RunKustomizeBuild(kustomizeDir string) ([]byte, error)

+ func SemverCheck(vSubStr, vDplStr string) bool

+ func SetInClusterPackageStatus(substatus *appv1.SubscriptionStatus, pkgname string, pkgerr error, ...) error

+ func SetPartOfLabel(s *appv1.Subscription, rsc *unstructured.Unstructured)

+ func SkipHooksOnManaged(resourcePath, curPath string) bool

+ func SkipOrUpdateSubscriptionStatus(clt client.Client, oldSub *appv1.Subscription) error

+ func SortResources(repoRoot, resourcePath string, skips ...SkipFunc) (map[string]string, map[string]string, []string, []string, []string, error)

+ func UnifyTimeZone(tw *appv1alpha1.TimeWindow, t time.Time) time.Time

+ func UpdateCRDs(p string, tRepo []string, logger logr.Logger) error

+ func UpdateDeployableStatus(statusClient client.Client, templateerr error, tplunit metav1.Object, ...) error

+ func UpdateSubscriptionStatus(statusClient client.Client, templateerr error, tplunit metav1.Object, ...) error

+ func ValidateK8sLabel(s string) string

+ func ValidatePackagesInSubscriptionStatus(statusClient client.StatusClient, sub *appv1.Subscription, ...) error

+ func VerifyAndOverrideKustomize(packageOverrides []*appv1.Overrides, relativePath, kustomizeDir string)

+ type EventRecorder struct

+ func NewEventRecorder(cfg *rest.Config, scheme *apiruntime.Scheme) (*EventRecorder, error)

+ func (rec *EventRecorder) RecordEvent(obj apiruntime.Object, reason, msg string, err error)

+ type GitCloneOption struct

+ Branch plumbing.ReferenceName

+ CaCerts string

+ CloneDepth int

+ CommitHash string

+ DestDir string

+ InsecureSkipVerify bool

+ Passphrase []byte

+ Password string

+ RepoURL string

+ RevisionTag string

+ SSHKey []byte

+ User string

+ type Kube func(KubeResource) bool

+ type KubeResource struct

+ type SkipFunc func(string, string) bool

+ type VersionRep struct

+ DplKey string

+ Vrange string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL