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.

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.