utils

Documentation

Index

• func GenerateFixedName(owner metav1.Object, prefix string) string
• func GetClusterDomainName() string
• func NewBlockingStart(logger *zap.Logger, runnable manager.Runnable) manager.Runnable
• func ObjectRef(obj metav1.Object, gvk schema.GroupVersionKind) corev1.ObjectReference
• func ToDNS1123Subdomain(name string) string
• type RunnableServer
  • func (r *RunnableServer) Start(stopCh <-chan struct{}) error

Functions

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 NewBlockingStart

func NewBlockingStart(logger *zap.Logger, runnable manager.Runnable) manager.Runnable

NewBlockingStart creates a wrapper around the provided runnable that will block until either the runnable returns a non-nil error or the stop channel is closed.

func ObjectRef

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

func ToDNS1123Subdomain

func ToDNS1123Subdomain(name string) string

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

Types

type RunnableServer

type RunnableServer struct {
	// Server is the http.Server to wrap.
	*http.Server

	// ServeFunc is the function used to start the http.Server. If nil,
	// ListenAndServe() will be used.
	ServeFunc func() error

	// ShutdownTimeout is the duration to wait for the http.Server to gracefully
	// shut down when the stop channel is closed. If this is zero or negative,
	// the http.Server will be immediately closed instead.
	ShutdownTimeout time.Duration

	// WaitGroup is a temporary workaround for Manager returning immediately
	// without waiting for Runnables to stop. See
	// https://github.com/kubernetes-sigs/controller-runtime/issues/350.
	WaitGroup *sync.WaitGroup
}

RunnableServer is a small wrapper around http.Server so that it matches the manager.Runnable interface.

func (*RunnableServer) Start

func (r *RunnableServer) Start(stopCh <-chan struct{}) error

Start the server. The server will be shut down when StopCh is closed.