controller

Documentation

Index

• Constants
• func CreateControlledCloudflaredIfNotExist(ctx context.Context, kubeClient client.Client, ...) error
• func FromIngressToExposure(ctx context.Context, kubeClient client.Client, ingress networkingv1.Ingress) ([]exposure.Exposure, error)
• func RegisterIngressController(logger logr.Logger, mgr manager.Manager, options IngressControllerOptions) error
• type IngressController
  • func NewIngressController(logger logr.Logger, kubeClient client.Client, ingressClassName string, ...) *IngressController
  • func (i *IngressController) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)
• type IngressControllerOptions

Constants

const IngressControllerFinalizer = "strrl.dev/cloudflare-tunnel-ingress-controller-controlled"

const WellKnownIngressAnnotation = "kubernetes.io/ingress.class"

Functions

func CreateControlledCloudflaredIfNotExist

func CreateControlledCloudflaredIfNotExist(
	ctx context.Context,
	kubeClient client.Client,
	tunnelClient *cloudflarecontroller.TunnelClient,
	namespace string,
) error

func FromIngressToExposure

func FromIngressToExposure(ctx context.Context, kubeClient client.Client, ingress networkingv1.Ingress) ([]exposure.Exposure, error)

func RegisterIngressController

func RegisterIngressController(logger logr.Logger, mgr manager.Manager, options IngressControllerOptions) error

Types

type IngressController

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

func NewIngressController

func NewIngressController(logger logr.Logger, kubeClient client.Client, ingressClassName string, controllerClassName string, tunnelClient *cloudflarecontroller.TunnelClient) *IngressController

func (*IngressController) Reconcile

func (i *IngressController) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)

type IngressControllerOptions

type IngressControllerOptions struct {
	IngressClassName    string
	ControllerClassName string
	CFTunnelClient      *cloudflarecontroller.TunnelClient
}