eventsource

Documentation

Index

• func ServiceToPortMapping(svc *corev1.Service, es *esv1alpha1.EventSource) (out map[string]ingresscommon.NamedPath)
• type EventSourceIngressController
  • func NewEventSourceIngressController(esl eslister.EventSourceLister, svcl corev1lister.ServiceLister, ...) *EventSourceIngressController
  • func (e *EventSourceIngressController) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (e *EventSourceIngressController) SetIPGetter(name string, getter v1.IPGetter)
• type EventSourceIngressControllerConfig
  • func NewEventSourceIngressControllerConfig() EventSourceIngressControllerConfig
  • func (c *EventSourceIngressControllerConfig) GetKnownSources() map[string]bool
  • func (c *EventSourceIngressControllerConfig) SetIPGetter(name string, getter v1.IPGetter)

Functions

func ServiceToPortMapping

func ServiceToPortMapping(svc *corev1.Service, es *esv1alpha1.EventSource) (out map[string]ingresscommon.NamedPath)

ServiceToPortMapping - receives a Service and argo EventSource and returns a validated port lookup map of NamedPaths. The lookup map allows mapping a target port to a desired path. It is generic for any eventsource but only provides data for supported event source types, github and webhook currently.

Types

type EventSourceIngressController

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

func NewEventSourceIngressController

func NewEventSourceIngressController(esl eslister.EventSourceLister, svcl corev1lister.ServiceLister, config EventSourceIngressControllerConfig, igc v1.IngressConfigurator) *EventSourceIngressController

func (*EventSourceIngressController) Reconcile

func (e *EventSourceIngressController) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*EventSourceIngressController) SetIPGetter

func (e *EventSourceIngressController) SetIPGetter(name string, getter v1.IPGetter)

type EventSourceIngressControllerConfig

type EventSourceIngressControllerConfig struct {
	Gateway        types.NamespacedName
	BaseURL        string
	AdminNamespace string
	// contains filtered or unexported fields
}

func NewEventSourceIngressControllerConfig

func NewEventSourceIngressControllerConfig() EventSourceIngressControllerConfig

func (*EventSourceIngressControllerConfig) GetKnownSources

func (c *EventSourceIngressControllerConfig) GetKnownSources() map[string]bool

func (*EventSourceIngressControllerConfig) SetIPGetter

func (c *EventSourceIngressControllerConfig) SetIPGetter(name string, getter v1.IPGetter)