sink

Documentation

Index

• func GetURI(objRef *corev1.ObjectReference, ns string) (*url.URL, error)
• type Args
  • func GetArgs() (Args, error)
• type Clients
  • func ConfigureClients() (Clients, error)
• type Resource
  • func (r Resource) HandleEvent(response http.ResponseWriter, request *http.Request)

Functions

func GetURI

func GetURI(objRef *corev1.ObjectReference, ns string) (*url.URL, error)

GetURI retrieves the ObjectReference to URI.

Types

type Args

type Args struct {
	// ElName is the EventListener name.
	ElName string
	// ElNamespace is the EventListener namespace.
	ElNamespace string
	// Port is the port the Sink should listen on.
	Port string
}

Args define the arguments for Sink.

func GetArgs

func GetArgs() (Args, error)

GetArgs returns the flagged Args

type Clients

type Clients struct {
	DiscoveryClient discoveryclient.DiscoveryInterface
	RESTClient      restclient.Interface
	TriggersClient  triggersclientset.Interface
	PipelineClient  pipelineclientset.Interface
}

Clients define the set of client dependencies Sink requires.

func ConfigureClients

func ConfigureClients() (Clients, error)

ConfigureClients returns the kubernetes and triggers clientsets

type Resource

type Resource struct {
	TriggersClient         triggersclientset.Interface
	DiscoveryClient        discoveryclient.DiscoveryInterface
	RESTClient             restclient.Interface
	PipelineClient         pipelineclientset.Interface
	HTTPClient             *http.Client
	EventListenerName      string
	EventListenerNamespace string
}

Resource defines the sink resource for processing incoming events for the EventListener.

func (Resource) HandleEvent

func (r Resource) HandleEvent(response http.ResponseWriter, request *http.Request)

HandleEvent processes an incoming HTTP event for the event listener.