Documentation ¶
Index ¶
- type Args
- type AuthOverride
- type Clients
- type DefaultAuthOverride
- type Response
- type Sink
- func (r Sink) CreateResources(sa string, res []json.RawMessage, triggerName, eventID string, ...) error
- func (r Sink) ExecuteInterceptors(t *triggersv1.EventListenerTrigger, in *http.Request, event []byte, ...) ([]byte, http.Header, error)
- func (r Sink) HandleEvent(response http.ResponseWriter, request *http.Request)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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.
type AuthOverride ¶
type AuthOverride interface { OverrideAuthentication(sa string, namespace string, log *zap.SugaredLogger, defaultDiscoveryClient discoveryclient.ServerResourcesInterface, defaultDynamicClient dynamic.Interface) (discoveryClient discoveryclient.ServerResourcesInterface, dynamicClient dynamic.Interface, err error) }
AuthOverride is an interface that constructs a discovery client for the ServerResourceInterface and a dynamic client for the Tekton Resources, using the token provide as the bearer token in the REST config used to build those client. The other non-credential related parameters for the REST client used are copied from the in cluster config of the event sink.
type Clients ¶
type Clients struct { DiscoveryClient discoveryclient.DiscoveryInterface RESTClient restclient.Interface TriggersClient triggersclientset.Interface }
Clients define the set of client dependencies Sink requires.
type DefaultAuthOverride ¶
type DefaultAuthOverride struct { }
func (DefaultAuthOverride) OverrideAuthentication ¶
func (r DefaultAuthOverride) OverrideAuthentication(sa string, namespace string, log *zap.SugaredLogger, defaultDiscoverClient discoveryclient.ServerResourcesInterface, defaultDynamicClient dynamic.Interface) (discoveryClient discoveryclient.ServerResourcesInterface, dynamicClient dynamic.Interface, err error)
type Response ¶
type Response struct { // EventListener is the name of the eventListener EventListener string `json:"eventListener"` // Namespace is the namespace that the eventListener is running in Namespace string `json:"namespace,omitempty"` // EventID is a uniqueID that gets assigned to each incoming request EventID string `json:"eventID,omitempty"` }
Response defines the HTTP body that the Sink responds to events with.
type Sink ¶
type Sink struct { KubeClientSet kubernetes.Interface TriggersClient triggersclientset.Interface DiscoveryClient discoveryclient.ServerResourcesInterface DynamicClient dynamic.Interface HTTPClient *http.Client EventListenerName string EventListenerNamespace string Logger *zap.SugaredLogger Auth AuthOverride // listers index properties about resources EventListenerLister listers.EventListenerLister TriggerLister listers.TriggerLister TriggerBindingLister listers.TriggerBindingLister ClusterTriggerBindingLister listers.ClusterTriggerBindingLister TriggerTemplateLister listers.TriggerTemplateLister }
Sink defines the sink resource for processing incoming events for the EventListener.
func (Sink) CreateResources ¶
func (r Sink) CreateResources(sa string, res []json.RawMessage, triggerName, eventID string, log *zap.SugaredLogger) error
func (Sink) ExecuteInterceptors ¶
func (r Sink) ExecuteInterceptors(t *triggersv1.EventListenerTrigger, in *http.Request, event []byte, log *zap.SugaredLogger) ([]byte, http.Header, error)
func (Sink) HandleEvent ¶
func (r Sink) HandleEvent(response http.ResponseWriter, request *http.Request)
HandleEvent processes an incoming HTTP event for the event listener.