ClusterInterceptors
Tekton Triggers ships with the ClusterInterceptor
Custom Resource Definition (CRD), which allows you to implement a custom cluster-scoped Webhook-style Interceptor
.
A ClusterInterceptor
specifies an external Kubernetes v1 Service running custom business logic that receives the event payload from the
EventListener
via an HTTP request and returns a processed version of the payload along with an HTTP 200 response. The ClusterInterceptor
can also
halt processing if the event payload does not meet criteria you have configured as well as add extra fields that are accessible in the EventListener's
top-level extensions
field to other Interceptors
and ClusterInterceptors
chained with it and the associated TriggerBinding
.
Structure of a ClusterInterceptor
A ClusterInterceptor
definition consists of the following fields:
- Required:
apiVersion
- specifies the target API version, for exampletriggers.tekton.dev/v1alpha1
kind
- specifies that this Kubernetes resource is aClusterInterceptor
objectmetadata
- specifies data that uniquely identifies thisClusterInterceptor
object, for example aname
spec
- specifies the configuration information for thisClusterInterceptor
object, including:- [
clientConfig
] - specifies how a client, such as anEventListener
communicates with thisClusterInterceptor
object
- [
Configuring the client of the ClusterInterceptor
The clientConfig
field specifies the client, such as an EventListener
and how it communicates with the ClusterInterceptor
to exchange
event payload and other data. You can configure this field in one of the following ways:
- Specify the
url
field and as its value a URL at which the corresponding Kubernetes service listens for incoming requests from thisClusterInterceptor
- Specify the
service
field and within it reference the corresponding Kubernetes service that’s listening for incoming requests from thisClusterInterceptor
For example:
spec:
clientConfig:
url: "http://interceptor-svc.default.svc/"
---
spec:
clientConfig:
service:
name: "my-interceptor-svc"
namespace: "default"
path: "/optional-path" # optional
port: 8081 # defaults to 80
Configuring a Kubernetes Service for the ClusterInterceptor
The Kubernetes object running the custom business logic for your ClusterInterceptor
must meet the following criteria:
- Fronted by a regular Kubernetes v1 Service listening on an HTTP port (default port is 80)
- Accepts an HTTP
POST
request that contains anInterceptorRequest
as a JSON body - Returns an HTTP 200 OK response that contains an
InterceptorResponse
as a JSON body. If the trigger processing should continue, the interceptor should set thecontinue
field in the response totrue
. If the processing should be stopped, the interceptor should set thecontinue
field tofalse
and also provide additional information detailing the error in thestatus
field. - Returns a response other than HTTP 200 OK only if payload processing halts due to a catastrophic failure.
Running ClusterInterceptor as HTTPS
Triggers now run clusterinterceptor as https
server in order to support end to end secure connection and here is a TEP which gives more detail about this support.
By default Triggers run all core interceptor (GitHub, GitLab, BitBucket, CEL) as HTTPS
.
Triggers expose a new optional field caBundle
as part of clusterinterceptor spec.
Example:
spec:
clientConfig:
caBundle: <cert data>
service:
name: "my-interceptor-svc"
namespace: "default"
path: "/optional-path" # optional
port: 8443
Triggers uses knative pkg to generate key, cert, cacert and fill caBundle for core interceptors (GitHub, GitLab, BitBucket, CEL).
Triggers now support writing custom interceptor for both http
and https
. Support of http
for custom interceptor will be there for 1-2 releases, later it will be removed and only https
will be supported.
End user who write https
custom interceptor need to pass caBundle
as well as label
labels:
server/type: https
to ClusterInterceptor
in order to make secure connection with eventlistener.
Here is the reference for writing https server for custom interceptor.
Feedback
Was this page helpful?