route

Documentation

Index

• Constants
• Variables
• func GetControllerRef(o *metav1.ObjectMeta) *metav1.OwnerReference
• type Exposer
  • func NewExposer(underlyingExposer challengeexposers.Interface, ...) *Exposer
  • func (e *Exposer) Expose(c *acme.Client, domain string, token string) error
  • func (e *Exposer) Remove(domain string) error
• type RouteController
  • func NewRouteController(acmeClientFactory *acmeclientbuilder.SharedClientFactory, ...) *RouteController
  • func (rc *RouteController) Run(workers int, stopCh <-chan struct{})

Constants

const (
	RouterAdmitTimeout  = 30 * time.Second
	GeneratedAnnotation = "acme.openshift.io/generated"
)

const (
	ControllerName = "openshift-acme-controller"
	// Raise this when we have separate rate limiting for ACME.
	// Now it will get eventually reconciled when informers re-sync or on edit.
	MaxRetries               = 2
	RenewalStandardDeviation = 1
	RenewalMean              = 0
	AcmeTimeout              = 60 * time.Second
)

Variables

var (
	KeyFunc = cache.DeletionHandlingMetaNamespaceKeyFunc
)

Functions

func GetControllerRef

func GetControllerRef(o *metav1.ObjectMeta) *metav1.OwnerReference

TODO: move to a package

Types

type Exposer

type Exposer struct {
	// contains filtered or unexported fields
}

func NewExposer

func NewExposer(underlyingExposer challengeexposers.Interface,
	routeClientset routeclientset.Interface,
	kubeClientset kubernetes.Interface,
	recorder record.EventRecorder,
	exposerIP string,
	exposerPort int32,
	selfNamespace string,
	selfSelector map[string]string,
	route *routev1.Route,
) *Exposer

func (*Exposer) Expose

func (e *Exposer) Expose(c *acme.Client, domain string, token string) error

func (*Exposer) Remove

func (e *Exposer) Remove(domain string) error

type RouteController

type RouteController struct {
	// contains filtered or unexported fields
}

func NewRouteController

func NewRouteController(
	acmeClientFactory *acmeclientbuilder.SharedClientFactory,
	exposers map[string]challengeexposers.Interface,
	routeClientset routeclientset.Interface,
	kubeClientset kubernetes.Interface,
	routeInformer cache.SharedIndexInformer,
	secretInformer cache.SharedIndexInformer,
	exposerIP string,
	exposerPort int32,
	selfNamespace string,
	selfSelector map[string]string,
	defaultRouteTermination routev1.InsecureEdgeTerminationPolicyType,
) *RouteController

func (*RouteController) Run

func (rc *RouteController) Run(workers int, stopCh <-chan struct{})