utils

Documentation

Index

• func CopySecret(corev1Input clientcorev1.CoreV1Interface, srcNS string, srcSecretName string, ...) (*corev1.Secret, error)
• func GenerateFixedName(owner metav1.Object, prefix string) string
• func GetClusterDomainName() string
• func ObjectRef(obj metav1.Object, gvk schema.GroupVersionKind) corev1.ObjectReference
• func PassThroughHeaders(headers http.Header) http.Header
• func ReceivingContextFrom(ctx context.Context) context.Context
• func SendingContextFrom(ctx context.Context, tctx cloudevents.HTTPTransportContext, targetURI *url.URL) context.Context
• func ToDNS1123Subdomain(name string) string

Functions

func CopySecret

func CopySecret(corev1Input clientcorev1.CoreV1Interface, srcNS string, srcSecretName string, tgtNS string, svcAccount string) (*corev1.Secret, error)

CopySecret will copy a secret from one namespace into another. If a ServiceAccount name is provided then it'll add it as a PullSecret to it. It'll either return a pointer to the new Secret or and error indicating why it couldn't do it.

func GenerateFixedName

func GenerateFixedName(owner metav1.Object, prefix string) string

GenerateFixedName generates a fixed name for the given owning resource and human readable prefix. The name's length will be short enough to be valid for K8s Services.

Deprecated, use knative.dev/pkg/kmeta.ChildName instead.

func GetClusterDomainName

func GetClusterDomainName() string

GetClusterDomainName returns cluster's domain name or an error Closes issue: https://github.com/knative/eventing/issues/714

func ObjectRef

func ObjectRef(obj metav1.Object, gvk schema.GroupVersionKind) corev1.ObjectReference

func PassThroughHeaders

func PassThroughHeaders(headers http.Header) http.Header

PassThroughHeaders extracts the headers from headers that are in the `forwardHeaders` set or has any of the prefixes in `forwardPrefixes`.

func ReceivingContextFrom

func ReceivingContextFrom(ctx context.Context) context.Context

ReceivingContextFrom filters the transport context headers using PassThroughHeaders after receiving an event using cloudevents.Client

func SendingContextFrom

func SendingContextFrom(ctx context.Context, tctx cloudevents.HTTPTransportContext, targetURI *url.URL) context.Context

SendingContextFrom creates the context to use when sending a Cloud Event with cloudevents.Client. It sets the target if specified, and attaches a filtered set of headers from the initial request.

func ToDNS1123Subdomain

func ToDNS1123Subdomain(name string) string

ToDNS1123Subdomain converts 'name' to a valid DNS1123 subdomain, required for object names in K8s.