Documentation
¶
Index ¶
- func CreateCapp(k8sClient client.Client, capp *cappv1alpha1.Capp) *cappv1alpha1.Capp
- func CreateCappWithHTTPHostname(k8sClient client.Client) (*cappv1alpha1.Capp, string)
- func CreateCappWithLogger(logType cappv1alpha1.LogType, client client.Client) *cappv1alpha1.Capp
- func CreateCredentialsSecret(logType cappv1alpha1.LogType, client client.Client)
- func CreateExcludedServiceAccount(k8sClient client.Client)
- func CreateHTTPSCapp(k8sClient client.Client) (*cappv1alpha1.Capp, string)
- func CreateSecret(k8sClient client.Client, secret *corev1.Secret)
- func CreateTestUser(k8sClient client.Client, namespace string)
- func DeleteCapp(k8sClient client.Client, capp *cappv1alpha1.Capp)
- func DeleteExcludedServiceAccount(k8sClient client.Client)
- func DeleteTestUser(k8sClient client.Client, namespace string)
- func DoesResourceExist(k8sClient client.Client, obj client.Object) bool
- func GenerateCappName() string
- func GenerateCertSecretName(hostname string) string
- func GenerateResourceName(hostname, suffix string) string
- func GenerateRouteHostname() string
- func GenerateSecretName() string
- func GenerateUniqueCappName(baseCappName string) string
- func GetCapp(k8sClient client.Client, name string, namespace string) *cappv1alpha1.Capp
- func GetCappConfig(k8sClient client.Client, name string, namespace string) *cappv1alpha1.CappConfig
- func GetCappRevision(k8sClient client.Client, cappRevisionName, namespace string) *cappv1alpha1.CappRevision
- func GetCappRevisions(ctx context.Context, k8sClient client.Client, capp cappv1alpha1.Capp) ([]cappv1alpha1.CappRevision, error)
- func GetCertificate(k8sClient client.Client, name string, namespace string) *cmapi.Certificate
- func GetClusterResource(k8sClient client.Client, obj client.Object, name string)
- func GetDNSRecord(k8sClient client.Client, name, namespace string) *dnsrecordv1alpha1.CNAMERecord
- func GetDomainMapping(k8sClient client.Client, name string, namespace string) *knativev1beta1.DomainMapping
- func GetKSVC(k8sClient client.Client, name string, namespace string) *knativev1.Service
- func GetNFSPVC(k8sClient client.Client, name string, namespace string) *nfspvcv1alpha1.NfsPvc
- func GetNextRevisionName(currentRevision string) string
- func GetResource(k8sClient client.Client, obj client.Object, name, namespace string)
- func GetRevision(k8sClient client.Client, name string, namespace string) *knativev1.Revision
- func GetSecret(k8sClient client.Client, name string, namespace string) *corev1.Secret
- func GetSyslogNGFlow(k8sClient client.Client, name string, namespace string) *loggingv1beta1.SyslogNGFlow
- func GetSyslogNGOutput(k8sClient client.Client, name string, namespace string) *loggingv1beta1.SyslogNGOutput
- func NewRetryOnConflictBackoff() wait.Backoff
- func RandomName(prefix string) string
- func SwitchUser(k8sClient *client.Client, cfg *rest.Config, namespace string, ...)
- func UpdateCapp(k8sClient client.Client, capp *cappv1alpha1.Capp)
- func UpdateResource(k8sClient client.Client, object client.Object) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CreateCapp ¶
func CreateCapp(k8sClient client.Client, capp *cappv1alpha1.Capp) *cappv1alpha1.Capp
CreateCapp creates a new Capp instance with a unique name and returns it.
func CreateCappWithHTTPHostname ¶
func CreateCappWithHTTPHostname(k8sClient client.Client) (*cappv1alpha1.Capp, string)
CreateCappWithHTTPHostname creates a Capp with a Hostname.
func CreateCappWithLogger ¶
func CreateCappWithLogger(logType cappv1alpha1.LogType, client client.Client) *cappv1alpha1.Capp
CreateCappWithLogger creates a Capp instance with the specified logger type and returns the created Capp object.
func CreateCredentialsSecret ¶
func CreateCredentialsSecret(logType cappv1alpha1.LogType, client client.Client)
CreateCredentialsSecret creates a Kubernetes secret containing credentials for the specified logger type.
func CreateExcludedServiceAccount ¶
CreateExcludedServiceAccount configures a service account that should be excluded from the mutating webhook.
func CreateHTTPSCapp ¶
func CreateHTTPSCapp(k8sClient client.Client) (*cappv1alpha1.Capp, string)
CreateHTTPSCapp creates a Capp with a Hostname, TLS Enabled and TLSSecret.
func CreateSecret ¶
CreateSecret creates a new secret.
func CreateTestUser ¶
CreateTestUser creates a test user with the specified Kubernetes client and namespace.
func DeleteCapp ¶
func DeleteCapp(k8sClient client.Client, capp *cappv1alpha1.Capp)
DeleteCapp deletes an existing Capp instance.
func DeleteExcludedServiceAccount ¶
DeleteExcludedServiceAccount deletes the excluded user created in the specified namespace.
func DeleteTestUser ¶
DeleteTestUser deletes the test user created in the specified namespace.
func DoesResourceExist ¶
DoesResourceExist checks if a given Kubernetes object exists in the cluster.
func GenerateCappName ¶
func GenerateCappName() string
GenerateCappName generates a new name for Capp.
func GenerateCertSecretName ¶
GenerateCertSecretName generates a capp cert secret name.
func GenerateResourceName ¶
GenerateResourceName generates the hostname based on the provided suffix and a dot (".") trailing character. It returns the adjusted hostname, where the suffix (minus the trailing character) is added if not already present.
func GenerateRouteHostname ¶
func GenerateRouteHostname() string
GenerateRouteHostname generates a new route hostname by calling generateName with the predefined RouteHostname as the baseName.
func GenerateSecretName ¶
func GenerateSecretName() string
GenerateSecretName generates a new secret name by calling generateName with the predefined RouteTlsSecret as the baseName.
func GenerateUniqueCappName ¶
GenerateUniqueCappName generates a unique Capp name.
func GetCappConfig ¶
func GetCappConfig(k8sClient client.Client, name string, namespace string) *cappv1alpha1.CappConfig
GetCappConfig fetches and returns an existing instance of an existing cappConfig
func GetCappRevision ¶
func GetCappRevision(k8sClient client.Client, cappRevisionName, namespace string) *cappv1alpha1.CappRevision
GetCappRevision retrieves a CappRevision by name.
func GetCappRevisions ¶
func GetCappRevisions(ctx context.Context, k8sClient client.Client, capp cappv1alpha1.Capp) ([]cappv1alpha1.CappRevision, error)
GetCappRevisions retrieves a list of CappRevision resources filtered by labels matching a specific Capp, returning the list and any error encountered.
func GetCertificate ¶
GetCertificate fetches and returns an existing instance of a Certificate.
func GetClusterResource ¶
GetClusterResource fetches an existing Cluster resource and returns an instance of it.
func GetDNSRecord ¶
func GetDNSRecord(k8sClient client.Client, name, namespace string) *dnsrecordv1alpha1.CNAMERecord
GetDNSRecord fetches and returns an existing instance of a CNAMERecord.
func GetDomainMapping ¶
func GetDomainMapping(k8sClient client.Client, name string, namespace string) *knativev1beta1.DomainMapping
GetDomainMapping fetches and returns an existing instance of a DomainMapping.
func GetNextRevisionName ¶
GetNextRevisionName generates the name for the next revision based on the current revision name.
func GetResource ¶
GetResource fetches an existing resource and returns an instance of it.
func GetRevision ¶
GetRevision fetches and returns an existing instance of a Knative Revision.
func GetSyslogNGFlow ¶
func GetSyslogNGFlow(k8sClient client.Client, name string, namespace string) *loggingv1beta1.SyslogNGFlow
GetSyslogNGFlow fetches existing and returns an instance of a SyslogNGFlow.
func GetSyslogNGOutput ¶
func GetSyslogNGOutput(k8sClient client.Client, name string, namespace string) *loggingv1beta1.SyslogNGOutput
GetSyslogNGOutput fetches existing and returns an instance of a SyslogNGOutput.
func NewRetryOnConflictBackoff ¶
NewRetryOnConflictBackoff returns a preconfigured backoff for RetryOnConflict.
func RandomName ¶
RandomName generates random names like kafka-source-x7k9p2
func SwitchUser ¶
func SwitchUser(k8sClient *client.Client, cfg *rest.Config, namespace string, scheme *runtime.Scheme, serviceAccountName string)
SwitchUser switches the Kubernetes client's user context to the given serviceAccountName if it's not empty. If serviceAccountName is empty, it reverts to the original context.
func UpdateCapp ¶
func UpdateCapp(k8sClient client.Client, capp *cappv1alpha1.Capp)
UpdateCapp updates the provided Capp instance in the Kubernetes cluster, and returns it.
Types ¶
This section is empty.
Source Files